lib-http: client: Added http_client_queue_requests_active().

It counts how many active requests a queue has.

diff --git a/src/lib-http/http-client-private.h b/src/lib-http/http-client-private.h
index 0a5c58b0dd8758afbe99fc8865780194ba63086d..4f13542aeea24790a93fe4f7095b916237b12b0b 100644 (file)
--- a/src/lib-http/http-client-private.h
+++ b/src/lib-http/http-client-private.h
@@ -489,6 +489,8 @@ http_client_queue_claim_request(struct http_client_queue *queue,
 unsigned int
 http_client_queue_requests_pending(struct http_client_queue *queue,
        unsigned int *num_urgent_r) ATTR_NULL(2);
+unsigned int
+http_client_queue_requests_active(struct http_client_queue *queue);
 void
 http_client_queue_connection_success(struct http_client_queue *queue,
                                         const struct http_client_peer_addr *addr);

diff --git a/src/lib-http/http-client-queue.c b/src/lib-http/http-client-queue.c
index c3032689461067c8844477b8bb0834160db377a3..8262dd57b4031718dfc7df659b936295189b9f5e 100644 (file)
--- a/src/lib-http/http-client-queue.c
+++ b/src/lib-http/http-client-queue.c
@@ -904,6 +904,12 @@ http_client_queue_requests_pending(struct http_client_queue *queue,
        return array_count(&queue->queued_requests) + urg_count;
 }
 
+unsigned int
+http_client_queue_requests_active(struct http_client_queue *queue)
+{
+       return array_count(&queue->requests);
+}
+
 /*
  * ioloop
  */