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 d8402454db38edc4e97f3df2b2f735600410fa27..0cc9fd4958bf496da4f728558d7f2da168c532b9 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
  */