| /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.
183 # Last payload for a host_id wins in the case of conflicting requests.
186 if unique_host_requests.get(request.host_id):
187 unique_host_requests[request.host_id].update(request.payload)
189 unique_host_requests[request.host_id] = request.payload
193 for host_id, payload in unique_host_requests.iteritems():
194 similar_requests.setdefault(payload, []).append(host_id)
208 host_id=host, payload=payload).get_request()
221 host_ids = set([request.host_id for request in host_requests])
229 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
101 suite, it is a map <host_id -> suite_job_id>
134 if self.hosts_to_suites.get(queue_entry.host_id, None) == parent_id:
141 self.hosts_to_suites[queue_entry.host_id] = parent_id
236 if queue_entry.host_id is None:
238 elif host.id != queue_entry.host_id:
|
| scheduler_models.py | 343 _fields = ('id', 'job_id', 'host_id')
414 'WHERE %(host_label_table)s.host_id = %(host_id)s '
420 'host_id': self.id
426 'host_id': self.id
483 _fields = ('id', 'job_id', 'host_id', 'status', 'meta_host',
502 if self.host_id:
503 self.host = rdb_lib.get_hosts([self.host_id])[0]
573 self.update_field('host_id', host.id)
578 self.update_field('host_id', None
[all...] |
| /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 | 664 def get_host_special_tasks(self, host_id, **data):
666 host_id=host_id, **data)
670 def get_host_status_task(self, host_id, end_time):
672 host_id=host_id, end_time=end_time)
676 def get_host_diagnosis_interval(self, host_id, end_time, success):
678 host_id=host_id, end_time=end_time,
|
| /tools/test/connectivity/acts/tests/google/bt/hid/ |
| HidDeviceTest.py | 108 host_id = self.host_ad.droid.bluetoothGetLocalAddress()
163 hid_device_send_key_data_report(host_id, self.device_ad, "04")
164 hid_device_send_key_data_report(host_id, self.device_ad, "05")
167 self.device_ad.droid.bluetoothHidDeviceReportError(host_id, 1)
171 host_id, 1, 1, hid_keyboard_report("04"))
214 host_id = self.host_ad.droid.bluetoothGetLocalAddress()
224 hid_device_send_key_data_report(host_id, self.device_ad, "04")
225 hid_device_send_key_data_report(host_id, self.device_ad, "05")
|
| /external/autotest/server/lib/ |
| status_history.py | 242 def get_tasks(cls, afe, host_id, start_time, end_time):
251 @param host_id Database host id of the desired host.
261 host_id,
269 def get_status_task(cls, afe, host_id, end_time):
277 @param host_id Database host id of the desired host.
285 task = afe.get_host_status_task(host_id, query_end)
362 def get_hqes(cls, afe, host_id, start_time, end_time):
371 @param host_id Database host id of the desired host.
381 host_id=host_id,
[all...] |
| /external/ltp/testcases/lib/ |
| test_net.sh | 233 # tst_ipaddr_un NET_ID [HOST_ID]
235 # COUNTER: Integer value for counting HOST_ID and NET_ID. Default is 1.
238 # HOST_ID: Integer or hex value of host. For IPv4 is 4th octet, for
242 local counter host_id net_id max_host_id max_net_id tmp type
262 host_id=$((tmp % max_host_id))
265 if [ $host_id -eq 0 ]; then
266 host_id=$max_host_id
271 host_id="${2:-0}"
274 host_id=$(printf %d $host_id)
[all...] |
| /external/autotest/frontend/afe/ |
| frontend_test_utils.py | 143 for host_id in hosts:
144 models.HostQueueEntry.objects.create(job=job, host_id=host_id,
146 models.IneligibleHostQueue.objects.create(job=job, host_id=host_id)
|
| rpc_interface.py | 579 {'host_id': host_obj.id, 'attribute': attribute})
691 host_id=host_dict['id'], active=True, complete=False)
696 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/scheduler/shard/ |
| shard_client_unittest.py | 230 host_id = host_serialized[u'id']
240 self.expect_heartbeat(known_host_ids=[host_id],
242 return_incorrect_hosts=[host_id, 42])
249 host = models.Host.smart_get(host_id)
258 host = models.Host.smart_get(host_id)
|
| /external/tensorflow/tensorflow/contrib/tpu/python/tpu/ |
| tpu_context.py | 342 def _placement_function(_sentinal=None, core_id=None, host_id=None): # pylint: disable=invalid-name
344 if core_id is not None and host_id is not None:
346 'core_id and host_id can have only one non-None value.')
352 host_id = core_id / self.num_of_cores_per_host
353 return '/job:%s/task:%d/device:CPU:0' % (master, host_id)
368 host_id = i / num_of_cores_per_host
370 return '%s/task:%d/device:TPU:%d' % (job_device, host_id, ordinal_id)
|
| tpu_system_metadata.py | 69 host_id = match.group(1)
71 device_dict[host_id].append(core_id)
|
| tpu_estimator.py | 664 ctx, input_fn, inputs_structure_recorder, batch_axis, device, host_id):
691 host_id, (0, 0, 0))[shard_index_in_host]
[all...] |
| /external/autotest/cli/ |
| host.py | 429 host_id = self.host_ids[host]
430 for a in self.execute_rpc('get_acl_groups', hosts=host_id):
449 host_id = self.host_ids[host]
451 for l in self.execute_rpc('get_labels', host=host_id):
455 self.execute_rpc('host_remove_labels', id=host_id,
540 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.cc | 1320 uint8_t host_id = 0; local
[all...] |
