/external/autotest/scheduler/ |
rdb_unittest.py | 46 self.get_hosts_manager.add_request(host_id=1) 52 response.append(rdb_testing_utils.FakeHost(hostname='host', host_id=1)) 66 self.get_hosts_manager.add_request(host_id=1) 67 self.get_hosts_manager.add_request(host_id=2) 70 response = [rdb_testing_utils.FakeHost(hostname='host', host_id=1)] 102 for host_id in range(1, 4): 103 self.get_hosts_manager.add_request(host_id=host_id) 105 rdb_testing_utils.FakeHost('host%s'%host_id, host_id)) [all...] |
rdb_lib.py | 59 'host_id': queue_entry.host_id, 104 for host_id in host_ids: 105 request_manager.add_request(host_id=host_id)
|
rdb.py | 56 @returns: A list of RDBServerHostWrapper objects, ordered by host_id. 184 # Last payload for a host_id wins in the case of conflicting requests. 187 if unique_host_requests.get(request.host_id): 188 unique_host_requests[request.host_id].update(request.payload) 190 unique_host_requests[request.host_id] = request.payload 194 for host_id, payload in unique_host_requests.iteritems(): 195 similar_requests.setdefault(payload, []).append(host_id) 209 host_id=host, payload=payload).get_request() 222 host_ids = set([request.host_id for request in host_requests]) 230 if request.host_id in host_map [all...] |
rdb_testing_utils.py | 46 def __init__(self, hostname, host_id, **kwargs): 47 kwargs.update({'hostname': hostname, 'id': host_id}) 120 def create_special_task(cls, job_id=None, host_id=None, 125 host_id = queue_entry.host.id 128 host = models.Host.objects.get(id=host_id) 342 deps=deps, acls=acls, host_id=None, priority=priority, 415 def assert_host_db_status(self, host_id): 422 @param host_id: Id of the host to check. 426 host = models.Host.objects.get(id=host_id) 467 def check_host_assignment(self, job_id, host_id) [all...] |
host_scheduler_unittests.py | 44 jobs_without_hosts[0].host_id is None) 93 hqes = list(self.db_helper.get_hqes(host_id=host.id)) 113 hqes = list(self.db_helper.get_hqes(host_id=host.id)) 136 hqes = list(self.db_helper.get_hqes(host_id=host.id)) 155 task2 = self.db_helper.create_special_task(host_id=host.id) 185 task = self.db_helper.create_special_task(host_id=host.id) 186 task1 = self.db_helper.create_special_task(host_id=host1.id) 200 self.assertTrue(hqe.active and hqe.host_id == host.id and 203 self.assertTrue(task.is_active == 0 and task.host_id == host.id) 218 task = self.db_helper.create_special_task(host_id=host.id [all...] |
monitor_db_unittest.py | 86 agent_or_task.hostnames = dict((host_id, '192.168.1.1') 87 for host_id in id_list) 160 'ifnull(nullif(host_id, NULL), host_id) DESC, ' 190 def _record_job_scheduled(self, job_id, host_id): 191 record = (job_id, host_id) 194 (job_id, host_id)) 198 def _assert_job_scheduled_on(self, job_id, host_id): 199 record = (job_id, host_id) 203 (job_id, host_id, self._jobs_scheduled) [all...] |
query_managers.py | 34 hostless_query = 'host_id IS NULL AND meta_host IS NULL' 81 'ISNULL(host_id), ' 136 queued_tasks, 'afe_host_queue_entries', 'host_id', 138 join_from_key='host_id', force_left_join=True) 161 @return: A list of dictionaries with the hqe id, job_id and host_id 170 'host_id', flat=True)) 173 queue_entry_id__isnull=True).values_list('host_id', flat=True)) 179 'id', 'job_id', 'host_id')) 199 host_id = hqe.host_id [all...] |
host_scheduler.py | 12 of assignment in this case refers to the modification of the host_id 100 suite, it is a map <host_id -> suite_job_id> 133 if self.hosts_to_suites.get(queue_entry.host_id, None) == parent_id: 140 self.hosts_to_suites[queue_entry.host_id] = parent_id 235 if queue_entry.host_id is None: 237 elif host.id != queue_entry.host_id:
|
scheduler_models.py | 370 _fields = ('id', 'job_id', 'host_id') 412 WHERE afe_hosts_labels.host_id = %s 466 _fields = ('id', 'job_id', 'host_id', 'status', 'meta_host', 478 if self.host_id: 479 self.host = rdb_lib.get_hosts([self.host_id])[0] 526 self.update_field('host_id', host.id) 531 self.update_field('host_id', None) 536 def block_host(self, host_id): 537 logging.info("creating block %s/%s", self.job.id, host_id) 538 row = [0, self.job.id, host_id] [all...] |
prejob_task.py | 52 in the Queued state and setting its host_id to None, so it gets a new host 120 host_id=self.queue_entry.host_id).count()
|
/external/autotest/server/ |
afe_urls.py | 88 def get_host_url(self, host_id): 91 @param host_id: Host id. 95 return self._geturl({'tab_id': 'view_host', 'object_id': host_id})
|
frontend.py | 643 def get_host_special_tasks(self, host_id, **data): 645 host_id=host_id, **data) 649 def get_host_status_task(self, host_id, end_time): 651 host_id=host_id, end_time=end_time) 655 def get_host_diagnosis_interval(self, host_id, end_time, success): 657 host_id=host_id, end_time=end_time,
|
/external/autotest/server/lib/ |
status_history.py | 238 def get_tasks(cls, afe, host_id, start_time, end_time): 247 @param host_id Database host id of the desired host. 257 host_id, 265 def get_status_task(cls, afe, host_id, end_time): 273 @param host_id Database host id of the desired host. 281 task = afe.get_host_status_task(host_id, query_end) 358 def get_hqes(cls, afe, host_id, start_time, end_time): 367 @param host_id Database host id of the desired host. 377 host_id=host_id, [all...] |
/external/autotest/frontend/afe/ |
frontend_test_utils.py | 119 for host_id in hosts: 120 models.HostQueueEntry.objects.create(job=job, host_id=host_id, 122 models.IneligibleHostQueue.objects.create(job=job, host_id=host_id)
|
rpc_interface.py | 540 host_id=host_dict['id'], active=True, complete=False) 545 host_id=host_dict['id'], is_active=True, is_complete=False) [all...] |
/external/autotest/site_utils/ |
job_history.py | 122 It's a dictionary of host_id: TaskCache. 125 def try_get(self, host_id, job_id, start_time, end_time): 128 @param host_id: ID of the host. 136 if not host_id in self: 138 return self[host_id].try_get(job_id, start_time, end_time) 141 def update(self, host_id, start_time, end_time): 144 @param host_id: ID of the host. 151 host_id=host_id, 154 self[host_id] = TaskCache(tasks, search_start_time, search_end_time [all...] |
/external/autotest/client/common_lib/cros/graphite/ |
es_utils.py | 16 'host_id': 1 36 For example, the below query returns job_id, host_id, and job_start 37 for all job_ids in [0, 99999] and host_id matching 10. 40 'fields': ['job_id', 'host_id', 'job_start'], 45 'host_id': 10, 376 "host_id": 1, 385 "host_id": 2, 394 "host_id": 3, 403 "host_id": 22,
|
/external/autotest/cli/ |
host.py | 428 host_id = self.host_ids[host] 429 for a in self.execute_rpc('get_acl_groups', hosts=host_id): 448 host_id = self.host_ids[host] 450 for l in self.execute_rpc('get_labels', host=host_id): 454 self.execute_rpc('host_remove_labels', id=host_id, 539 host_id = self.host_ids[host]
|
host_unittest.py | [all...] |
/external/autotest/contrib/ |
compare_suite.py | 122 self.host_id = self.tko_job.machine_id 131 self.host_id = 0 349 suite_job_runtime.hosts = set([job.host_id 351 if job.host_id != 0])
|
/system/nfc/src/nfa/hci/ |
nfa_hci_act.c | 1318 uint8_t host_id = 0; local [all...] |
nfa_hci_utils.c | 705 bool nfa_hciu_is_active_host(uint8_t host_id) { 709 if (nfa_hci_cb.inactive_host[xx] == host_id) return false; 725 bool nfa_hciu_is_host_reseting(uint8_t host_id) { 729 if (nfa_hci_cb.reset_host[xx] == host_id) return true; [all...] |
/system/nfc/src/nfa/dm/ |
nfa_dm_discover.c | 911 if (nfa_dm_cb.disc_cb.entry[xx].host_id == 943 if (nfa_dm_cb.disc_cb.entry[xx].host_id == [all...] |
/system/nfc/src/nfa/int/ |
nfa_dm_int.h | 337 tNFA_DM_DISC_HOST_ID host_id; /* DH or UICC1/UICC2 */ member in struct:__anon107380 630 tNFA_DM_DISC_HOST_ID host_id,
|
nfa_hci_int.h | 477 extern bool nfa_hciu_is_active_host(uint8_t host_id); 478 extern bool nfa_hciu_is_host_reseting(uint8_t host_id);
|