Home
last modified time | relevance | path

Searched refs:shard_hostname (Results 1 – 8 of 8) sorted by relevance

/external/autotest/scheduler/
Drdb_testing_utils.py138 def create_shard(cls, shard_hostname): argument
143 shard = cls.get_shard(hostname=shard_hostname)
144 return (models.Shard.objects.create(hostname=shard_hostname)
172 def assign_job_to_shard(cls, job_id, shard_hostname): argument
183 job_filter, shard_hostname)
184 job_filter.update(shard=cls.create_shard(shard_hostname))
382 priority=0, parent_job_id=None, shard_hostname=None): argument
410 if shard_hostname:
411 self.db_helper.assign_job_to_shard(job.id, shard_hostname)
/external/autotest/frontend/afe/
Drpc_interface_unittest.py41 def _do_heartbeat_and_assert_response(self, shard_hostname='shard1', argument
50 shard_hostname=shard_hostname,
55 self._assert_shard_heartbeat_response(shard_hostname, retval,
58 return shard_hostname
61 def _assert_shard_heartbeat_response(self, shard_hostname, retval, jobs=[], argument
69 (job.id, job.name, shard_hostname) for job in jobs]
167 shard_hostname=shard2.hostname,
638 shard_hostname='shard1', argument
643 shard = models.Shard.objects.create(hostname=shard_hostname)
1132 shard_hostname = 'shard1'
[all …]
Drpc_utils.py936 def retrieve_shard(shard_hostname): argument
946 return models.Shard.smart_get(shard_hostname)
1055 shard_hostname = None
1058 shard_hostname = host.shard.hostname
1060 if shard_hostname and not server_utils.is_shard():
1062 [shard_hostname],
1108 for shard_hostname in shard_hostnames:
1109 afe = frontend_wrappers.RetryingAFE(server=shard_hostname,
Drpc_interface.py2034 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
2083 shard_obj = rpc_utils.retrieve_shard(shard_hostname=shard_hostname)
2231 shard = rpc_utils.retrieve_shard(shard_hostname=hostname)
/external/autotest/scheduler/shard/
Dshard_client_unittest.py57 def expect_heartbeat(self, shard_hostname='host1', argument
63 'shard_heartbeat', shard_hostname=shard_hostname,
179 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes, argument
Dshard_client.py118 def __init__(self, global_afe_hostname, shard_hostname, tick_pause_sec): argument
122 self.hostname = shard_hostname
505 shard_hostname = _get_shard_hostname_and_ensure_running_on_shard()
507 return ShardClient(global_afe_hostname, shard_hostname, tick_pause_sec)
Dshard_client_integration_tests.py42 job = self.create_job(deps=set(['a']), shard_hostname=client.hostname)
64 job = self.create_job(deps=set(['a']), shard_hostname=client.hostname)
/external/autotest/
Dglobal_config.ini60 shard_hostname: key