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_unittest.py
53
'SHARD', '
shard_hostname
', 'host1')
56
def expect_heartbeat(self,
shard_hostname
='host1',
62
'shard_heartbeat',
shard_hostname
=
shard_hostname
,
160
'SHARD', '
shard_hostname
', 'host1')
178
def verify_upload_jobs_and_hqes(name,
shard_hostname
, jobs, hqes,
shard_client.py
112
def __init__(self, global_afe_hostname,
shard_hostname
, tick_pause_sec):
116
self.hostname =
shard_hostname
306
return {'
shard_hostname
': self.hostname,
437
'SHARD', '
shard_hostname
', default=None)
440
'To run the shard client,
shard_hostname
must neither be None nor '
459
shard_hostname
= _get_shard_hostname_and_ensure_running_on_shard()
461
return ShardClient(global_afe_hostname,
shard_hostname
, tick_pause_sec)
/external/autotest/frontend/afe/
rpc_interface_unittest.py
38
def _do_heartbeat_and_assert_response(self,
shard_hostname
='shard1',
47
shard_hostname
=
shard_hostname
,
52
self._assert_shard_heartbeat_response(
shard_hostname
, retval,
55
return
shard_hostname
58
def _assert_shard_heartbeat_response(self,
shard_hostname
, retval, jobs=[],
66
(job.id, job.name,
shard_hostname
) for job in jobs]
164
shard_hostname
=shard2.hostname,
635
shard_hostname
='shard1',
640
shard = models.Shard.objects.create(hostname=
shard_hostname
)
[
all
...]
rpc_utils.py
[
all
...]
rpc_interface.py
[
all
...]
Completed in 59 milliseconds