/external/autotest/scheduler/ |
D | postjob_task.py | 30 def __init__(self, queue_entries, log_file_name): argument 33 self.queue_entries = queue_entries 52 return self.queue_entries[0].job.owner 56 return self._get_consistent_execution_path(self.queue_entries) 65 for queue_entry in self.queue_entries: 71 for entry in self.queue_entries] 92 for queue_entry in self.queue_entries: 231 def __init__(self, queue_entries, recover_run_monitor=None): argument 232 self._job = queue_entries[0].job 234 queue_entries, log_file_name='.collect_crashinfo.log') [all …]
|
D | rdb_integration_tests.py | 133 queue_entries = self._dispatcher._refresh_pending_queue_entries() 134 hosts = list(rdb_lib.acquire_hosts(queue_entries)) 164 queue_entries = self._dispatcher._refresh_pending_queue_entries() 165 hosts = list(rdb_lib.acquire_hosts(queue_entries)) 225 queue_entries = self._dispatcher._refresh_pending_queue_entries() 226 matching_host = rdb_lib.acquire_hosts(queue_entries).next() 261 queue_entries = self._dispatcher._refresh_pending_queue_entries() 262 matching_hosts = list(rdb_lib.acquire_hosts(queue_entries)) 265 for job, host in zip(queue_entries, matching_hosts): 283 queue_entries = self._dispatcher._refresh_pending_queue_entries() [all …]
|
D | monitor_db.py | 524 queue_entries = scheduler_models.HostQueueEntry.fetch( 530 for entry in queue_entries: 542 used_queue_entries.update(agent_task.queue_entries) 582 return QueueTask(queue_entries=task_entries) 584 return postjob_task.GatherLogsTask(queue_entries=task_entries) 586 return postjob_task.FinalReparseTask(queue_entries=task_entries) 695 queue_entries = scheduler_models.HostQueueEntry.fetch( 697 for queue_entry in queue_entries: 789 queue_entries = self._job_query_manager.get_pending_queue_entries( 791 if not queue_entries: [all …]
|
D | rdb_lib.py | 18 def __init__(self, queue_entries, suite_min_duts=None): argument 31 jobs = [queue_entry.job_id for queue_entry in queue_entries] 65 def acquire_hosts(queue_entries, suite_min_duts=None): argument 79 job_query_manager = JobQueryManager(queue_entries, suite_min_duts) 82 for entry in queue_entries:
|
D | rdb_cache_unittests.py | 71 queue_entries = self._dispatcher._refresh_pending_queue_entries() 114 self.check_hosts(rdb_lib.acquire_hosts(queue_entries)) 131 queue_entries = self._dispatcher._refresh_pending_queue_entries() 164 self.check_hosts(rdb_lib.acquire_hosts(queue_entries)) 191 queue_entries = self._dispatcher._refresh_pending_queue_entries() 194 self.check_hosts(rdb_lib.acquire_hosts(queue_entries)) 219 queue_entries = self._dispatcher._refresh_pending_queue_entries() 238 acquired_hosts = list(rdb_lib.acquire_hosts(queue_entries)) 313 queue_entries = self._dispatcher._refresh_pending_queue_entries() 340 self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
|
D | agent_task.py | 167 def _set_ids(self, host=None, queue_entries=None): argument 168 if queue_entries and queue_entries != [None]: 172 for entry in queue_entries: 295 def _parse_results(self, queue_entries): argument 296 for queue_entry in queue_entries: 506 def _check_queue_entry_statuses(self, queue_entries, allowed_hqe_statuses, argument 509 for entry in queue_entries:
|
D | host_scheduler_unittests.py | 68 queue_entries = self._dispatcher._refresh_pending_queue_entries() 69 job_manager = rdb_lib.JobQueryManager(queue_entries) 70 job_info = job_manager.get_job_info(queue_entries[0]) 87 queue_entries = self._dispatcher._refresh_pending_queue_entries() 107 queue_entries = self._dispatcher._refresh_pending_queue_entries() 130 queue_entries = self._dispatcher._refresh_pending_queue_entries()
|
D | scheduler_models.py | 1261 def _assign_new_group(self, queue_entries): argument 1262 if len(queue_entries) == 1: 1263 group_subdir_name = queue_entries[0].host.hostname 1267 self.id, [entry.host.hostname for entry in queue_entries], 1270 for queue_entry in queue_entries: 1332 queue_entries = self._choose_group_to_run(queue_entry) 1333 if queue_entries: 1334 self._finish_run(queue_entries) 1337 def _finish_run(self, queue_entries): argument 1338 for queue_entry in queue_entries:
|
D | prejob_task.py | 173 self._set_ids(host=self.host, queue_entries=[self.queue_entry]) 212 self._set_ids(host=self.host, queue_entries=[self.queue_entry]) 266 self._set_ids(host=self.host, queue_entries=[self.queue_entry]) 368 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
|
D | monitor_db_functional_test.py | 663 queue_entries = list(job.hostqueueentry_set.all()) 665 self._check_statuses(queue_entries[0], HqeStatus.VERIFYING) 679 queue_entries = list(job.hostqueueentry_set.all()) 683 self._check_statuses(queue_entries[0], HqeStatus.RUNNING) 689 self._check_statuses(queue_entries[0], HqeStatus.GATHERING) 940 queue_entries = list(job.hostqueueentry_set.all()) 942 for queue_entry, status in zip(queue_entries, statuses): 947 queue_entries = list(job.hostqueueentry_set.all())
|
D | host_scheduler.py | 328 queue_entries = self.job_query_manager.get_pending_queue_entries( 330 unverified_host_jobs = [job for job in queue_entries
|
D | monitor_db_unittest.py | 797 hqe_ids = [hqe.id for hqe in queue_task.queue_entries]
|
/external/autotest/frontend/afe/ |
D | rpc_utils.py | 442 queue_entries = job.hostqueueentry_set.all() 444 queue_entries = models.HostQueueEntry.query_objects( 445 queue_entry_filter_data, initial_query=queue_entries) 447 for queue_entry in queue_entries: 582 def _special_task_to_dict(task, queue_entries): argument 593 for qentry in queue_entries: 621 queue_entries): 642 dict_list.append(_special_task_to_dict(e, queue_entries)) 648 def _compute_next_job_for_tasks(queue_entries, special_tasks): argument 668 for queue_entry in queue_entries[hqe_index:]: [all …]
|
D | rpc_interface_unittest.py | 242 queue_entries = job.hostqueueentry_set.all() 243 self.assertEquals(len(queue_entries), 1) 244 self.assertEquals(queue_entries[0].host, None) 245 self.assertEquals(queue_entries[0].meta_host, None)
|
D | rpc_interface.py | 1464 queue_entries = get_host_queue_entries( 1468 interleaved_entries = rpc_utils.interleave_entries(queue_entries, 1475 interleaved_entries, queue_entries)
|
D | models.py | 951 def check_abort_permissions(queue_entries): argument 966 not_owned = queue_entries.exclude(job__owner=user.login)
|
/external/autotest/cli/ |
D | host.py | 304 queue_entries = self.execute_rpc('get_host_queue_entries', 309 for entry in queue_entries:
|