Searched refs:host_ids (Results 1 – 12 of 12) sorted by relevance
| /external/autotest/venv/lucifer/ |
| D | handoffs.py | 56 host_ids = {id for id in hqes.values_list('host_id', flat=True)
58 logger.debug('Found Hosts associated with jobs: %r', host_ids)
59 _clean_up_hosts(host_ids)
72 def _clean_up_hosts(host_ids): argument
83 .filter(id__in=host_ids)
|
| /external/autotest/cli/ |
| D | host.py | 412 self.host_ids = {}
521 if host not in self.host_ids:
523 host_id = self.host_ids[host]
542 if host in self.host_ids:
543 host_id = self.host_ids[host]
719 self.host_ids[host['hostname']] = host['id']
721 if host not in self.host_ids:
724 host_id = self.host_ids[host]
1045 self.host_ids = {}
1067 self.host_ids[host['hostname']] = host['id']
[all …]
|
| D | host_unittest.py | 1255 def _gen_acls_rpcs(self, hosts, acls, host_ids=[]): argument
1263 for host_id in host_ids:
1457 host_ids = []
1462 host_ids.append(host_id)
1493 rpcs += self._gen_acls_rpcs(hosts, acls, host_ids=host_ids)
|
| /external/autotest/scheduler/shard/ |
| D | shard_client.py | 185 host_ids = [h['id'] for h in hosts_serialized]
186 logging.info('Heartbeat response contains hosts %s', host_ids)
300 host_ids = []
303 host_ids.append(h.id)
305 return job_ids, host_ids, host_statuses
|
| D | shard_client_integration_tests.py | 51 job_ids, host_ids, _ = client._get_known_jobs_and_hosts()
92 job_ids, host_ids, _ = client._get_known_jobs_and_hosts()
|
| /external/autotest/scheduler/ |
| D | rdb_lib.py | 90 def get_hosts(host_ids): argument
104 for host_id in host_ids:
|
| D | rdb.py | 40 def update_hosts(self, host_ids, **kwargs): argument
47 self.host_objects.filter(id__in=host_ids).update(**kwargs)
221 host_ids = set([request.host_id for request in host_requests])
226 for host in self.host_query_manager.get_hosts(host_ids):
|
| D | agent_task.py | 161 self.host_ids = []
169 self.host_ids = []
174 self.host_ids.append(entry.host.id)
187 self.host_ids = [host.id]
|
| D | monitor_db_unittest.py | 36 host_ids = () variable in DummyAgent
86 agent_or_task.host_ids = agent_or_task.queue_entry_ids = id_list
208 def _assert_job_scheduled_on_number_of(self, job_id, host_ids, number): argument
211 for host_id in host_ids:
218 'Jobs scheduled: %s' % (job_id, number, host_ids, found))
221 'Jobs scheduled: %s' % (job_id, number, host_ids, found))
|
| D | monitor_db.py | 490 self._register_agent_for_ids(self._host_agents, agent.host_ids, agent)
511 self._unregister_agent_for_ids(self._host_agents, agent.host_ids,
1206 'queue_entry ids:%s' % (agent.host_ids,
1277 self.host_ids = task.host_ids
|
| D | query_managers.py | 392 host_ids = self._hosts_available.keys()
|
| /external/autotest/frontend/afe/ |
| D | rpc_utils.py | 297 host_ids = [host.id for host in host_objects]
298 hosts_in_job = models.Host.objects.filter(id__in=host_ids)
|