diff options
author | Nick Mathewson <nickm@torproject.org> | 2018-05-06 21:03:26 -0400 |
---|---|---|
committer | Nick Mathewson <nickm@torproject.org> | 2018-05-06 21:03:26 -0400 |
commit | 6e3e96d2ff0c1b83bdd3f2059d1b4a2b96a53341 (patch) | |
tree | ac68c952544fdbadcf71cdb660e1c9aeb606a601 /src | |
parent | f36656cada48a2d9f51c857d8477a8060cb89b9d (diff) | |
download | tor-6e3e96d2ff0c1b83bdd3f2059d1b4a2b96a53341.tar.gz tor-6e3e96d2ff0c1b83bdd3f2059d1b4a2b96a53341.zip |
Fix the selection of events to cancel in test_workqueue.c
Our previous algorithm had a nonzero probability of picking no
events to cancel, which is of course incorrect. The new code uses
Vitter's good old reservoir sampling "algorithm R" from 1985.
Fixes bug 26008; bugfix on 0.2.6.3-alpha.
Diffstat (limited to 'src')
-rw-r--r-- | src/test/test_workqueue.c | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/src/test/test_workqueue.c b/src/test/test_workqueue.c index 8d29d2062d..cc7073850c 100644 --- a/src/test/test_workqueue.c +++ b/src/test/test_workqueue.c @@ -224,7 +224,8 @@ add_n_work_items(threadpool_t *tp, int n) workqueue_entry_t **to_cancel; workqueue_entry_t *ent; - to_cancel = tor_malloc(sizeof(workqueue_entry_t*) * opt_n_cancel); + // We'll choose randomly which entries to cancel. + to_cancel = tor_calloc(opt_n_cancel, sizeof(workqueue_entry_t*)); while (n_queued++ < n) { ent = add_work(tp); @@ -233,9 +234,14 @@ add_n_work_items(threadpool_t *tp, int n) tor_libevent_exit_loop_after_delay(tor_libevent_get_base(), NULL); return -1; } - if (n_try_cancel < opt_n_cancel && - tor_weak_random_range(&weak_rng, n) < opt_n_cancel) { + + if (n_try_cancel < opt_n_cancel) { to_cancel[n_try_cancel++] = ent; + } else { + int p = tor_weak_random_range(&weak_rng, n_queued); + if (p < n_try_cancel) { + to_cancel[p] = ent; + } } } |