| /external/autotest/scheduler/ |
| D | 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))
112 self.assertTrue(request.host_id == client_host.id)
118 host_id = 10
[all …]
|
| D | rdb.py | 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:
230 self.update_response_map(request, [host_map[request.host_id]])
286 if request.host_id and request.host_id != host.id:
[all …]
|
| D | rdb_testing_utils.py | 46 def __init__(self, hostname, host_id, **kwargs): argument
47 kwargs.update({'hostname': hostname, 'id': host_id})
120 def create_special_task(cls, job_id=None, host_id=None, argument
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): argument
426 host = models.Host.objects.get(id=host_id)
467 def check_host_assignment(self, job_id, host_id): argument
484 host = models.Host.objects.get(id=host_id)
[all …]
|
| D | 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)
|
| D | 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 …]
|
| D | monitor_db_unittest.py | 87 agent_or_task.hostnames = dict((host_id, '192.168.1.1')
88 for host_id in id_list)
191 def _record_job_scheduled(self, job_id, host_id): argument
192 record = (job_id, host_id)
195 (job_id, host_id))
199 def _assert_job_scheduled_on(self, job_id, host_id): argument
200 record = (job_id, host_id)
204 (job_id, host_id, self._jobs_scheduled))
211 for host_id in host_ids:
212 record = (job_id, host_id)
[all …]
|
| D | host_scheduler.py | 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:
|
| D | scheduler_models.py | 502 if self.host_id:
503 self.host = rdb_lib.get_hosts([self.host_id])[0]
583 def block_host(self, host_id): argument
584 logging.info("creating block %s/%s", self.job.id, host_id)
585 row = [0, self.job.id, host_id]
590 def unblock_host(self, host_id): argument
591 logging.info("removing block %s/%s", self.job.id, host_id)
593 'job_id=%d and host_id=%d' % (self.job.id, host_id))
951 return (self.host_id is None
1266 host=models.Host.objects.get(id=queue_entry.host_id),
|
| D | query_managers.py | 199 host_id = hqe.host_id
203 hosts_to_suites[host_id] = parent_job_id
|
| /external/bcc/examples/networking/distributed_bridge/ |
| D | tunnel_mesh.py | 18 host_id = int(argv[2]) variable
44 gre_local='172.16.1.%d' % (100 + host_id),
66 if i != host_id:
86 ipaddr = "99.1.%d.%d/24" % (j, host_id + 1)
91 if dhcp == 1 and host_id == 0:
115 call(["/bin/rm", "-rf", "/tmp/dhcp_%d_%d" % (host_id, j)])
116 call(["mkdir", "/tmp/dhcp_%d_%d" % (host_id, j)])
117 call(["touch", "/tmp/dhcp_%d_%d/dhclient.conf" % (host_id, j)])
118 call(["touch", "/tmp/dhcp_%d_%d/dhclient.lease" % (host_id, j)])
120 "-cf", "/tmp/dhcp_%d_%d/dhclient.conf" % (host_id, j),
[all …]
|
| D | tunnel.py | 17 host_id = int(argv[1]) variable
67 ipaddr = "99.1.%d.%d/24" % (i, host_id + 1)
|
| /external/ltp/testcases/lib/ |
| D | tst_net.sh | 361 local counter host_id net_id max_host_id max_net_id tmp type
381 host_id=$((tmp % max_host_id))
384 if [ $host_id -eq 0 ]; then
385 host_id=$max_host_id
390 host_id="${2:-0}"
393 host_id=$(printf %d $host_id)
396 [ $host_id -lt 0 ] && host_id=1
400 host_id=$((host_id % max_net_id))
403 echo "${IPV4_NET16_UNUSED}.${net_id}.${host_id}"
407 [ $host_id -gt 0 ] && host_id="$(printf %x $host_id)" || host_id=
[all …]
|
| /external/autotest/database/ |
| D | schema_129.sql | 61 `host_id` int(11) DEFAULT NULL,
63 UNIQUE KEY `acl_groups_hosts_both_ids` (`aclgroup_id`,`host_id`),
64 KEY `acl_groups_hosts_host_id` (`host_id`),
66 …CONSTRAINT `acl_groups_hosts_host_id_fk` FOREIGN KEY (`host_id`) REFERENCES `afe_hosts` (`id`) ON …
211 `host_id` int(11) NOT NULL,
215 KEY `host_id` (`host_id`),
217 CONSTRAINT `afe_host_attributes_ibfk_1` FOREIGN KEY (`host_id`) REFERENCES `afe_hosts` (`id`)
231 `host_id` int(11) DEFAULT NULL,
243 UNIQUE KEY `host_queue_entries_job_id_and_host_id` (`job_id`,`host_id`),
244 KEY `host_queue_entries_host_id` (`host_id`),
[all …]
|
| /external/autotest/server/lib/ |
| D | status_history.py | 223 def get_tasks(cls, afe, host_id, start_time, end_time): argument
242 host_id,
250 def get_status_task(cls, afe, host_id, end_time): argument
266 task = afe.get_host_status_task(host_id, query_end)
332 def get_hqes(cls, afe, host_id, start_time, end_time): argument
351 host_id=host_id,
627 def get_diagnosis_interval(host_id, end_time, success): argument
654 host_id=host_id, is_complete=True)
674 def get_status_task(host_id, end_time): argument
700 host_id=host_id,
|
| /external/tensorflow/tensorflow/python/tpu/ |
| D | tpu_context.py | 166 def _placement_function(host_id): argument
168 return self._internal_ctx.tpu_host_placement_function(host_id=host_id)
527 …def _placement_function(_sentinal=None, replica_id=None, host_id=None): # pylint: disable=invalid… argument
530 if replica_id is not None and host_id is not None:
542 host_id = replica_id / self.num_of_cores_per_host
544 return '/job:%s/task:%d/device:CPU:0' % (master, host_id)
559 host_id = i / num_of_cores_per_host
561 return '%s/task:%d/device:TPU:%d' % (job_device, host_id, ordinal_id)
565 def tpu_ordinal_function(self, host_id): argument
581 replica = self.device_assignment.lookup_replicas(host_id,
[all …]
|
| D | tpu_embedding.py | 834 for host_id, table_variable, accumulator_variable in (zip(
843 shard_id=host_id))
854 for host_id, table_variable, accumulator_variable in (zip(
861 shard_id=host_id))
922 for host_id, table_variable, m_variable, v_variable in (zip(
933 shard_id=host_id))
945 for host_id, table_variable, m_variable, v_variable in (zip(
953 shard_id=host_id))
986 for host_id, table_variable in (zip(
995 shard_id=host_id))
[all …]
|
| D | tpu_estimator.py | 732 ctx, input_fn, inputs_structure_recorder, host_device, host_id): argument
735 tpu_ordinal_function_impl = ctx.tpu_ordinal_function(host_id)
746 invocation_index=host_id * ctx.num_of_cores_per_host + core_ordinal)
775 ctx, input_fn, inputs_structure_recorder, batch_axis, device, host_id): argument
783 internal_ctx=ctx, input_device=device, invocation_index=host_id)
802 tpu_ordinal_function_impl = ctx.tpu_ordinal_function(host_id)
850 ctx, input_fn, inputs_structure_recorder, device, host_id): argument
857 internal_ctx=ctx, input_device=device, invocation_index=host_id)
873 tpu_ordinal_function_impl = ctx.tpu_ordinal_function(host_id)
917 host_id=host_id,
[all …]
|
| /external/autotest/site_utils/ |
| D | job_history.py | 125 def try_get(self, host_id, job_id, start_time, end_time): argument
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): argument
151 host_id=host_id,
154 self[host_id] = TaskCache(tasks, search_start_time, search_end_time)
275 host_id=self.host.id,
|
| /external/autotest/frontend/afe/ |
| D | 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)
|
| D | rpc_interface.py | 687 host_id=host_dict['id'], active=True, complete=False)
692 host_id=host_dict['id'], is_active=True, is_complete=False)
1454 def get_host_special_tasks(host_id, **filter_data): argument
1468 host = models.Host.smart_get(host_id, False)
1470 return get_special_tasks(host_id=host_id, **filter_data)
1478 host_id=host_id, **filter_data)
1515 def get_status_task(host_id, end_time): argument
1537 status_history.get_status_task(host_id, end_time),
1542 def get_host_status_task(host_id, end_time): argument
1557 host = models.Host.smart_get(host_id)
[all …]
|
| /external/u-boot/disk/ |
| D | part_amiga.h | 34 u32 host_id; member
85 u32 host_id; member
101 u32 host_id; member
|
| /external/autotest/server/ |
| D | frontend.py | 625 def get_host_special_tasks(self, host_id, **data): argument
627 host_id=host_id, **data)
631 def get_host_status_task(self, host_id, end_time): argument
633 host_id=host_id, end_time=end_time)
637 def get_host_diagnosis_interval(self, host_id, end_time, success): argument
639 host_id=host_id, end_time=end_time,
|
| D | afe_urls.py | 88 def get_host_url(self, host_id): argument
95 return self._geturl({'tab_id': 'view_host', 'object_id': host_id})
|
| /external/autotest/scheduler/shard/ |
| D | shard_client_unittest.py | 231 host_id = host_serialized[u'id']
241 self.expect_heartbeat(known_host_ids=[host_id],
243 return_incorrect_hosts=[host_id, 42])
250 host = models.Host.smart_get(host_id)
259 host = models.Host.smart_get(host_id)
|
| /external/autotest/cli/ |
| D | host_unittest.py | 1235 def _gen_labels_rpcs(self, labels, platform=False, host_id=None): argument
1243 if host_id:
1244 rpcs.append(('get_labels', {'host': host_id}, True, []))
1263 for host_id in host_ids:
1264 rpcs.append(('get_acl_groups', {'hosts': host_id}, True, []))
1461 host_id = self._host_ids[self._hosts.index(host)]
1462 host_ids.append(host_id)
1479 rpcs += self._gen_labels_rpcs(labels, host_id=host_id)
1485 host_id=host_id)
|