lib-http: client: If a peer object is no longer linked to a queue, don't close it...

The peer object is canceled, rather than closed. Which means that any newly started and idle connections are closed immediately.
Requests may be pending though.
This is only relevant when hosts/queues are removed at some point.
This is a preparational change for having a maximum lifetime on hosts/queues, in which case this becomes a possibility.

diff --git a/src/lib-http/http-client-peer.c b/src/lib-http/http-client-peer.c
index 44b44716f9c952b86765c004afc9b99344c9182b..22b52ae97bd2d8cb568a6e01e84b05958a608995 100644 (file)
--- a/src/lib-http/http-client-peer.c
+++ b/src/lib-http/http-client-peer.c
@@ -200,6 +200,23 @@ bool http_client_peer_is_connected(struct http_client_peer *peer)
        return FALSE;
 }
 
+static void
+http_client_peer_cancel(struct http_client_peer *peer)
+{
+       struct http_client_connection **conn;
+       ARRAY_TYPE(http_client_connection) conns;
+
+       http_client_peer_debug(peer, "Peer cancel");
+
+       /* make a copy of the connection array; freed connections modify it */
+       t_array_init(&conns, array_count(&peer->conns));
+       array_copy(&conns.arr, 0, &peer->conns.arr, 0, array_count(&peer->conns));
+       array_foreach_modifiable(&conns, conn) {
+               if (!http_client_connection_is_active(*conn))
+                       http_client_connection_close(conn);
+       }
+}
+
 static unsigned int
 http_client_peer_requests_pending(struct http_client_peer *peer,
                                  unsigned int *num_urgent_r)
@@ -253,13 +270,13 @@ http_client_peer_handle_requests_real(struct http_client_peer *peer)
        /* FIXME: limit the number of requests handled in one run to prevent
           I/O starvation. */
 
-       /* disconnect if we're not linked to any queue anymore */
+       /* disconnect pending connections if we're not linked to any queue
+          anymore */
        if (array_count(&peer->queues) == 0) {
-               i_assert(peer->to_backoff != NULL);
                http_client_peer_debug(peer,
-                       "Peer no longer used; will now disconnect "
+                       "Peer no longer used; will now cancel pending connections "
                        "(%u connections exist)", array_count(&peer->conns));
-               http_client_peer_close(&peer);
+               http_client_peer_cancel(peer);
                return;
        }