| /external/autotest/frontend/afe/ |
| D | site_rpc_interface_unittest.py | 503 def _do_heartbeat_and_assert_response(self, shard_hostname='shard1', argument
512 shard_hostname=shard_hostname,
517 self._assert_shard_heartbeat_response(shard_hostname, retval,
520 return shard_hostname
523 def _assert_shard_heartbeat_response(self, shard_hostname, retval, jobs=[], argument
529 (job.id, job.name, shard_hostname) for job in jobs]
549 self, jobs, hqes, shard_hostname='host1', argument
568 shard_hostname=shard_hostname,
574 shard_hostname=shard_hostname,
607 jobs=jobs, hqes=hqes, shard_hostname='other_shard')
[all …]
|
| D | rpc_utils.py | 1070 def retrieve_shard(shard_hostname): argument
1082 return models.Shard.smart_get(shard_hostname)
1191 shard_hostname = None
1194 shard_hostname = host.shard.rpc_hostname()
1196 if shard_hostname and not server_utils.is_shard():
1198 [shard_hostname],
1245 for shard_hostname in shard_hostnames:
1246 afe = frontend_wrappers.RetryingAFE(server=shard_hostname,
|
| D | site_rpc_interface.py | 405 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
456 shard_obj = rpc_utils.retrieve_shard(shard_hostname=shard_hostname)
529 shard = rpc_utils.retrieve_shard(shard_hostname=hostname)
|
| D | rpc_interface_unittest.py | 440 shard_hostname = 'shard1'
443 'SHARD', 'shard_hostname', shard_hostname)
447 shard = models.Shard.objects.create(hostname=shard_hostname)
461 server=shard_hostname, user=None)
|
| /external/autotest/scheduler/ |
| D | rdb_testing_utils.py | 138 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/scheduler/shard/ |
| D | shard_client_unittest.py | 51 def expect_heartbeat(self, shard_hostname='host1', argument
57 'shard_heartbeat', shard_hostname=shard_hostname,
173 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes, argument
|
| D | shard_client.py | 104 def __init__(self, global_afe_hostname, shard_hostname, tick_pause_sec): argument
108 self.hostname = shard_hostname
378 shard_hostname = _get_shard_hostname_and_ensure_running_on_shard()
380 return ShardClient(global_afe_hostname, shard_hostname, tick_pause_sec)
|
| D | shard_client_integration_tests.py | 42 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/puppylab/ |
| D | clusterctl | 147 shard_hostname = '%s:%s' % (lab_manifest.vm_host_name, shard_port)
151 '%s_shadow_config_hostname' % shard_name: shard_hostname,
158 self.shard_board_map[shard_hostname] = board
|
| D | ClusterTemplate | 63 "shard_hostname" => "%(shard1_shadow_config_hostname)s",
|
| /external/autotest/ |
| D | global_config.ini | 59 shard_hostname: key
|