struct http_client_connection *conn = *_conn;
struct http_client_request **req;
+ http_client_connection_debug(conn, "Aborting connection: %s", error);
+
conn->connected = FALSE;
conn->closing = TRUE;
}
}
+ http_client_connection_debug(conn,
+ "Aborting connection with temporary error: %s", error);
+
conn->connected = FALSE;
conn->closing = TRUE;
"SSL handshaking to %s failed: Connection timed out in %u.%03u secs",
_conn->name, msecs/1000, msecs%1000);
}
+ http_client_connection_debug(conn, "%s", error);
http_client_connection_retry_requests(conn,
HTTP_CLIENT_REQUEST_ERROR_TIMED_OUT, error);
break;
error = _conn->input == NULL ? "Connection lost" :
t_strdup_printf("Connection lost: %s",
strerror(_conn->input->stream_errno));
+ http_client_connection_debug(conn, "%s", error);
http_client_connection_retry_requests(conn,
HTTP_CLIENT_REQUEST_ERROR_CONNECTION_LOST, error);
default:
if (conn->peer->addr.https_name != NULL) {
if (http_client_connection_ssl_init(conn, &error) < 0) {
http_client_peer_connection_failure(conn->peer, error);
+ http_client_connection_debug(conn, "%s", error);
http_client_connection_unref(&conn);
}
return;
conn->connect_start_timestamp = ioloop_timeval;
if (connection_client_connect(&conn->conn) < 0) {
conn->connect_errno = errno;
+ http_client_connection_debug(conn, "Connect failed: %m");
conn->to_input = timeout_add_short(0,
http_client_connection_delayed_connect_error, conn);
return;
if (num_urgent == 0 &&
working_conn_count >= peer->client->set.max_parallel_connections) {
/* no */
- if (conn == NULL)
+ if (conn == NULL) {
+ http_client_peer_debug(peer,
+ "Only non-urgent requests, and we already have "
+ "%u pending connections", working_conn_count);
return FALSE;
+ }
/* pipeline it */
return http_client_connection_next_request(conn);
}
} else {
new_connections = (num_urgent > connecting ? num_urgent - connecting : 0);
}
+ http_client_peer_debug(peer,
+ "Creating %u new connections to handle requests "
+ "(already %u usable, connecting to %u, closing %u)",
+ new_connections, working_conn_count - connecting,
+ connecting, closing);
http_client_peer_connect(peer, new_connections);
/* now we wait until it is connected */