From 2fc3da3ff51f3fe7fa5338c2d6b52a06ed9c4f19 Mon Sep 17 00:00:00 2001 From: Andrea Shepard Date: Mon, 11 Nov 2013 21:50:16 -0800 Subject: Implement global queue size query in channel.c --- src/or/channel.c | 10 ++++++++++ src/or/channel.h | 1 + 2 files changed, 11 insertions(+) diff --git a/src/or/channel.c b/src/or/channel.c index f729a17be9..e2d102d2ac 100644 --- a/src/or/channel.c +++ b/src/or/channel.c @@ -4035,6 +4035,16 @@ channel_mark_outgoing(channel_t *chan) * Flow control queries * ***********************/ +/* + * Get the latest estimate for the total queue size of all open channels + */ + +uint64_t +channel_get_global_queue_estimate(void) +{ + return estimated_total_queue_size; +} + /* * Estimate the number of writeable cells * diff --git a/src/or/channel.h b/src/or/channel.h index 388c729953..18f7cfc01e 100644 --- a/src/or/channel.h +++ b/src/or/channel.h @@ -484,6 +484,7 @@ void channel_listener_dump_transport_statistics(channel_listener_t *chan_l, int severity); /* Flow control queries */ +uint64_t channel_get_global_queue_estimate(void); int channel_num_cells_writeable(channel_t *chan); /* Timestamp queries */ -- cgit v1.2.3-54-g00ecf