Fix a bug where streams would linger forever when we had no dirinfo

fixes bug 8387; fix on 0.1.1.11-alpha (code), or on 0.2.4.10-alpha (behavior).
This commit is contained in:
Nick Mathewson 2014-07-09 16:14:14 -04:00
parent f5ce580bab
commit ed3d7892c7
4 changed files with 38 additions and 6 deletions

11
changes/bug8387 Normal file
View File

@ -0,0 +1,11 @@
o Major bugfixes (client):
- Perform circuit cleanup operations even when circuit
construction operations are disabled (because the network is
disabled, or because there isn't enough directory information).
Previously, when we were not building predictive circuits, we
were not closing expired circuits either.
Fixes bug 8387; bugfix on 0.1.1.11-alpha. This bug became visible
in 0.2.4.10-alpha when we became more strict about when we have
"enough directory information to build circuits".

View File

@ -969,7 +969,6 @@ circuit_predict_and_launch_new(void)
void void
circuit_build_needed_circs(time_t now) circuit_build_needed_circs(time_t now)
{ {
static time_t time_to_new_circuit = 0;
const or_options_t *options = get_options(); const or_options_t *options = get_options();
/* launch a new circ for any pending streams that need one */ /* launch a new circ for any pending streams that need one */
@ -978,14 +977,34 @@ circuit_build_needed_circs(time_t now)
/* make sure any hidden services have enough intro points */ /* make sure any hidden services have enough intro points */
rend_services_introduce(); rend_services_introduce();
if (time_to_new_circuit < now) { circuit_expire_old_circs_as_needed(now);
if (!options->DisablePredictedCircuits)
circuit_predict_and_launch_new();
}
/**
* Called once a second either directly or from
* circuit_build_needed_circs(). As appropriate (once per NewCircuitPeriod)
* resets failure counts and expires old circuits.
*/
void
circuit_expire_old_circs_as_needed(time_t now)
{
static time_t time_to_expire_and_reset = 0;
if (time_to_expire_and_reset < now) {
circuit_reset_failure_count(1); circuit_reset_failure_count(1);
time_to_new_circuit = now + options->NewCircuitPeriod; time_to_expire_and_reset = now + get_options()->NewCircuitPeriod;
if (proxy_mode(get_options())) if (proxy_mode(get_options()))
addressmap_clean(now); addressmap_clean(now);
circuit_expire_old_circuits_clientside(); circuit_expire_old_circuits_clientside();
#if 0 /* disable for now, until predict-and-launch-new can cull leftovers */ #if 0 /* disable for now, until predict-and-launch-new can cull leftovers */
/* If we ever re-enable, this has to move into
* circuit_build_needed_circs */
circ = circuit_get_youngest_clean_open(CIRCUIT_PURPOSE_C_GENERAL); circ = circuit_get_youngest_clean_open(CIRCUIT_PURPOSE_C_GENERAL);
if (get_options()->RunTesting && if (get_options()->RunTesting &&
circ && circ &&
@ -995,8 +1014,6 @@ circuit_build_needed_circs(time_t now)
} }
#endif #endif
} }
if (!options->DisablePredictedCircuits)
circuit_predict_and_launch_new();
} }
/** If the stream <b>conn</b> is a member of any of the linked /** If the stream <b>conn</b> is a member of any of the linked

View File

@ -21,6 +21,7 @@ int circuit_conforms_to_options(const origin_circuit_t *circ,
const or_options_t *options); const or_options_t *options);
#endif #endif
void circuit_build_needed_circs(time_t now); void circuit_build_needed_circs(time_t now);
void circuit_expire_old_circs_as_needed(time_t now);
void circuit_detach_stream(circuit_t *circ, edge_connection_t *conn); void circuit_detach_stream(circuit_t *circ, edge_connection_t *conn);
void circuit_expire_old_circuits_serverside(time_t now); void circuit_expire_old_circuits_serverside(time_t now);

View File

@ -1485,8 +1485,11 @@ run_scheduled_events(time_t now)
* and we make a new circ if there are no clean circuits. * and we make a new circ if there are no clean circuits.
*/ */
have_dir_info = router_have_minimum_dir_info(); have_dir_info = router_have_minimum_dir_info();
if (have_dir_info && !net_is_disabled()) if (have_dir_info && !net_is_disabled()) {
circuit_build_needed_circs(now); circuit_build_needed_circs(now);
} else {
circuit_expire_old_circs_as_needed(now);
}
/* every 10 seconds, but not at the same second as other such events */ /* every 10 seconds, but not at the same second as other such events */
if (now % 10 == 5) if (now % 10 == 5)