OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:_dispatcher
(Results
1 - 6
of
6
) sorted by null
/external/autotest/scheduler/
host_scheduler_unittests.py
68
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
87
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
88
self.
_dispatcher
._schedule_new_jobs()
107
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
108
self.
_dispatcher
._schedule_new_jobs()
130
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
131
self.
_dispatcher
._schedule_new_jobs()
207
host_agents = list(self.
_dispatcher
._host_agents[host.id])
240
self.
_dispatcher
._schedule_special_tasks()
243
self.assertFalse(self.
_dispatcher
.host_has_agent(host)
[
all
...]
rdb_integration_tests.py
133
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
164
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
225
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
261
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
283
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
303
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
325
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
354
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
363
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
370
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries(
[
all
...]
monitor_db_unittest.py
137
self.
_dispatcher
= monitor_db.Dispatcher()
247
self.
_dispatcher
._host_scheduler.tick()
249
self.
_dispatcher
._schedule_new_jobs()
401
self.
_dispatcher
._schedule_new_jobs()
423
self.god.stub_with(self.
_dispatcher
, '_seconds_between_garbage_stats',
430
self.
_dispatcher
._last_garbage_stats_time = 0
431
self.
_dispatcher
._garbage_collection()
434
self.
_dispatcher
._garbage_collection()
462
self.
_dispatcher
._agents = list(self._agents)
467
self.
_dispatcher
._handle_agents(
[
all
...]
rdb_cache_unittests.py
71
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
131
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
191
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
219
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
313
queue_entries = self.
_dispatcher
._refresh_pending_queue_entries()
rdb_testing_utils.py
367
self.
_dispatcher
= monitor_db.Dispatcher()
368
self.host_scheduler = self.
_dispatcher
._host_scheduler
370
self.job_query_manager = self.
_dispatcher
._job_query_manager
/external/autotest/frontend/afe/
rpc_handler.py
130
self.
_dispatcher
= serviceHandler.ServiceHandler(self._rpc_methods)
164
return self.
_dispatcher
.handleRequest(json_request)
172
return self.
_dispatcher
.translateRequest(json_request)
180
return self.
_dispatcher
.dispatchRequest(decoded_request)
208
return self.
_dispatcher
.translateResult(results)
Completed in 72 milliseconds