Commit c9ace7de authored by juga's avatar juga
Browse files

scanner: move log to function that starts measuring

since the relay might start being measured some time after
apply_async is called if there're not available threads.
parent fe16d6d8
......@@ -202,6 +202,7 @@ def _pick_ideal_second_hop(relay, dest, rl, cont, is_exit):
def measure_relay(args, conf, destinations, cb, rl, relay):
log.debug('Measuring %s %s', relay.nickname, relay.fingerprint)
s = requests_utils.make_session(
cb.controller, conf.getfloat('general', 'http_timeout'))
# Pick a destionation
......@@ -409,8 +410,6 @@ def main_loop(args, conf, controller, relay_list, circuit_builder, result_dump,
if settings.end_event.is_set():
num_relays += 1
log.debug('Measuring %s %s', target.nickname,
# callback and callback_err must be non-blocking
callback = result_putter(result_dump)
callback_err = result_putter_error(target)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment