diff options
| author | David Goulet <dgoulet@torproject.org> | 2018-02-15 14:34:53 -0500 |
|---|---|---|
| committer | David Goulet <dgoulet@torproject.org> | 2018-02-15 14:54:24 -0500 |
| commit | e19cd38f08a67ed6bfb6f9ab174c134c41885af4 (patch) | |
| tree | 8061310fd38164c5a259b655b902f8338d33cf79 /src | |
| parent | c235c32bbcd33351d0d720fe2fb3dbac6369d12c (diff) | |
| download | tor-e19cd38f08a67ed6bfb6f9ab174c134c41885af4.tar.gz tor-e19cd38f08a67ed6bfb6f9ab174c134c41885af4.zip | |
cmux: Always use the cmux policy
Remove the checks on cmux->policy since it should always be set.
Signed-off-by: David Goulet <dgoulet@torproject.org>
Diffstat (limited to 'src')
| -rw-r--r-- | src/or/circuitmux.c | 10 | ||||
| -rw-r--r-- | src/test/test_circuitlist.c | 1 |
2 files changed, 5 insertions, 6 deletions
diff --git a/src/or/circuitmux.c b/src/or/circuitmux.c index e601ffa55e..f9f5faa057 100644 --- a/src/or/circuitmux.c +++ b/src/or/circuitmux.c @@ -458,9 +458,7 @@ circuitmux_clear_policy(circuitmux_t *cmux) tor_assert(cmux); /* Internally, this is just setting policy to NULL */ - if (cmux->policy) { - circuitmux_set_policy(cmux, NULL); - } + circuitmux_set_policy(cmux, NULL); } /** @@ -884,7 +882,7 @@ circuitmux_attach_circuit,(circuitmux_t *cmux, circuit_t *circ, hashent->muxinfo.cell_count = cell_count; hashent->muxinfo.direction = direction; /* Allocate policy specific circuit data if we need it */ - if (cmux->policy && cmux->policy->alloc_circ_data) { + if (cmux->policy->alloc_circ_data) { /* Assert that we have the means to free policy-specific data */ tor_assert(cmux->policy->free_circ_data); /* Allocate it */ @@ -1085,7 +1083,7 @@ circuitmux_set_num_cells(circuitmux_t *cmux, circuit_t *circ, cmux->n_cells += n_cells; /* Do we need to notify a cmux policy? */ - if (cmux->policy && cmux->policy->notify_set_n_cells) { + if (cmux->policy->notify_set_n_cells) { /* Call notify_set_n_cells */ cmux->policy->notify_set_n_cells(cmux, cmux->policy_data, @@ -1210,7 +1208,7 @@ circuitmux_notify_xmit_cells(circuitmux_t *cmux, circuit_t *circ, * We call notify_xmit_cells() before making the circuit inactive if needed, * so the policy can always count on this coming in on an active circuit. */ - if (cmux->policy && cmux->policy->notify_xmit_cells) { + if (cmux->policy->notify_xmit_cells) { cmux->policy->notify_xmit_cells(cmux, cmux->policy_data, circ, hashent->muxinfo.policy_data, n_cells); diff --git a/src/test/test_circuitlist.c b/src/test/test_circuitlist.c index d170009a9c..3794ffc2c6 100644 --- a/src/test/test_circuitlist.c +++ b/src/test/test_circuitlist.c @@ -9,6 +9,7 @@ #include "channel.h" #include "circuitbuild.h" #include "circuitlist.h" +#include "circuitmux_ewma.h" #include "hs_circuitmap.h" #include "test.h" #include "log_test_helpers.h" |