From 8afe41b481caa984fa6b4a0fbbf626d4cd22ce59 Mon Sep 17 00:00:00 2001 From: Andrea Shepard Date: Mon, 1 Oct 2012 20:05:03 -0700 Subject: Implement channel_set_cmux_policy_everywhere() --- src/or/channel.c | 16 ++++++++++++++++ src/or/channel.h | 3 +++ 2 files changed, 19 insertions(+) diff --git a/src/or/channel.c b/src/or/channel.c index 4ad5bf15f..880fa63ca 100644 --- a/src/or/channel.c +++ b/src/or/channel.c @@ -2695,6 +2695,22 @@ channel_listener_dumpstats(int severity) } } +/** + * Set the cmux policy on all active channels + */ + +void +channel_set_cmux_policy_everywhere(circuitmux_policy_t *pol) +{ + if (!active_channels) return; + + SMARTLIST_FOREACH_BEGIN(active_channels, channel_t *, curr) { + if (curr->cmux) { + circuitmux_set_policy(curr->cmux, pol); + } + } SMARTLIST_FOREACH_END(curr); +} + /** * Clean up channels * diff --git a/src/or/channel.h b/src/or/channel.h index 4d3db41ce..cb9835a9f 100644 --- a/src/or/channel.h +++ b/src/or/channel.h @@ -291,6 +291,9 @@ void channel_free_all(void); void channel_dumpstats(int severity); void channel_listener_dumpstats(int severity); +/* Set the cmux policy on all active channels */ +void channel_set_cmux_policy_everywhere(circuitmux_policy_t *pol); + #ifdef _TOR_CHANNEL_INTERNAL /* Channel operations for subclasses and internal use only */ -- cgit v1.2.3