Home
last modified time | relevance | path

Searched refs:queue_entry (Results 1 – 24 of 24) sorted by relevance

/external/autotest/scheduler/
Dmonitor_db_functional_test.py411 def _check_statuses(self, queue_entry, queue_entry_status, argument
413 self._check_entry_status(queue_entry, queue_entry_status)
415 self._check_host_status(queue_entry.host, host_status)
418 def _check_entry_status(self, queue_entry, status): argument
420 queue_entry = self._update_instance(queue_entry)
421 self.assertEquals(queue_entry.status, status)
430 def _run_pre_job_verify(self, queue_entry): argument
432 self._check_statuses(queue_entry, HqeStatus.VERIFYING,
439 job, queue_entry = self._make_job_and_queue_entry()
440 self._run_pre_job_verify(queue_entry)
[all …]
Dprejob_task.py82 if self.queue_entry:
87 queue_entry__id=self.queue_entry.id,
93 queue_entry_id=self.queue_entry.id).count()
114 self.queue_entry.requeue()
121 queue_entry_id=self.queue_entry.id,
122 host_id=self.queue_entry.host_id).count()
128 queue_entry = models.HostQueueEntry.objects.get(
129 id=self.queue_entry.id)
131 queue_entry = None
136 queue_entry=queue_entry,
[all …]
Dmonitor_db.py282 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None, argument
297 extra_args=extra_args, job=job, queue_entry=queue_entry,
495 def get_agents_for_entry(self, queue_entry): argument
499 return list(self._queue_entry_agents.get(queue_entry.id, set()))
618 def _get_agent_task_for_queue_entry(self, queue_entry): argument
625 task_entries = queue_entry.job.get_group_entries(queue_entry)
628 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
630 if queue_entry.is_hostless():
631 return HostlessQueueTask(queue_entry=queue_entry)
633 if queue_entry.status == models.HostQueueEntry.Status.GATHERING:
[all …]
Dhost_scheduler.py124 def record_assignment(self, queue_entry): argument
130 parent_id = queue_entry.job.parent_job_id
133 if self.hosts_to_suites.get(queue_entry.host_id, None) == parent_id:
135 'seems already recorded', queue_entry.id,
136 parent_id, queue_entry.host.hostname)
140 self.hosts_to_suites[queue_entry.host_id] = parent_id
142 parent_id, queue_entry.host.hostname,
222 def schedule_host_job(cls, host, queue_entry): argument
235 if queue_entry.host_id is None:
236 queue_entry.set_host(host)
[all …]
Drdb_lib.py31 jobs = [queue_entry.job_id for queue_entry in queue_entries]
38 def get_job_info(self, queue_entry): argument
45 job_id = queue_entry.job_id
54 parent_id = queue_entry.job.parent_job_id
59 'host_id': queue_entry.host_id,
60 'parent_job_id': queue_entry.job.parent_job_id,
61 'priority': queue_entry.job.priority,
Dagent_task.py296 for queue_entry in queue_entries:
297 queue_entry.set_status(models.HostQueueEntry.Status.PARSING)
599 queue_entry = None variable in SpecialAgentTask
612 self.queue_entry = None
613 if task.queue_entry:
614 self.queue_entry = scheduler_models.HostQueueEntry(
615 id=task.queue_entry.id)
616 self.host.dbg_str += self.queue_entry.get_dbg_str()
638 if self.task.queue_entry:
639 job = self.task.queue_entry.job
[all …]
Dpostjob_task.py65 for queue_entry in self.queue_entries:
66 queue_entry.update_from_database()
68 was_aborted = bool(queue_entry.aborted)
69 elif was_aborted != bool(queue_entry.aborted): # subsequent entries
92 for queue_entry in self.queue_entries:
93 queue_entry.set_status(status)
240 host_list = ','.join(queue_entry.host.hostname
241 for queue_entry in self.queue_entries)
317 for queue_entry in self.queue_entries:
322 host=models.Host.objects.get(id=queue_entry.host.id),
[all …]
Dscheduler_models.py781 for queue_entry in hosts_queue:
783 (queue_entry._get_hostname(),
784 queue_entry.status))
805 self.job.schedule_pre_job_tasks(queue_entry=self)
867 self.job.run_if_ready(queue_entry=self)
1195 def _should_run_cleanup(self, queue_entry): argument
1199 return queue_entry.host.dirty
1203 def _should_run_verify(self, queue_entry): argument
1204 do_not_verify = (queue_entry.host.protection ==
1215 def _should_run_reset(self, queue_entry): argument
[all …]
Dmonitor_db_unittest.py181 def hqe__do_schedule_pre_job_tasks_stub(queue_entry): argument
183 self._record_job_scheduled(queue_entry.job.id, queue_entry.host.id)
184 queue_entry.set_status('Starting')
754 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
755 assert queue_entry.job is job
756 job.run_if_ready(queue_entry)
791 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
792 assert queue_entry.job is job
793 job.run_if_ready(queue_entry)
794 self.assertEqual(queue_entry.status,
[all …]
Drdb_testing_utils.py124 queue_entry = cls.get_hqes(job_id=job_id)[0]
125 host_id = queue_entry.host.id
127 queue_entry = None
133 host=host, queue_entry=queue_entry, task=task,
Dmonitor_db_cleanup.py112 for queue_entry in hqes:
114 queue_entry)
115 queue_entry.abort()
Dscheduler_models_unittest.py337 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
338 queue_entry.job.reboot_before = reboot_before
339 queue_entry._do_schedule_pre_job_tasks()
358 self.assertEquals(task.queue_entry.id, queue_entry_id)
Dquery_managers.py387 relevant_jobs = [queue_entry.job_id
388 for queue_entry in pending_queue_entries]
Drdb_integration_tests.py569 for host, queue_entry in zip(matching_hosts, queue_entries):
571 suites[queue_entry.job.parent_job_id][1].append(host)
/external/autotest/frontend/afe/
Drpc_utils.py365 for queue_entry in host_queue_entries:
366 key = _execution_key_for(queue_entry)
370 for queue_entry in host_queue_entries:
371 if not queue_entry.execution_subdir:
373 execution_count = count_per_execution[_execution_key_for(queue_entry)]
374 if execution_count < queue_entry.job.synch_count:
378 % (queue_entry.job.id, queue_entry.execution_subdir,
379 execution_count, queue_entry.job.synch_count)})
456 for queue_entry in queue_entries:
457 if (queue_entry.host and (preserve_metahosts or
[all …]
Dmodels.py83 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
85 queue_entry.save()
138 queue_entry = HostQueueEntry.create(meta_host=self, job=job,
140 queue_entry.save()
758 for queue_entry in self.hostqueueentry_set.all():
759 logging.info(' Deleting and aborting hqe %s...', queue_entry)
760 queue_entry.deleted = True
761 queue_entry.abort()
762 logging.info(' ... done with hqe %s.', queue_entry)
784 queue_entry = HostQueueEntry.create(host=self, job=job,
[all …]
Dmodels_test.py204 queue_entry=job.hostqueueentry_set.all()[0])
Drpc_interface_unittest.py935 queue_entry=entry2, # ran with job 2
/external/swiftshader/third_party/llvm-7.0/llvm/test/CodeGen/X86/
D2009-09-23-LiveVariablesBug.ll11 %struct.queue_entry = type { %struct.queue_entry*, %struct.queue_entry* }
14 …queue_entry, %struct._lck_rw_t_internal_, i64, %struct.vm_page*, i32, i32, i32, i32, %struct.vm_ob…
15 %struct.vm_page = type { %struct.queue_entry, %struct.queue_entry, %struct.vm_page*, %struct.vm_obj…
/external/swiftshader/third_party/LLVM/test/CodeGen/X86/
D2009-09-23-LiveVariablesBug.ll11 %struct.queue_entry = type { %struct.queue_entry*, %struct.queue_entry* }
14 …queue_entry, %struct._lck_rw_t_internal_, i64, %struct.vm_page*, i32, i32, i32, i32, %struct.vm_ob…
15 %struct.vm_page = type { %struct.queue_entry, %struct.queue_entry, %struct.vm_page*, %struct.vm_obj…
/external/llvm/test/CodeGen/X86/
D2009-09-23-LiveVariablesBug.ll11 %struct.queue_entry = type { %struct.queue_entry*, %struct.queue_entry* }
14 …queue_entry, %struct._lck_rw_t_internal_, i64, %struct.vm_page*, i32, i32, i32, i32, %struct.vm_ob…
15 %struct.vm_page = type { %struct.queue_entry, %struct.queue_entry, %struct.vm_page*, %struct.vm_obj…
/external/autotest/server/
Dautoserv_utils.py20 queue_entry=None, verbose=True, argument
91 if job or queue_entry:
93 job = queue_entry.job
/external/autotest/site_utils/
Djob_history.py180 return [task for task in self.tasks if task.queue_entry and
181 task.queue_entry.job.id == job_id]
278 tasks = [task for task in tasks if task.queue_entry and
279 task.queue_entry.job.id == self.id]
/external/autotest/contrib/
Dcompare_suite.py159 if not task.queue_entry or task.queue_entry.job_id != self.id: