Home
last modified time | relevance | path

Searched refs:task_queue (Results 1 – 6 of 6) sorted by relevance

/external/autotest/scheduler/
Dthread_lib_unittest.py61 task_queue = thread_lib.ThreadedTaskQueue()
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
105 task_queue = thread_lib.ThreadedTaskQueue()
114 task_queue.drone_threads[drone1] = waiting_worker
115 task_queue.drone_threads[drone2] = failing_worker
117 target=task_queue.wait_on_drones)
131 self.assertTrue(task_queue.drone_threads == {})
135 task_queue.drone_threads[drone1] = quick_worker
[all …]
Ddrone_task_queue_unittest.py62 task_queue = drone_task_queue.DroneTaskQueue()
63 task_queue.results[drone1] = None
65 task_queue.execute, [])
66 task_queue.results.clear()
82 task_queue.execute(drones, wait=False)
83 self.assertTrue(set(task_queue.results.keys()) == set(drones))
84 results = task_queue.get_results()
85 self.assertTrue(len(task_queue.results) == 0)
97 self.assertTrue(task_queue.execute(drones, wait=True)[drone1] ==
99 self.assertTrue(len(task_queue.results) == 0)
[all …]
/external/chromium-trace/catapult/third_party/gsutil/gslib/
Dcommand.py1073 task_queue = _NewMultiprocessingQueue()
1074 task_queues.append(task_queue)
1087 consumer_pool = _ConsumerPool(processes, task_queue)
1348 task_queue = task_queues[self.recursive_apply_level]
1350 task_queue = _NewMultiprocessingQueue()
1352 task_queue = _NewThreadsafeQueue()
1361 func, task_queue, should_return_results,
1393 is_blocking_call=True, task_queue=task_queue)
1409 is_blocking_call=False, task_queue=None): argument
1428 task_queue = task_queue or task_queues[recursive_apply_level]
[all …]
/external/chromium-trace/catapult/dashboard/dashboard/
Dtesting_common.py74 task_queue = self.testbed.get_stub(testbed.TASKQUEUE_SERVICE_NAME)
75 tasks = task_queue.GetTasks(task_queue_name)
76 task_queue.FlushQueue(task_queue_name)
83 task_queue = self.testbed.get_stub(testbed.TASKQUEUE_SERVICE_NAME)
84 tasks = task_queue.GetTasks(task_queue_name)
85 task_queue.FlushQueue(task_queue_name)
Dbench_find_anomalies_test.py131 task_queue = self.testbed.get_stub(testbed.TASKQUEUE_SERVICE_NAME)
132 test_support.execute_until_empty(task_queue,
164 task_queue = self.testbed.get_stub(testbed.TASKQUEUE_SERVICE_NAME)
165 tasks = task_queue.GetTasks(bench_find_anomalies._TASK_QUEUE_NAME)
/external/valgrind/drd/scripts/
Ddownload-and-build-splash2.in145 + i < sizeof(global->task_queue) / sizeof(global->task_queue[0]);
148 + DRD_IGNORE_VAR(global->task_queue[i].n_tasks);