From c62f15cc134cc9701c391eec8e9ef92105aa6d33 Mon Sep 17 00:00:00 2001 From: Stephan Bosch Date: Thu, 15 Sep 2016 22:49:54 +0200 Subject: [PATCH] lib-http: client: Added http_client_queue_requests_active(). It counts how many active requests a queue has. --- src/lib-http/http-client-private.h | 2 ++ src/lib-http/http-client-queue.c | 6 ++++++ 2 files changed, 8 insertions(+) diff --git a/src/lib-http/http-client-private.h b/src/lib-http/http-client-private.h index 0a5c58b0dd..4f13542aee 100644 --- 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 c303268946..8262dd57b4 100644 --- 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 */ -- 2.47.3