| /external/autotest/contrib/ |
| reverify_hosts | 14 # I _think_ (but I don't know) that the AFE calls operate on all the
23 frontend.AFE().reverify_hosts(hostnames=sys.argv[1:])
|
| shared_hosts.py | 10 cautotest = frontend.AFE(server='cautotest')
11 cautotest_cq = frontend.AFE(server='cautotest-cq')
|
| task_runner.sh | 22 AFE=localhost:8001
70 $AT_DIR/cli/atest host delete $hostnames --web $AFE
71 $AT_DIR/cli/atest label delete $labels --web $AFE
73 $AT_DIR/cli/atest host create $hostnames --web $AFE
74 $AT_DIR/cli/atest label add -m $hostnames $labels --web $AFE
126 $AT_DIR/cli/atest shard delete $SHARD_NAME --web $AFE
128 $AT_DIR/cli/atest shard create $SHARD_NAME -l $SHARD_BOARD --web $AFE
|
| stage_build.py | 45 AFE = frontend.AFE()
46 AFE.set_host_attribute('job_repo_url', repo_url, hostname=options.host)
|
| generate_rpm_mapping.py | 22 <Upload mapping information in csv file to AFE>
400 @param hosts: hosts objects get from AFE.
459 help='AFE server that the script will be talking to. '
464 AFE = frontend_wrappers.RetryingAFE(timeout_min=5, delay_sec=10,
466 logging.info('Connected to %s', AFE.server)
468 AFE.get_hosts(),
|
| find_suite_tasks.py | 30 parser.add_argument('--afe', type=str, action='store',
31 help='AFE server to connect to')
37 def GetSuiteHQEs(suite_job_id, look_past_seconds, afe=None, tko=None):
40 @param suite_job_id: Suite's AFE job id.
43 @param afe: AFE database handle.
50 if afe is None:
51 afe = frontend.AFE()
79 child_jobs = afe.get_jobs(parent_job_id=suite_job_id
[all...] |
| /external/autotest/server/ |
| afe_utils.py | 5 """Utility functions for AFE-based interactions.
8 utilities that require accessing the AFE, should do so by creating
9 their own instance of the AFE client and interact with it directly.
18 AFE = frontend_wrappers.RetryingAFE(timeout_min=5, delay_sec=10)
19 _CROS_VERSION_MAP = AFE.get_stable_version_map(AFE.CROS_IMAGE_TYPE)
20 _FIRMWARE_VERSION_MAP = AFE.get_stable_version_map(AFE.FIRMWARE_IMAGE_TYPE)
21 _FAFT_VERSION_MAP = AFE.get_stable_version_map(AFE.FAFT_IMAGE_TYPE
[all...] |
| /external/autotest/test_suites/ |
| dev_harness.py | 48 AFE = frontend.AFE(debug=True)
51 m = random.choice(AFE.get_hostnames(label='board:'+new_globals['board']))
53 label = AFE.get_labels(
56 AFE.set_host_attribute(constants.JOB_REPO_URL, repo_url, hostname=m)
|
| /external/autotest/frontend/afe/ |
| direct_afe.py | 8 from autotest_lib.frontend.afe import rpc_interface
10 class directAFE(frontend.AFE):
12 A wrapper for frontend.AFE which exposes all of the AFE
|
| /external/autotest/utils/ |
| reverify_repair_failed.py | 26 afe_client = frontend.AFE(debug=False, server=options.server)
|
| tko_publish.py | 62 afe = frontend.AFE()
63 # the way AFE API is right now is to give a whole list of jobs and can't
65 finished_jobs = afe.get_jobs(finished=True)
|
| /external/autotest/cli/ |
| atest_migrate_host | 8 old = frontend.AFE(web_server='http://' + sys.argv[1])
9 new = frontend.AFE(web_server='http://' + sys.argv[2])
|
| /external/autotest/site_utils/ |
| test_push.py | 37 from autotest_lib.frontend.afe import models
38 from autotest_lib.frontend.afe import rpc_utils
56 AFE = frontend_wrappers.RetryingAFE(timeout_min=0.5, delay_sec=2)
150 hosts = AFE.run('get_hosts', status='Ready', locked=False)
181 AFE.run('abort_host_queue_entries', job=job_id)
188 AFE.reverify_hosts(hostnames=[hostname])
194 hosts = [h.hostname for h in AFE.get_hosts()]
195 AFE.reverify_hosts(hostnames=hosts)
303 hosts = AFE.get_hosts(label=constants.Labels.BOARD_PREFIX+board,
311 AFE.run('host_remove_labels', id=host.id, labels=labels_to_remove
[all...] |
| abort_suite.py | 54 def abort_suites(afe, substring):
62 @param afe: An instance of frontend.AFE to make RPCs with.
66 hqe_info = afe.run('abort_host_queue_entries',
89 afe = frontend.AFE()
92 abort_suites(afe, name)
|
| lxc_cleanup.py | 34 AFE = frontend_wrappers.RetryingAFE(timeout_min=0.1, delay_sec=10)
81 hqes = AFE.get_host_queue_entries(job_id=job_id)
|
| sync_cloudsql_access.py | 36 ROLES_REQUIRE_TKO_ACCESS = {'scheduler', 'drone', 'shard', 'database', 'afe'}
53 def update_allowed_networks(project, instance, afe=None, extra_servers=None):
58 @param afe: Server of the frontend RPC, default to None to use the server
64 rpc = frontend.AFE(server=afe)
101 parser.add_argument('--afe', type=str, dest='afe',
110 update_allowed_networks(options.project, options.instance, options.afe,
|
| label_cleaner.py | 142 server = frontend.AFE(server=GLOBAL_AFE).run(
|
| deploy_server_local.py | 41 # frontend repo, no need to update afe.
42 COMMANDS_TO_REPOS_DICT = {'afe': 'frontend/',
48 AFE = frontend_wrappers.RetryingAFE(
343 not AFE.run('get_servers', hostname=socket.getfqdn(),
431 help='Force to run the update commands for afe, tko '
|
| /external/autotest/site_utils/suite_scheduler/ |
| board_enumerator_unittest.py | 24 self.afe = self.mox.CreateMock(frontend.AFE)
25 self.enumerator = board_enumerator.BoardEnumerator(afe=self.afe)
39 self.afe.get_labels(name__startswith=self.prefix).AndReturn(
47 self.afe.get_labels(name__startswith=self.prefix).AndReturn([])
54 """Listing boards raises an exception from the AFE."""
55 self.afe.get_labels(name__startswith=self.prefix).AndRaise(Exception())
|
| /external/autotest/server/cros/dynamic_suite/ |
| frontend_wrappers.py | 12 from autotest_lib.frontend.afe.json_rpc import proxy
43 class RetryingAFE(frontend.AFE):
44 """Wrapper around frontend.AFE that retries all RPCs.
60 """Set timeout minutes for the AFE server.
62 @param timeout_min: The timeout minutes for AFE server.
|
| tools_unittest.py | 32 self.afe = self.mox.CreateMock(frontend.AFE)
|
| job_status_unittest.py | 36 self.afe = self.mox.CreateMock(frontend.AFE)
48 self.afe.get_jobs(id=job.id, finished=True).AndReturn(job)
54 self.afe.run('get_host_queue_entries',
86 self.afe.get_jobs(id=jobs[0].id, finished=True).AndReturn([])
98 results = [result for result in job_status.wait_for_results(self.afe,
138 self.afe.get_jobs(parent_job_id=parent_job_id).AndReturn(jobs[:6])
148 self.afe.get_jobs(id__in=list(job_id_set),
157 self.afe,
178 results = list(job_status._yield_job_results(self.afe, self.tko, job)
[all...] |
| /external/autotest/server/hosts/ |
| afe_store_unittest.py | 9 from autotest_lib.frontend.afe.json_rpc import proxy as rpc_proxy
19 self.mock_afe = mock.create_autospec(frontend.AFE, instance=True)
20 self.store = afe_store.AfeStore(self.hostname, afe=self.mock_afe)
|
| /external/autotest/server/cros/network/ |
| chaos_clique_utils.py | 26 Locks the allocated machine if the machine was discovered via AFE
38 afe = frontend.AFE(debug=True,
40 available_pcaps = afe.get_hosts(label='packet_capture')
56 Locks the allocated machine if the machine was discovered via AFE
63 afe = frontend.AFE(debug=True,
66 afe, lock_manager, labels=['webdriver'])
|
| /external/autotest/server/cros/clique_lib/ |
| clique_dut_locker.py | 147 Locks the allocated machine if the machine was discovered via AFE
153 @return: hostname of the device locked in AFE.
163 afe = frontend.AFE(debug=True,
170 afe, self.lock_manager, labels=labels) + '.cros'
191 """Locks an DUT host in AFE.
218 @return a list of DUTObject, locked on AFE.
|
