| /external/autotest/server/cros/dynamic_suite/ |
| frontend_wrappers.py | 14 from autotest_lib.frontend.afe.json_rpc import proxy
51 class RetryingAFE(frontend.AFE):
52 """Wrapper around frontend.AFE that retries all RPCs.
68 """Set timeout minutes for the AFE server.
70 @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)
49 self.afe.run('get_host_queue_entries',
86 self.afe.get_jobs(id__in=list(job_id_set),
94 waiter = job_status.JobResultWaiter(self.afe, self.tko)
115 results = list(job_status._yield_job_results(self.afe, self.tko, job))
|
| suite_unittest.py | 64 self.afe = self.mox.CreateMock(frontend.AFE)
266 afe=self.afe, tko=self.tko)
328 job_mock = self.afe.create_job(
365 """Should schedule stable and experimental tests with the AFE."""
376 afe=self.afe, tko=self.tko,
391 """Should schedule tests with the AFE."""
407 afe=self.afe, tko=self.tko
[all...] |
| /external/autotest/site_utils/ |
| deploy_server.py | 33 def discover_servers(afe):
40 @param afe: Server to contact with RPC requests.
51 rpc = frontend.AFE(server=afe)
70 ' deploy_server.py -x --afe cautotest\n'
79 parser.add_argument('--afe',
80 help='The AFE server used to get servers from server_db,'
172 if not options.afe:
173 print('No servers or afe specified. Aborting')
175 print('Retrieving servers from %s..' % options.afe)
[all...] |
| sync_cloudsql_access.py | 38 'afe',
68 def update_allowed_networks(project, instance, afe=None, extra_servers=None,
74 @param afe: Server of the frontend RPC, default to None to use the server
81 rpc = frontend.AFE(server=afe)
142 parser.add_argument('--afe', type=str, dest='afe',
154 update_allowed_networks(options.project, options.instance, options.afe,
|
| dut_status.py | 259 def _get_host_histories(afe, arguments):
270 @param afe Autotest frontend
282 afe, hostname, arguments.since, arguments.until)
294 def _validate_host_list(afe, arguments):
308 @param afe Autotest frontend
326 afe, arguments.since, arguments.until, labels.getlabels())
328 histories = _get_host_histories(afe, arguments)
357 def _validate_command(afe, arguments):
370 @param afe Autotest frontend
379 return _validate_host_list(afe, arguments
[all...] |
| label_cleaner.py | 160 server = frontend.AFE(server=GLOBAL_AFE).run(
168 """Cleans unused labels from AFE database"""
221 """Cleans unused labels from AFE database"""
|
| deploy_server_local.py | 36 # frontend repo, no need to update afe.
37 COMMANDS_TO_REPOS_DICT = {'afe': 'frontend/client/',
44 AFE = frontend_wrappers.RetryingAFE(
449 help='Force to run the update commands for afe, tko '
|
| rpc_flight_recorder.py | 6 """Standalone service to monitor AFE servers and report to ts_mon"""
15 from autotest_lib.frontend.afe.json_rpc import proxy
116 """Monitors a list of AFE"""
119 @param servers: list of afe services to monitor
205 """Object that runs rpc calls against the given afe frontend"""
212 self._afe = frontend.AFE(server=self._hostname)
263 parser.add_argument('-a', '--afe', action='append', default=[],
267 help='Frequency to poll AFE servers')
284 if not options.afe:
285 options.afe = [global_config.global_config.get_config_value
[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)
132 self.mock_afe = mock.create_autospec(frontend.AFE, instance=True)
134 self.hostname, afe=self.mock_afe)
|
| /external/autotest/server/cros/network/ |
| chaos_clique_utils.py | 27 Locks the allocated machine if the machine was discovered via AFE
39 afe = frontend.AFE(debug=True,
41 available_pcaps = afe.get_hosts(label='packet_capture')
57 Locks the allocated machine if the machine was discovered via AFE
64 afe = frontend.AFE(debug=True,
67 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.
|
| /external/autotest/server/cros/ |
| sonic_client_utils.py | 152 afe = frontend.AFE(debug=True)
157 lambda: site_utils.lock_host_with_labels(afe, lock_manager, labels),
|
| host_lock_manager_unittest.py | 74 self.afe = self.mox.CreateMock(frontend.AFE)
75 self.manager = host_lock_manager.HostLockManager(self.afe)
79 """Test that host unknown to AFE is skipped."""
80 self.afe.get_hosts(hostname=self.HOST1).AndReturn(None)
89 self.afe.get_hosts(hostname=self.HOST1).AndReturn(host_info)
98 self.afe.get_hosts(hostname=self.HOST1).AndReturn(host_info)
107 self.afe.get_hosts(hostname=self.HOST1).AndReturn(host_info)
117 self.afe.get_hosts(hostname=self.HOST1).AndReturn(host_info)
127 manager = self.MockHostLockManager(self.afe)
[all...] |
| /external/autotest/server/lib/ |
| suite_report.py | 171 def generate_suite_report(suite_job_id, afe=None, tko=None,
175 @param suite_job_id: The AFE id of the suite job.
176 @param afe: AFE database handle.
183 if afe is None:
184 afe = frontend.AFE()
189 suite_job = afe.get_jobs(id=suite_job_id)[0]
196 child_jobs = afe.get_jobs(parent_job_id=suite_job_id)
211 hqes = afe.get_host_queue_entries(job_id__in=list(child_job_ids)
[all...] |
| /external/autotest/contrib/ |
| log_distiller.py | 6 The job_id needs to be in the afe database.
355 'The job_id needs to be in the afe database.')
359 rpc = frontend.AFE()
|
| /external/autotest/site_utils/rpm_control_system/ |
| frontend_server.py | 77 so that we don't hit AFE too often. The elements in
80 @var _afe: AFE instance to talk to autotest. Used to retrieve rpm hostname.
97 self._afe = frontend.AFE()
264 from afe. A local LRU cache is used avoid hitting afe too often.
325 from afe. A local LRU cache is used avoid hitting afe too often.
343 'from AFE for %s, no host found.' % device_hostname)
|
| /external/autotest/site_utils/deployment/ |
| install.py | 17 * The DUTs are not necessarily in the AFE database. DUTs that
34 * If the DUT isn't in the AFE database, add it.
108 """Exception when there is no servo port stored in the AFE."""
173 def _update_build(afe, report_log, arguments):
180 * The stable test version currently in the AFE database.
196 @param afe AFE object for RPC calls.
202 # Gather the current AFE and Omaha version settings, and report them
204 cros_version_map = afe.get_stable_version_map(afe.CROS_IMAGE_TYPE
[all...] |
| /external/autotest/frontend/afe/ |
| rpc_interface.py | 54 from autotest_lib.frontend.afe import control_file as control_file_lib
55 from autotest_lib.frontend.afe import model_attributes
56 from autotest_lib.frontend.afe import model_logic
57 from autotest_lib.frontend.afe import models
58 from autotest_lib.frontend.afe import rpc_utils
[all...] |
| rpc_interface_unittest.py | 16 from autotest_lib.frontend.afe import frontend_test_utils
17 from autotest_lib.frontend.afe import model_logic
18 from autotest_lib.frontend.afe import models
19 from autotest_lib.frontend.afe import rpc_interface
20 from autotest_lib.frontend.afe import rpc_utils
[all...] |
| /external/autotest/server/ |
| autoserv | 277 afe = frontend.AFE()
278 board = server_utils.get_board_from_afe(machine, afe)
279 hosts = afe.get_hosts(hostname=machine)
288 logging.error('Failed to get board name from AFE. Start servod is '
[all...] |
| autoserv.py | 277 afe = frontend.AFE()
278 board = server_utils.get_board_from_afe(machine, afe)
279 hosts = afe.get_hosts(hostname=machine)
288 logging.error('Failed to get board name from AFE. Start servod is '
[all...] |
| frontend.py | 12 http://www.chromium.org/chromium-os/testing/afe-rpc-infrastructure
24 from autotest_lib.frontend.afe import rpc_client_lib
54 if key == 'afe' or key == 'hash':
63 Inherited for both TKO and AFE uses.
65 All the constructors go in the afe / tko class.
102 Make a RPC call to the AFE server
143 @param job_id: The afe job id to look up.
197 @property _afe AFE object through which to make the actual RPC
203 def __init__(self, afe):
204 self._afe = afe
[all...] |
