Implement channel_set_cmux_policy_everywhere()

This commit is contained in:
Andrea Shepard 2012-10-01 20:05:03 -07:00
parent 13972aee78
commit 8afe41b481
2 changed files with 19 additions and 0 deletions

View File

@ -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 * Clean up channels
* *

View File

@ -291,6 +291,9 @@ void channel_free_all(void);
void channel_dumpstats(int severity); void channel_dumpstats(int severity);
void channel_listener_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 #ifdef _TOR_CHANNEL_INTERNAL
/* Channel operations for subclasses and internal use only */ /* Channel operations for subclasses and internal use only */