Home	Sort by relevance Sort by last modified time

Full Search Definition Symbol File Path History   | | Help

    Searched refs:results_queue (Results 1 - 3 of 3) sorted by null

/external/autotest/scheduler/
thread_lib.py	52 self.results_queue = Queue.Queue() 58 def worker(drone, results_queue): 62 in results_queue. 65 @param results_queue: A queue, into which the worker places 69 results_queue.put(ThreadedTaskQueue.result( 117 while not self.results_queue.empty(): 118 drone_results = self.results_queue.get() 133 drone_utility. The results_queue and drone_threads will be cleared. 143 if not self.results_queue.empty(): 146 'through get_results.' % self.results_queue)     [all...]
thread_lib_unittest.py	70 task_queue.worker(drone, task_queue.results_queue) 71 result = task_queue.results_queue.get() 73 self.assertTrue(task_queue.results_queue.empty() and 151 task_queue.results_queue.put( 153 task_queue.results_queue.put( 162 self.assertTrue(task_queue.results_queue.empty()) 163 task_queue.results_queue.put( 165 task_queue.results_queue.put( 182 task_queue.results_queue.put(1) 185 task_queue.results_queue.get(     [all...]
drone_manager_unittest.py	458 self.manager._refresh_task_queue.results_queue.put(

Completed in 484 milliseconds