diff options
author | Roger Dingledine <arma@torproject.org> | 2009-09-06 23:14:13 -0400 |
---|---|---|
committer | Mike Perry <mikeperry-git@fscked.org> | 2009-09-16 15:55:32 -0700 |
commit | 672e2f6908fda52897c9564b756de743692d1d55 (patch) | |
tree | 75d0db87f240c4c73d3a386607ec553e74baa535 | |
parent | 4b3bc714a3f5253470e1feab80bfd30744d34d44 (diff) | |
download | tor-672e2f6908fda52897c9564b756de743692d1d55.tar.gz tor-672e2f6908fda52897c9564b756de743692d1d55.zip |
space/indent cleanups, plus point out three bugs
-rw-r--r-- | src/or/circuitbuild.c | 63 | ||||
-rw-r--r-- | src/or/circuituse.c | 2 | ||||
-rw-r--r-- | src/or/config.c | 11 | ||||
-rw-r--r-- | src/or/or.h | 6 | ||||
-rw-r--r-- | src/or/test.c | 6 |
5 files changed, 49 insertions, 39 deletions
diff --git a/src/or/circuitbuild.c b/src/or/circuitbuild.c index 3fa446faac..50faac1702 100644 --- a/src/or/circuitbuild.c +++ b/src/or/circuitbuild.c @@ -20,12 +20,13 @@ * and random segfaults due to memory corruption (and * not even at calls to log() either!) */ + /* XXX022 somebody should rename Tor's log() function, so we can + * remove this wart. -RD */ #undef log /* - * Linux doesn't provide lround in math.h by default, - * but mac os does... Its best just to leave math.h - * out of the picture entirely. + * Linux doesn't provide lround in math.h by default, but mac os does... + * It's best just to leave math.h out of the picture entirely. */ //#define log math_h_log //#include <math.h> @@ -86,6 +87,8 @@ static smartlist_t *entry_guards = NULL; * and those changes need to be flushed to disk. */ static int entry_guards_dirty = 0; +/** If set, we're running the unit tests: we should avoid clobbering + * our state file. */ static int unit_tests = 0; /********* END VARIABLES ************/ @@ -101,12 +104,15 @@ static int onion_append_hop(crypt_path_t **head_ptr, extend_info_t *choice); static void entry_guards_changed(void); static time_t start_of_month(time_t when); +/** Make a note that we're running unit tests (rather than running Tor + * itself), so we avoid clobbering our state file. */ void circuitbuild_running_unit_tests(void) { unit_tests = 1; } +/** DOCDOC */ void circuit_build_times_reset(circuit_build_times_t *cbt) { @@ -117,6 +123,7 @@ circuit_build_times_reset(circuit_build_times_t *cbt) cbt->computed = 0; } +/** DOCDOC */ void circuit_build_times_init(circuit_build_times_t *cbt) { @@ -176,6 +183,7 @@ circuit_build_times_max(circuit_build_times_t *cbt) return max_build_time; } +/** DOCDOC */ static build_time_t circuit_build_times_min(circuit_build_times_t *cbt) { @@ -183,7 +191,7 @@ circuit_build_times_min(circuit_build_times_t *cbt) build_time_t min_build_time = BUILD_TIME_MAX; for (i = 0; i < NCIRCUITS_TO_OBSERVE; i++) { if (cbt->circuit_build_times[i] && /* 0 <-> uninitialized */ - cbt->circuit_build_times[i] < min_build_time) + cbt->circuit_build_times[i] < min_build_time) min_build_time = cbt->circuit_build_times[i]; } if (min_build_time == BUILD_TIME_MAX) { @@ -217,6 +225,7 @@ circuit_build_times_create_histogram(circuit_build_times_t *cbt, return histogram; } +/** DOCDOC */ static build_time_t circuit_build_times_mode(circuit_build_times_t *cbt) { @@ -236,7 +245,6 @@ circuit_build_times_mode(circuit_build_times_t *cbt) /** * output a histogram of current circuit build times. - * */ void circuit_build_times_update_state(circuit_build_times_t *cbt, @@ -283,14 +291,14 @@ circuit_build_times_shuffle_array(circuit_build_times_t *cbt) /* This code can only be run on a compact array */ tor_assert(cbt->total_build_times == cbt->build_times_idx); while (n-- > 1) { - int k = crypto_rand_int(n + 1); /* 0 <= k <= n. */ + int k = crypto_rand_int(n + 1); /* 0 <= k <= n. */ build_time_t tmp = cbt->circuit_build_times[k]; cbt->circuit_build_times[k] = cbt->circuit_build_times[n]; cbt->circuit_build_times[n] = tmp; } } -/** Load histogram from state */ +/** Load histogram from <b>state</b>. DOCDOC what else? */ int circuit_build_times_parse_state(circuit_build_times_t *cbt, or_state_t *state, char **msg) @@ -298,16 +306,17 @@ circuit_build_times_parse_state(circuit_build_times_t *cbt, int tot_values = 0, N = 0; config_line_t *line; int i; - msg = NULL; + msg = NULL; /* XXX is this a bug? should be *msg, or we'll seg fault + * if we try to set it */ circuit_build_times_init(cbt); /* We don't support decreasing the table size yet */ tor_assert(state->TotalBuildTimes <= NCIRCUITS_TO_OBSERVE); for (line = state->BuildtimeHistogram; line; line = line->next) { - smartlist_t * args = smartlist_create(); + smartlist_t *args = smartlist_create(); smartlist_split_string(args, line->value, " ", - SPLIT_SKIP_SPACE|SPLIT_IGNORE_BLANK, 0); + SPLIT_SKIP_SPACE|SPLIT_IGNORE_BLANK, 0); if (smartlist_len(args) < 2) { *msg = tor_strdup("Unable to parse circuit build times: " "Too few arguments to CircuitBuildTime"); @@ -357,9 +366,10 @@ circuit_build_times_parse_state(circuit_build_times_t *cbt, tor_assert(cbt->total_build_times == state->TotalBuildTimes); tor_assert(tot_values == cbt->total_build_times); circuit_build_times_set_timeout(cbt); - return (msg ? -1 : 0); + return msg ? -1 : 0; } +/** DOCDOC */ void circuit_build_times_update_alpha(circuit_build_times_t *cbt) { @@ -454,13 +464,14 @@ circuit_build_times_add_timeout_worker(circuit_build_times_t *cbt, if (gentime < (build_time_t)cbt->timeout*1000) { log_warn(LD_CIRC, - "Generated a synthetic timeout LESS than the current timeout: %u vs %d", - gentime, cbt->timeout*1000); + "Generated a synthetic timeout LESS than the current timeout: " + "%u vs %d", gentime, cbt->timeout*1000); tor_assert(gentime >= (build_time_t)cbt->timeout*1000); } else if (gentime > BUILD_TIME_MAX) { gentime = BUILD_TIME_MAX; log_info(LD_CIRC, - "Generated a synthetic timeout larger than the max: %u", gentime); + "Generated a synthetic timeout larger than the max: %u", + gentime); } else { log_info(LD_CIRC, "Generated synthetic time %u for timeout", gentime); } @@ -491,7 +502,7 @@ circuit_build_times_count_pretimeouts(circuit_build_times_t *cbt) cbt->Xm = circuit_build_times_min(cbt); // Use current timeout to get an estimate on alpha circuit_build_times_initial_alpha(cbt, timeout_quantile, - cbt->timeout*1000); + cbt->timeout*1000); while (cbt->pre_timeouts-- != 0) { circuit_build_times_add_timeout_worker(cbt, timeout_quantile); } @@ -515,7 +526,7 @@ int circuit_build_times_needs_circuits_now(circuit_build_times_t *cbt) { return circuit_build_times_needs_circuits(cbt) && - approx_time()-cbt->last_circ_at > BUILD_TIMES_TEST_FREQUENCY; + approx_time()-cbt->last_circ_at > BUILD_TIMES_TEST_FREQUENCY; } void @@ -568,7 +579,7 @@ circuit_build_times_check_too_many_timeouts(circuit_build_times_t *cbt) } log_notice(LD_CIRC, - "Network connection type appears to have changed. " + "Network connection speed appears to have changed. " "Resetting timeouts."); if (Xm >= (build_time_t)cbt->timeout*1000) { @@ -577,8 +588,8 @@ circuit_build_times_check_too_many_timeouts(circuit_build_times_t *cbt) /* No circuits have completed */ cbt->timeout *= 2; log_warn(LD_CIRC, - "Adjusting CircuitBuildTimeout to %d in the hopes that " - "some connections will succeed", cbt->timeout); + "Adjusting CircuitBuildTimeout to %d in the hopes that " + "some connections will succeed", cbt->timeout); goto reset; } } @@ -593,9 +604,9 @@ circuit_build_times_check_too_many_timeouts(circuit_build_times_t *cbt) cbt->timeout = lround(timeout/1000.0); log_notice(LD_CIRC, - "Reset circuit build timeout to %d (%lf, Xm: %d, a: %lf) based on " - "%d recent circuit times", cbt->timeout, timeout, cbt->Xm, - cbt->alpha, RECENT_CIRCUITS); + "Reset circuit build timeout to %d (%lf, Xm: %d, a: %lf) based " + "on %d recent circuit times", cbt->timeout, timeout, cbt->Xm, + cbt->alpha, RECENT_CIRCUITS); reset: @@ -638,9 +649,9 @@ circuit_build_times_set_timeout(circuit_build_times_t *cbt) if (cbt->total_build_times < MIN_CIRCUITS_TO_OBSERVE) { log_info(LD_CIRC, - "Not enough circuits yet to calculate a new build timeout." - " Need %d more.", - MIN_CIRCUITS_TO_OBSERVE-cbt->total_build_times); + "Not enough circuits yet to calculate a new build timeout." + " Need %d more.", + MIN_CIRCUITS_TO_OBSERVE-cbt->total_build_times); return; } @@ -653,7 +664,7 @@ circuit_build_times_set_timeout(circuit_build_times_t *cbt) cbt->timeout = lround(timeout/1000.0); log_info(LD_CIRC, - "Set circuit build timeout to %d (%lf, Xm: %d, a: %lf) based on " + "Set circuit build timeout to %d (%lf, Xm: %d, a: %lf) based on " "%d circuit times", cbt->timeout, timeout, cbt->Xm, cbt->alpha, cbt->total_build_times); diff --git a/src/or/circuituse.c b/src/or/circuituse.c index 4162790ec3..f6a41665d1 100644 --- a/src/or/circuituse.c +++ b/src/or/circuituse.c @@ -861,6 +861,7 @@ circuit_build_failed(origin_circuit_t *circ) circuit_increment_failure_count(); /* Don't increment failure count, since Bob may have picked * the introduction point maliciously */ + /* XXX Mike, you didn't read my comment above! :) -RD */ /* Alice will pick a new intro point when this one dies, if * the stream in question still cares. No need to act here. */ break; @@ -875,6 +876,7 @@ circuit_build_failed(origin_circuit_t *circ) circuit_increment_failure_count(); /* Don't increment failure count, since Alice may have picked * the rendezvous point maliciously */ + /* XXX Mike, you didn't read my comment above! :) -RD */ log_info(LD_REND, "Couldn't connect to Alice's chosen rend point %s " "(%s hop failed).", diff --git a/src/or/config.c b/src/or/config.c index 1505dc3e4e..cd222595b5 100644 --- a/src/or/config.c +++ b/src/or/config.c @@ -409,9 +409,9 @@ static config_var_t _state_vars[] = { V(LastRotatedOnionKey, ISOTIME, NULL), V(LastWritten, ISOTIME, NULL), - VAR("TotalBuildTimes", UINT, TotalBuildTimes, NULL), - VAR("CircuitBuildTimeBin", LINELIST_S, BuildtimeHistogram, NULL), - VAR("BuildtimeHistogram", LINELIST_V, BuildtimeHistogram, NULL), + V("TotalBuildTimes", UINT, NULL), + VAR("CircuitBuildTimeBin", LINELIST_S, BuildtimeHistogram, NULL), + VAR("BuildtimeHistogram", LINELIST_V, BuildtimeHistogram, NULL), { NULL, CONFIG_TYPE_OBSOLETE, 0, NULL } }; @@ -5068,13 +5068,10 @@ or_state_set(or_state_t *new_state) log_warn(LD_GENERAL,"Unparseable bandwidth history state: %s",err); tor_free(err); } - - if (circuit_build_times_parse_state(&circ_times, global_state, &err) < 0) { + if (circuit_build_times_parse_state(&circ_times, global_state, &err) < 0) { log_warn(LD_GENERAL,"%s",err); tor_free(err); - } - } /** Reload the persistent state from disk, generating a new state as needed. diff --git a/src/or/or.h b/src/or/or.h index 6f4ad4516d..5462784503 100644 --- a/src/or/or.h +++ b/src/or/or.h @@ -2871,7 +2871,7 @@ void entry_guards_free_all(void); typedef uint32_t build_time_t; #define BUILD_TIME_MAX ((build_time_t)(INT32_MAX)) -/* Have we recieved a cell in the last 90 seconds? */ +/* Have we received a cell in the last 90 seconds? */ #define NETWORK_LIVE_INTERVAL 90 #define BUILD_TIMEOUT_INITIAL_VALUE 60 @@ -2898,8 +2898,8 @@ typedef struct { extern circuit_build_times_t circ_times; void circuit_build_times_update_state(circuit_build_times_t *cbt, or_state_t *state); -int circuit_build_times_parse_state(circuit_build_times_t *cbt, - or_state_t *state, char **msg); +int circuit_build_times_parse_state(circuit_build_times_t *cbt, + or_state_t *state, char **msg); void circuit_build_times_add_timeout(circuit_build_times_t *cbt); void circuit_build_times_set_timeout(circuit_build_times_t *cbt); int circuit_build_times_add_time(circuit_build_times_t *cbt, diff --git a/src/or/test.c b/src/or/test.c index 7228425241..06bfccece6 100644 --- a/src/or/test.c +++ b/src/or/test.c @@ -3472,7 +3472,7 @@ test_circuit_timeout(void) log_warn(LD_CIRC, "Timeout is %lf, Xm is %d", timeout2, final.Xm); test_assert(fabs(circuit_build_times_cdf(&initial, timeout0) - - circuit_build_times_cdf(&initial, timeout2)) < 0.05); + circuit_build_times_cdf(&initial, timeout2)) < 0.05); /* Generate MAX_RECENT_TIMEOUT_RATE*RECENT_CIRCUITS timeouts * and 1-that regular values. Then check for timeout error @@ -3491,10 +3491,10 @@ test_circuit_timeout(void) for (i = 0; i < MAX_RECENT_TIMEOUT_RATE*RECENT_CIRCUITS; i++) { circuit_build_times_add_timeout_worker(&estimate, - BUILDTIMEOUT_QUANTILE_CUTOFF); + BUILDTIMEOUT_QUANTILE_CUTOFF); if (i < MAX_RECENT_TIMEOUT_RATE*RECENT_CIRCUITS-1) { circuit_build_times_add_timeout_worker(&final, - BUILDTIMEOUT_QUANTILE_CUTOFF); + BUILDTIMEOUT_QUANTILE_CUTOFF); } } |