Searched refs:host_ids (Results 1 – 11 of 11) sorted by relevance
| /external/autotest/scheduler/ |
| D | query_managers.py | 295 def _get_host_acls(self, host_ids): argument
301 return self._get_many2many_dict(query, host_ids)
305 def _get_label_hosts(self, host_ids): argument
306 if not host_ids:
312 """ % self._get_sql_id_list(host_ids)
411 host_ids = self._hosts_available.keys()
412 self._host_acls = self._get_host_acls(host_ids)
414 self._get_label_hosts(host_ids))
|
| D | rdb_lib.py | 90 def get_hosts(host_ids): argument
104 for host_id in host_ids:
|
| D | rdb.py | 37 def update_hosts(self, host_ids, **kwargs): argument
44 self.host_objects.filter(id__in=host_ids).update(**kwargs)
219 host_ids = set([request.host_id for request in host_requests])
224 for host in self.host_query_manager.get_hosts(host_ids):
|
| D | agent_task.py | 153 self.host_ids = []
161 self.host_ids = [entry.host.id for entry in queue_entries]
167 self.host_ids = [host.id]
|
| D | monitor_db_unittest.py | 33 host_ids = () variable in DummyAgent
83 agent_or_task.host_ids = agent_or_task.queue_entry_ids = id_list
198 def _assert_job_scheduled_on_number_of(self, job_id, host_ids, number): argument
201 for host_id in host_ids:
208 'Jobs scheduled: %s' % (job_id, number, host_ids, found))
211 'Jobs scheduled: %s' % (job_id, number, host_ids, found))
|
| D | monitor_db.py | 434 self._register_agent_for_ids(self._host_agents, agent.host_ids, agent)
455 self._unregister_agent_for_ids(self._host_agents, agent.host_ids,
1010 'queue_entry ids:%s' % (agent.host_ids,
1114 self.host_ids = task.host_ids
|
| D | scheduler_models.py | 135 self.host_ids = ()
|
| /external/autotest/scheduler/shard/ |
| D | shard_client.py | 161 host_ids = [h['id'] for h in hosts_serialized]
162 logging.info('Heartbeat response contains hosts %s', host_ids)
252 host_ids = []
255 host_ids.append(h.id)
257 return job_ids, host_ids, host_statuses
|
| D | shard_client_integration_tests.py | 51 job_ids, host_ids = client._get_known_ids()
92 job_ids, host_ids = client._get_known_ids()
|
| /external/autotest/frontend/afe/ |
| D | rpc_utils.py | 317 host_ids = [host.id for host in host_objects]
318 hosts_in_job = models.Host.objects.filter(id__in=host_ids)
556 host_ids = set()
559 if host.id in host_ids:
561 host_ids.add(host.id)
|
| D | models.py | 546 host_ids = set(Host.objects.filter(
553 if host_ids:
554 Host.objects.filter(pk__in=host_ids).update(shard=shard)
555 return list(Host.objects.filter(pk__in=host_ids).all())
|