Home
last modified time | relevance | path

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

/external/autotest/scheduler/
Dmonitor_db_functional_test.py416 def _check_statuses(self, queue_entry, queue_entry_status, argument
418 self._check_entry_status(queue_entry, queue_entry_status)
420 self._check_host_status(queue_entry.host, host_status)
423 def _check_entry_status(self, queue_entry, status): argument
425 queue_entry = self._update_instance(queue_entry)
426 self.assertEquals(queue_entry.status, status)
435 def _run_pre_job_verify(self, queue_entry): argument
437 self._check_statuses(queue_entry, HqeStatus.VERIFYING,
444 job, queue_entry = self._make_job_and_queue_entry()
445 self._run_pre_job_verify(queue_entry)
[all …]
Dprejob_task.py69 if not self.queue_entry or self.queue_entry.meta_host:
72 self.queue_entry.set_execution_subdir()
77 self.queue_entry.execution_path(), log_name)
94 if self.queue_entry:
99 queue_entry__id=self.queue_entry.id,
105 queue_entry_id=self.queue_entry.id).count()
126 self.queue_entry.requeue()
133 queue_entry_id=self.queue_entry.id,
134 host_id=self.queue_entry.host_id).count()
140 queue_entry = models.HostQueueEntry.objects.get(
[all …]
Dhost_scheduler.py119 def record_assignment(self, queue_entry): argument
125 parent_id = queue_entry.job.parent_job_id
128 if self.hosts_to_suites.get(queue_entry.host_id, None) == parent_id:
130 'seems already recorded', queue_entry.id,
131 parent_id, queue_entry.host.hostname)
135 self.hosts_to_suites[queue_entry.host_id] = parent_id
137 parent_id, queue_entry.host.hostname,
219 def schedule_host_job(cls, host, queue_entry): argument
232 if queue_entry.host_id is None:
233 queue_entry.set_host(host)
[all …]
Dagent_task.py276 for queue_entry in queue_entries:
277 queue_entry.set_status(models.HostQueueEntry.Status.PARSING)
281 for queue_entry in queue_entries:
282 queue_entry.set_status(models.HostQueueEntry.Status.ARCHIVING)
580 queue_entry = None variable in SpecialAgentTask
589 self.queue_entry = None
590 if task.queue_entry:
591 self.queue_entry = scheduler_models.HostQueueEntry(
592 id=task.queue_entry.id)
593 self.host.dbg_str += self.queue_entry.get_dbg_str()
[all …]
Dmonitor_db.py248 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None, argument
263 extra_args=extra_args, job=job, queue_entry=queue_entry,
439 def get_agents_for_entry(self, queue_entry): argument
443 return list(self._queue_entry_agents.get(queue_entry.id, set()))
533 def _get_agent_task_for_queue_entry(self, queue_entry): argument
540 task_entries = queue_entry.job.get_group_entries(queue_entry)
543 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
545 if queue_entry.is_hostless():
546 return HostlessQueueTask(queue_entry=queue_entry)
548 if queue_entry.status == models.HostQueueEntry.Status.GATHERING:
[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,
Dscheduler_models.py736 for queue_entry in hosts_queue:
738 (queue_entry._get_hostname(),
739 queue_entry.status))
760 self.job.schedule_pre_job_tasks(queue_entry=self)
817 self.job.run_if_ready(queue_entry=self)
1123 for queue_entry in self.get_host_queue_entries():
1124 queue_entry.set_status(status)
1290 def _should_run_cleanup(self, queue_entry): argument
1294 return queue_entry.host.dirty
1298 def _should_run_verify(self, queue_entry): argument
[all …]
Dpostjob_task.py60 for queue_entry in self.queue_entries:
61 queue_entry.update_from_database()
63 was_aborted = bool(queue_entry.aborted)
64 elif was_aborted != bool(queue_entry.aborted): # subsequent entries
87 for queue_entry in self.queue_entries:
88 queue_entry.set_status(status)
233 host_list = ','.join(queue_entry.host.hostname
234 for queue_entry in self.queue_entries)
282 for queue_entry in self.queue_entries:
287 host=models.Host.objects.get(id=queue_entry.host.id),
[all …]
Dsite_monitor_db.py50 for queue_entry in self.queue_entries:
51 queue_entry.set_status(status)
204 for queue_entry in queue_entries:
209 queue_entry__id=queue_entry.id,
213 'Setting status to Queued.', str(queue_entry))
220 queue_entry.set_status('Queued')
Dmonitor_db_unittest.py171 def hqe__do_schedule_pre_job_tasks_stub(queue_entry): argument
173 self._record_job_scheduled(queue_entry.job.id, queue_entry.host.id)
174 queue_entry.set_status('Starting')
801 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
802 assert queue_entry.job is job
803 job.run_if_ready(queue_entry)
1021 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
1022 assert queue_entry.job is job
1023 job.run_if_ready(queue_entry)
1024 self.assertEqual(queue_entry.status,
[all …]
Dscheduler_models_unittest.py331 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
332 queue_entry.job.reboot_before = reboot_before
333 queue_entry._do_schedule_pre_job_tasks()
382 self.assertEquals(task.queue_entry.id, queue_entry_id)
459 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
460 assert queue_entry.job is job
461 self.assertEqual(None, job.run(queue_entry))
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.py99 for queue_entry in query.distinct():
100 logging.warning('Aborting entry %s due to max runtime', queue_entry)
101 queue_entry.abort()
Dquery_managers.py406 relevant_jobs = [queue_entry.job_id
407 for queue_entry in pending_queue_entries]
Drdb_integration_tests.py570 for host, queue_entry in zip(matching_hosts, queue_entries):
572 suites[queue_entry.job.parent_job_id][1].append(host)
/external/autotest/frontend/afe/
Drpc_utils.py358 for queue_entry in host_queue_entries:
359 key = _execution_key_for(queue_entry)
363 for queue_entry in host_queue_entries:
364 if not queue_entry.execution_subdir:
366 execution_count = count_per_execution[_execution_key_for(queue_entry)]
367 if execution_count < queue_entry.job.synch_count:
371 % (queue_entry.job.id, queue_entry.execution_subdir,
372 execution_count, queue_entry.job.synch_count)})
519 for queue_entry in queue_entries:
520 if (queue_entry.host and (preserve_metahosts or
[all …]
Dresources.py706 for queue_entry in input_dict['queue_entries']:
707 if 'host' in queue_entry:
708 host = queue_entry['host']
712 elif 'meta_host' in queue_entry:
714 queue_entry['meta_host'])
716 if 'atomic_group_class' in queue_entry:
718 queue_entry['atomic_group_class'])
828 queue_entry = QueueEntry.from_optional_instance(
829 self._request, self.instance.queue_entry)
836 'queue_entry': queue_entry.short_representation()
Dmodels.py78 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
80 queue_entry.save()
134 queue_entry = HostQueueEntry.create(meta_host=self, job=job,
137 queue_entry.save()
620 for queue_entry in self.hostqueueentry_set.all():
621 queue_entry.deleted = True
622 queue_entry.abort()
638 queue_entry = HostQueueEntry.create(host=self, job=job,
645 queue_entry.save()
1645 for queue_entry in self.hostqueueentry_set.all():
[all …]
Dmodels_test.py125 queue_entry=job.hostqueueentry_set.all()[0])
Drpc_interface_unittest.py276 queue_entry=entry2, # ran with job 2
/external/autotest/server/
Dautoserv_utils.py26 queue_entry=None, verbose=True, argument
90 if job or queue_entry:
92 job = queue_entry.job
133 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None, argument
155 extra_args=extra_args, job=job, queue_entry=queue_entry,
/external/autotest/cli/contrib/
Dwhy_isnt_my_job_running.py46 for queue_entry in queue_entries:
47 if queue_entry['host'] and queue_entry['host']['status']:
48 if queue_entry['host']['status'].startswith('Repair'):
49 repair_hostnames.append(queue_entry['host']['hostname'])
50 if queue_entry['status'] in ('Completed', 'Stopped'):
53 queue_entries_with_hosts = [queue_entry for queue_entry in queue_entries
54 if queue_entry['host']]
/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/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: