HomeSort by relevance Sort by last modified time
    Searched refs:shard_hostname (Results 1 - 9 of 9) sorted by null

  /external/autotest/frontend/afe/
site_rpc_interface_unittest.py 503 def _do_heartbeat_and_assert_response(self, shard_hostname='shard1',
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=[],
529 (job.id, job.name, shard_hostname) for job in jobs]
549 self, jobs, hqes, shard_hostname='host1',
568 shard_hostname=shard_hostname,
    [all...]
site_rpc_interface.py 405 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(),
409 @param shard_hostname: Hostname of the calling shard
456 shard_obj = rpc_utils.retrieve_shard(shard_hostname=shard_hostname)
529 shard = rpc_utils.retrieve_shard(shard_hostname=hostname)
rpc_utils.py     [all...]
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/
rdb_testing_utils.py 138 def create_shard(cls, shard_hostname):
141 @param shard_hostname: The hostname of the shard.
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):
176 @param shard_hostname: The hostname of a shard to assign the job.
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):
410 if shard_hostname
    [all...]
  /external/autotest/scheduler/shard/
shard_client_integration_tests.py 30 'SHARD', 'shard_hostname', 'host1')
42 job = self.create_job(deps=set(['a']), shard_hostname=client.hostname)
64 job = self.create_job(deps=set(['a']), shard_hostname=client.hostname)
shard_client.py 104 def __init__(self, global_afe_hostname, shard_hostname, tick_pause_sec):
108 self.hostname = shard_hostname
277 return {'shard_hostname': self.hostname,
356 'SHARD', 'shard_hostname', default=None)
359 'To run the shard client, shard_hostname must neither be None nor '
378 shard_hostname = _get_shard_hostname_and_ensure_running_on_shard()
380 return ShardClient(global_afe_hostname, shard_hostname, tick_pause_sec)
shard_client_unittest.py 48 'SHARD', 'shard_hostname', 'host1')
51 def expect_heartbeat(self, shard_hostname='host1',
57 'shard_heartbeat', shard_hostname=shard_hostname,
155 'SHARD', 'shard_hostname', 'host1')
173 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes,
  /external/autotest/puppylab/
clusterctl 147 shard_hostname = '%s:%s' % (lab_manifest.vm_host_name, shard_port)
151 '%s_shadow_config_hostname' % shard_name: shard_hostname,
156 # Assign a board to a shard. Use the shard_hostname as this
158 self.shard_board_map[shard_hostname] = board

Completed in 116 milliseconds