| /external/autotest/scheduler/ |
| monitor_db_functional_test.py | 416 def _check_statuses(self, queue_entry, queue_entry_status,
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):
425 queue_entry = self._update_instance(queue_entry)
426 self.assertEquals(queue_entry.status, status)
435 def _run_pre_job_verify(self, queue_entry):
437 self._check_statuses(queue_entry, HqeStatus.VERIFYING,
444 job, queue_entry = self._make_job_and_queue_entry(
[all...] |
| prejob_task.py | 69 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()
120 # queue_entry.abort()
126 self.queue_entry.requeue()
133 queue_entry_id=self.queue_entry.id
[all...] |
| rdb_lib.py | 31 jobs = [queue_entry.job_id for queue_entry in queue_entries]
38 def get_job_info(self, queue_entry):
39 """Extract job information from a queue_entry/host-scheduler.
41 @param queue_entry: The queue_entry for which we need job information.
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
[all...] |
| monitor_db.py | 248 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None,
258 @param queue_entry - A HostQueueEntry object - If supplied and no Job
263 extra_args=extra_args, job=job, queue_entry=queue_entry,
439 def get_agents_for_entry(self, queue_entry):
441 Find agents corresponding to the specified queue_entry.
443 return list(self._queue_entry_agents.get(queue_entry.id, set()))
533 def _get_agent_task_for_queue_entry(self, queue_entry):
537 @param queue_entry: a HostQueueEntry
540 task_entries = queue_entry.job.get_group_entries(queue_entry
[all...] |
| host_scheduler.py | 119 def record_assignment(self, queue_entry):
122 @param queue_entry: A scheduler_models.HostQueueEntry object which has
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):
223 1. Setting the active bit on the queue_entry
[all...] |
| agent_task.py | 276 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 class: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...] |
| postjob_task.py | 60 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...] |
| scheduler_models.py | 736 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)
[all...] |
| site_monitor_db.py | 50 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')
|
| scheduler_models_unittest.py | 331 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))
|
| monitor_db_unittest.py | 171 def hqe__do_schedule_pre_job_tasks_stub(queue_entry):
173 self._record_job_scheduled(queue_entry.job.id, queue_entry.host.id)
174 queue_entry.set_status('Starting')
379 # queue_entry = scheduler_models.HostQueueEntry.fetch(
399 # [self.label4.id, self.label8.id], queue_entry))
801 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
802 assert queue_entry.job is job
803 job.run_if_ready(queue_entry)
[all...] |
| monitor_db_cleanup.py | 99 for queue_entry in query.distinct():
100 logging.warning('Aborting entry %s due to max runtime', queue_entry)
101 queue_entry.abort()
|
| rdb_testing_utils.py | 124 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,
|
| query_managers.py | 406 relevant_jobs = [queue_entry.job_id
407 for queue_entry in pending_queue_entries]
|
| rdb_integration_tests.py | 570 for host, queue_entry in zip(matching_hosts, queue_entries):
572 suites[queue_entry.job.parent_job_id][1].append(host)
|
| /external/llvm/test/CodeGen/X86/ |
| 2009-09-23-LiveVariablesBug.ll | 11 %struct.queue_entry = type { %struct.queue_entry*, %struct.queue_entry* }
14 %struct.vm_object = type { %struct.queue_entry, %struct._lck_rw_t_internal_, i64, %struct.vm_page*, i32, i32, i32, i32, %struct.vm_object*, %struct.vm_object*, i64, %struct.memory_object*, i64, %struct.memory_object_control*, i32, i16, i16, [2 x i8], i8, i8, %struct.queue_entry, %struct.queue_entry, i64, i32, i32, i32, i8*, i64, i8, i8, [2 x i8], %struct.queue_entry }
15 %struct.vm_page = type { %struct.queue_entry, %struct.queue_entry, %struct.vm_page*, %struct.vm_object*, i64, [2 x i8], i8, i8, i32, i8, i8, i8, i8, i32 }
|
| /external/autotest/server/ |
| autoserv_utils.py | 26 queue_entry=None, verbose=True,
48 @param queue_entry: HostQueueEntry object. If supplied and no job
90 if job or queue_entry:
92 job = queue_entry.job
133 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None,
143 @param queue_entry - A HostQueueEntry object - If supplied and no Job
155 extra_args=extra_args, job=job, queue_entry=queue_entry,
|
| /external/autotest/frontend/afe/ |
| rpc_utils.py | 358 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
[all...] |
| resources.py | 706 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(
[all...] |
| models.py | 78 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()
1962 queue_entry = dbmodels.OneToOneField(HostQueueEntry, primary_key=True) variable in class:AbortedHostQueueEntry
2034 queue_entry = dbmodels.ForeignKey(HostQueueEntry, blank=True, null=True) variable in class:SpecialTask
[all...] |
| models_test.py | 125 queue_entry=job.hostqueueentry_set.all()[0])
|
| rpc_interface_unittest.py | 276 queue_entry=entry2, # ran with job 2
|
| /external/autotest/cli/contrib/ |
| why_isnt_my_job_running.py | 46 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/autotest/site_utils/ |
| job_history.py | 180 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/ |
| compare_suite.py | 159 if not task.queue_entry or task.queue_entry.job_id != self.id:
|
