From: Stephan Bosch Date: Sun, 18 Dec 2016 18:13:00 +0000 (+0100) Subject: lib-http: client: peer: Moved http_client_peer_connect_backoff() function. X-Git-Tag: 2.3.0.rc1~255 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=4a9bd6a8552df6ca229f13ffd5eee1d3a3343af8;p=thirdparty%2Fdovecot%2Fcore.git lib-http: client: peer: Moved http_client_peer_connect_backoff() function. This is a preparation for a subsequent change. --- diff --git a/src/lib-http/http-client-peer.c b/src/lib-http/http-client-peer.c index 32deb39976..081ed90fa5 100644 --- a/src/lib-http/http-client-peer.c +++ b/src/lib-http/http-client-peer.c @@ -199,6 +199,9 @@ void http_client_peer_pool_unref(struct http_client_peer_pool **_ppool) static bool http_client_peer_start_backoff_timer(struct http_client_peer *peer); +static void +http_client_peer_do_connect(struct http_client_peer *peer, + unsigned int count); const char * http_client_peer_label(struct http_client_peer *peer) @@ -217,6 +220,24 @@ http_client_peer_label(struct http_client_peer *peer) return peer->label; } +static void +http_client_peer_connect_backoff(struct http_client_peer *peer) +{ + i_assert(peer->to_backoff != NULL); + + http_client_peer_debug(peer, + "Backoff timer expired"); + + timeout_remove(&peer->to_backoff); + + if (array_count(&peer->queues) == 0) { + http_client_peer_close(&peer); + return; + } + + http_client_peer_do_connect(peer, 1); +} + static struct http_client_peer * http_client_peer_create(struct http_client *client, const struct http_client_peer_addr *addr) @@ -411,24 +432,6 @@ http_client_peer_do_connect(struct http_client_peer *peer, } } -static void -http_client_peer_connect_backoff(struct http_client_peer *peer) -{ - i_assert(peer->to_backoff != NULL); - - http_client_peer_debug(peer, - "Backoff timer expired"); - - timeout_remove(&peer->to_backoff); - - if (array_count(&peer->queues) == 0) { - http_client_peer_close(&peer); - return; - } - - http_client_peer_do_connect(peer, 1); -} - static bool http_client_peer_start_backoff_timer(struct http_client_peer *peer) {