| /external/autotest/scheduler/ |
| D | postjob_task.py | 25 def __init__(self, queue_entries, log_file_name): argument
28 self.queue_entries = queue_entries
47 return self.queue_entries[0].job.owner
51 return self._get_consistent_execution_path(self.queue_entries)
60 for queue_entry in self.queue_entries:
66 for entry in self.queue_entries]
87 for queue_entry in self.queue_entries:
224 def __init__(self, queue_entries, recover_run_monitor=None): argument
225 self._job = queue_entries[0].job
227 queue_entries, log_file_name='.collect_crashinfo.log')
[all …]
|
| D | rdb_integration_tests.py | 134 queue_entries = self._dispatcher._refresh_pending_queue_entries()
135 hosts = list(rdb_lib.acquire_hosts(queue_entries))
165 queue_entries = self._dispatcher._refresh_pending_queue_entries()
166 hosts = list(rdb_lib.acquire_hosts(queue_entries))
226 queue_entries = self._dispatcher._refresh_pending_queue_entries()
227 matching_host = rdb_lib.acquire_hosts(queue_entries).next()
262 queue_entries = self._dispatcher._refresh_pending_queue_entries()
263 matching_hosts = list(rdb_lib.acquire_hosts(queue_entries))
266 for job, host in zip(queue_entries, matching_hosts):
284 queue_entries = self._dispatcher._refresh_pending_queue_entries()
[all …]
|
| D | monitor_db.py | 506 queue_entries = scheduler_models.HostQueueEntry.fetch(
509 'running', len(queue_entries))
513 for entry in queue_entries:
522 used_queue_entries.update(agent_task.queue_entries)
547 return QueueTask(queue_entries=task_entries)
549 return postjob_task.GatherLogsTask(queue_entries=task_entries)
551 return postjob_task.FinalReparseTask(queue_entries=task_entries)
553 return postjob_task.ArchiveResultsTask(queue_entries=task_entries)
661 queue_entries = scheduler_models.HostQueueEntry.fetch(
664 for queue_entry in 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 | site_monitor_db.py | 33 def _archive_results(self, queue_entries): argument
50 for queue_entry in self.queue_entries:
54 def _check_queue_entry_statuses(self, queue_entries, allowed_hqe_statuses, argument
60 for entry in queue_entries:
202 queue_entries = scheduler_models.HostQueueEntry.fetch(
204 for queue_entry in queue_entries:
|
| D | agent_task.py | 159 def _set_ids(self, host=None, queue_entries=None): argument
160 if queue_entries and queue_entries != [None]:
161 self.host_ids = [entry.host.id for entry in queue_entries]
162 self.queue_entry_ids = [entry.id for entry in queue_entries]
164 for entry in queue_entries)
275 def _parse_results(self, queue_entries): argument
276 for queue_entry in queue_entries:
280 def _archive_results(self, queue_entries): argument
281 for queue_entry in queue_entries:
495 def _check_queue_entry_statuses(self, queue_entries, allowed_hqe_statuses, argument
[all …]
|
| D | host_scheduler_unittests.py | 69 queue_entries = self._dispatcher._refresh_pending_queue_entries()
70 job_manager = rdb_lib.JobQueryManager(queue_entries)
71 job_info = job_manager.get_job_info(queue_entries[0])
88 queue_entries = self._dispatcher._refresh_pending_queue_entries()
108 queue_entries = self._dispatcher._refresh_pending_queue_entries()
131 queue_entries = self._dispatcher._refresh_pending_queue_entries()
|
| D | prejob_task.py | 187 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
226 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
280 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
332 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
|
| D | scheduler_models.py | 1396 def _assign_new_group(self, queue_entries, group_name=''): argument
1397 if len(queue_entries) == 1:
1398 group_subdir_name = queue_entries[0].host.hostname
1402 self.id, [entry.host.hostname for entry in queue_entries],
1405 for queue_entry in queue_entries:
1531 queue_entries = self._choose_group_to_run(queue_entry)
1532 if queue_entries:
1533 self._finish_run(queue_entries)
1536 def _finish_run(self, queue_entries): argument
1537 for queue_entry in queue_entries:
|
| D | atomic_group_unittests.py | 200 queue_entries = job.get_host_queue_entries()
201 self.assertEqual(1, len(queue_entries))
202 self.assertEqual(queue_entries[0].status,
|
| D | monitor_db_functional_test.py | 680 queue_entries = list(job.hostqueueentry_set.all())
682 self._check_statuses(queue_entries[0], HqeStatus.VERIFYING)
696 queue_entries = list(job.hostqueueentry_set.all())
700 self._check_statuses(queue_entries[0], HqeStatus.RUNNING)
706 self._check_statuses(queue_entries[0], HqeStatus.GATHERING)
970 queue_entries = list(job.hostqueueentry_set.all())
972 for queue_entry, status in zip(queue_entries, statuses):
977 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 | 986 self.assertEquals(queue_task.queue_entries[0].get_group_name(),
1000 self.assertEquals(queue_task.queue_entries[0].get_group_name(),
1012 hqe_ids = [hqe.id for hqe in queue_task.queue_entries]
|
| /external/autotest/cli/contrib/ |
| D | why_isnt_my_job_running.py | 35 queue_entries = proxy.run('get_host_queue_entries', job__id=job_id) variable
38 if queue_entries and queue_entries[0]['atomic_group']:
39 if queue_entries[0]['status'] in RUNNING_HQE_STATUSES:
41 job_id, queue_entries[0]['status'])
46 for queue_entry in queue_entries:
53 queue_entries_with_hosts = [queue_entry for queue_entry in queue_entries
55 all_queue_entries_have_hosts = (len(queue_entries) ==
57 if (not all_queue_entries_have_hosts and len(queue_entries) > 1 and
73 print len(queue_entries), 'non-started atomic group HostQueueEntries',
76 atomic_group_name = queue_entries[0]['atomic_group']['name']
[all …]
|
| /external/autotest/frontend/afe/ |
| D | rpc_utils.py | 514 queue_entries = job.hostqueueentry_set.all()
516 queue_entries = models.HostQueueEntry.query_objects(
517 queue_entry_filter_data, initial_query=queue_entries)
519 for queue_entry in queue_entries:
707 def _special_task_to_dict(task, queue_entries): argument
718 for qentry in queue_entries:
746 queue_entries):
767 dict_list.append(_special_task_to_dict(e, queue_entries))
773 def _compute_next_job_for_tasks(queue_entries, special_tasks): argument
793 for queue_entry in queue_entries[hqe_index:]:
[all …]
|
| D | resources.py | 286 queue_entries = QueueEntryCollection(self._request)
287 queue_entries.set_query_parameters(host=self.instance.hostname)
298 'queue_entries': queue_entries.link(),
654 queue_entries = QueueEntryCollection(self._request)
655 queue_entries.set_query_parameters(job=self.instance.id)
663 'queue_entries': queue_entries.link(),
|
| D | rpc_interface_unittest.py | 250 queue_entries = job.hostqueueentry_set.all()
251 self.assertEquals(len(queue_entries), 1)
252 self.assertEquals(queue_entries[0].host, None)
253 self.assertEquals(queue_entries[0].meta_host, None)
254 self.assertEquals(queue_entries[0].atomic_group, None)
|
| D | rpc_interface.py | 1484 queue_entries = get_host_queue_entries(
1488 interleaved_entries = rpc_utils.interleave_entries(queue_entries,
1495 interleaved_entries, queue_entries)
|
| D | models.py | 921 def check_abort_permissions(queue_entries): argument
936 not_owned = queue_entries.exclude(job__owner=user.login)
|
| /external/autotest/cli/ |
| D | host.py | 288 queue_entries = self.execute_rpc('get_host_queue_entries',
293 for entry in queue_entries:
|