Bug28869
Created by: juga0
Merge request reports
Activity
Filter activity
1 1 __version__ = '1.0.3-dev0' 2 3 4 import threading 5 6 from . import globals # noqa 7 8 Created by: asn-d6
Hmm, I don't quite understand what's going on here and the commit does not explain what this is used for? Perhaps add some more docs to explain this addition to the init file? What are we trying to achieve? Why does this go into the init.py file and not in a settings.py file or something?
270 270 271 271 272 272 def dispatch_worker_thread(*a, **kw): 273 try: 274 return measure_relay(*a, **kw) 275 except Exception as err: 276 log.exception('Unhandled exception in worker thread') 277 raise err 273 return measure_relay(*a, **kw) 119 118 'target': conf.getfloat('scanner', 'download_target'), 120 119 'max': conf.getfloat('scanner', 'download_max'), 121 120 } 122 while len(results) < num_downloads: 121 while len(results) < num_downloads and not settings.end_event.is_set(): 354 354 return closure 355 355 356 356 357 def main_loop(args, conf, controller, relay_list, circuit_builder, result_dump, 358 relay_prioritizer, destinations, max_pending_results, pool): 359 pending_results = [] 360 while not settings.end_event.is_set(): 361 num_relays = 0 362 loop_tstart = time.time() 363 for target in relay_prioritizer.best_priority(): 364 if settings.end_event.is_set(): 270 270 271 271 272 272 def dispatch_worker_thread(*a, **kw): 273 try: 274 return measure_relay(*a, **kw) 275 except Exception as err: 276 log.exception('Unhandled exception in worker thread') 277 raise err 273 return measure_relay(*a, **kw) 119 118 'target': conf.getfloat('scanner', 'download_target'), 120 119 'max': conf.getfloat('scanner', 'download_max'), 121 120 } 122 while len(results) < num_downloads: 121 while len(results) < num_downloads and not settings.end_event.is_set(): 119 118 'target': conf.getfloat('scanner', 'download_target'), 120 119 'max': conf.getfloat('scanner', 'download_max'), 121 120 } 122 while len(results) < num_downloads: 121 while len(results) < num_downloads and not settings.end_event.is_set(): 354 354 return closure 355 355 356 356 357 def main_loop(args, conf, controller, relay_list, circuit_builder, result_dump, 358 relay_prioritizer, destinations, max_pending_results, pool): 359 pending_results = [] 360 while not settings.end_event.is_set(): 361 num_relays = 0 362 loop_tstart = time.time() 363 for target in relay_prioritizer.best_priority(): 364 if settings.end_event.is_set(): 354 354 return closure 355 355 356 356 357 def main_loop(args, conf, controller, relay_list, circuit_builder, result_dump, 358 relay_prioritizer, destinations, max_pending_results, pool): 359 pending_results = [] 360 while not settings.end_event.is_set(): 361 num_relays = 0 362 loop_tstart = time.time() 363 for target in relay_prioritizer.best_priority(): 364 if settings.end_event.is_set():
Please register or sign in to reply