OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:shard_hostname
(Results
1 - 7
of
7
) sorted by null
/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
118
def __init__(self, global_afe_hostname,
shard_hostname
, tick_pause_sec):
122
self.hostname =
shard_hostname
333
return {'
shard_hostname
': self.hostname,
483
'SHARD', '
shard_hostname
', default=None)
486
'To run the shard client,
shard_hostname
must neither be None nor '
505
shard_hostname
= _get_shard_hostname_and_ensure_running_on_shard()
507
return ShardClient(global_afe_hostname,
shard_hostname
, tick_pause_sec)
shard_client_unittest.py
54
'SHARD', '
shard_hostname
', 'host1')
57
def expect_heartbeat(self,
shard_hostname
='host1',
63
'shard_heartbeat',
shard_hostname
=
shard_hostname
,
161
'SHARD', '
shard_hostname
', 'host1')
179
def verify_upload_jobs_and_hqes(name,
shard_hostname
, jobs, hqes,
/external/autotest/frontend/afe/
rpc_interface_unittest.py
41
def _do_heartbeat_and_assert_response(self,
shard_hostname
='shard1',
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=[],
69
(job.id, job.name,
shard_hostname
) for job in jobs]
167
shard_hostname
=shard2.hostname,
638
shard_hostname
='shard1',
643
shard = models.Shard.objects.create(hostname=
shard_hostname
)
[
all
...]
rpc_utils.py
[
all
...]
rpc_interface.py
[
all
...]
Completed in 227 milliseconds