Lines Matching refs:peer
124 /* currently only called when peer is freed, so there is no need to
125 unlink from the peer */
129 struct http_client_peer *peer = queue->cur_peer;
131 http_client_peer_unlink_queue(peer, queue);
246 /* continue with current peer */
283 /* setup connection to new peer (can start new soft timeout) */
292 struct http_client_peer *peer;
314 /* update our peer address */
323 /* already got a peer? */
324 peer = NULL;
344 peer = queue->cur_peer;
346 /* peer is not relevant to this queue anymore */
353 if (peer == NULL)
354 peer = http_client_peer_get(queue->client, addr);
360 /* create provisional link between queue and peer */
361 http_client_peer_link_queue(peer, queue);
364 http_client_peer_trigger_request_handler(peer);
366 if (http_client_peer_is_connected(peer)) {
378 queue->cur_peer = peer;
389 /* we may be waiting for this peer already */
393 i_assert(*peer_idx == peer);
402 array_append(&queue->pending_peers, &peer, 1);
418 return peer;
447 struct http_client_peer *peer)
449 const struct http_client_peer_addr *addr = &peer->shared->addr;
475 if (*peer_idx == peer) {
477 connected peer, even if some of the connections
484 /* unlink this queue from the peer; if this was the last/only queue, the
485 peer will be freed, closing all connections.
497 struct http_client_peer *peer, const char *reason)
501 const struct http_client_peer_addr *addr = &peer->shared->addr;
517 i_assert(queue->cur_peer == peer);
528 if (*peer_idx == peer) {
539 http_client_peer_unlink_queue(peer, queue);
549 http_client_peer_unlink_queue(peer, queue);
574 http_client_peer_unlink_queue(peer, queue);
583 if (http_client_queue_connection_attempt(queue) != peer) {
584 http_client_peer_unlink_queue(peer, queue);
592 struct http_client_peer *peer)
596 if (queue->cur_peer == peer) {
602 if (*peer_idx == peer) {
989 "Connection to peer %s claimed request %s %s",