/external/autotest/site_utils/deployment/ |
D | install.py | 165 def _update_build(afe, report_log, arguments): argument 194 cros_version_map = afe.get_stable_version_map(afe.CROS_IMAGE_TYPE) 195 fw_version_map = afe.get_stable_version_map(afe.FIRMWARE_IMAGE_TYPE) 246 def _create_host(hostname, afe, afe_host): argument 256 'host_info_store': afe_store.AfeStore(hostname, afe), 301 def _update_host_attributes(afe, hostname, host_attr_dict): argument 325 afe.set_host_attribute(servo_host.SERVO_HOST_ATTR, 328 afe.set_host_attribute(servo_host.SERVO_PORT_ATTR, 332 afe.set_host_attribute(servo_host.SERVO_SERIAL_ATTR, 337 def _get_afe_host(afe, hostname, arguments, host_attr_dict): argument [all …]
|
/external/autotest/contrib/ |
D | manage_powerunit_info.py | 55 def add_powerunit_info_to_host(afe, device, keyvals): argument 64 if not afe.get_hosts(hostname=device): 70 afe.set_host_attribute(key, val, hostname=device) 73 def add_from_csv(afe, csv_file): argument 91 add_powerunit_info_to_host(afe, device, keyvals) 94 def dump_to_csv(afe, csv_file): argument 103 hosts = afe.get_hosts() 112 def list_powerunit_info(afe, devices): argument 118 hosts = afe.get_hosts(hostname__in = devices) 173 afe = frontend_wrappers.RetryingAFE(timeout_min=5, delay_sec=10, variable [all …]
|
D | find_suite_tasks.py | 37 def GetSuiteHQEs(suite_job_id, look_past_seconds, afe=None, tko=None): argument 50 if afe is None: 51 afe = frontend.AFE() 79 child_jobs = afe.get_jobs(parent_job_id=suite_job_id) 81 hqes = afe.get_host_queue_entries(job_id__in=list(child_job_ids)) 85 history = HostJobHistory.get_host_history(afe, hostname, 108 name_filter=None, status_filter=None, afe=None, tko=None): argument 125 afe=afe, tko=tko) 165 afe = None 166 if options.afe: [all …]
|
/external/autotest/frontend/afe/ |
D | direct_afe_unittest.py | 7 from autotest_lib.frontend.afe import direct_afe 12 afe = direct_afe.directAFE() 14 jobs = afe.get_jobs() 17 hosts = afe.get_hosts() 20 afe.create_host('a_host') 21 hosts = afe.get_hosts() 24 afe.create_job('job_name', hosts=['a_host']) 25 jobs = afe.get_jobs()
|
/external/autotest/server/ |
D | frontend.py | 24 from autotest_lib.frontend.afe import rpc_client_lib 214 def __init__(self, afe, android): argument 215 self._afe = afe 304 def __init__(self, afe): argument 305 super(_CrosVersionMap, self).__init__(afe, False) 345 def __init__(self, afe): argument 346 super(_AndroidVersionMap, self).__init__(afe, True) 371 def __init__(self, afe): argument 372 super(_SuffixHackVersionMap, self).__init__(afe, False) 769 def __init__(self, afe, hash): argument [all …]
|
D | site_utils.py | 130 def get_labels_from_afe(hostname, label_prefix, afe): argument 144 labels = afe.get_labels(name__startswith=label_prefix, 150 def get_label_from_afe(hostname, label_prefix, afe): argument 163 labels = get_labels_from_afe(hostname, label_prefix, afe) 168 def get_board_from_afe(hostname, afe): argument 180 return get_label_from_afe(hostname, constants.BOARD_PREFIX, afe) 183 def get_build_from_afe(hostname, afe): argument 196 build = get_label_from_afe(hostname, prefix + ':', afe) 343 def lock_host_with_labels(afe, lock_manager, labels): argument 360 potential_hosts = afe.get_hosts(multiple_labels=labels) [all …]
|
/external/autotest/site_utils/admin/scripts/ |
D | cli2hbs.sh | 29 mkdir -p ${TARGET_DIR}/frontend/afe 31 touch ${TARGET_DIR}/frontend/afe/__init__.py 34 cp -fpruv ${AUTOTEST_DIR}/frontend/afe/json_rpc \ 35 ${TARGET_DIR}/frontend/afe 36 cp -uv ${AUTOTEST_DIR}/frontend/afe/rpc_client_lib.py \ 37 ${TARGET_DIR}/frontend/afe 39 ${AUTOTEST_TOOLS_DIR}/autotest/syncfiles/frontend/afe/site_rpc_client_lib.py \ 40 ${TARGET_DIR}/frontend/afe
|
/external/autotest/server/cros/network/ |
D | rf_switch_utils.py | 22 afe = frontend.AFE( 25 rf_switch_hosts = afe.get_hosts(label=RF_SWITCH_LABEL, locked=False) 29 if afe.lock_host(rf_switch.hostname, LOCK_REASON): 44 afe = frontend.AFE( 46 afe.unlock_hosts([rf_switch_host.hostname]) 47 rf_switch = afe.get_hosts(hostnames=[rf_switch_host.hostname])
|
/external/autotest/site_utils/chromeos_proxy/ |
D | swarming_bot_manager.py | 77 def is_server_in_prod(server_name, afe): argument 87 afe = frontend_wrappers.RetryingAFE(timeout_min=5, delay_sec=10, 88 server=afe) 91 if afe.run('get_servers', hostname=server_name, 96 logging.warning('RPC get_servers failed on afe %s: %s', afe, str(e)) 104 def tick(afe, bot_manager): argument 110 if is_server_in_prod(socket.getfqdn(), afe): 147 tick(args.afe, bot_manager)
|
/external/autotest/server/lib/ |
D | status_history.py | 45 from autotest_lib.frontend.afe import models as afe_models 238 def get_tasks(cls, afe, host_id, start_time, end_time): argument 256 tasks = afe.get_host_special_tasks( 261 return [cls(afe.server, t) for t in tasks] 265 def get_status_task(cls, afe, host_id, end_time): argument 281 task = afe.get_host_status_task(host_id, query_end) 282 return cls(afe.server, task) if task else None 358 def get_hqes(cls, afe, host_id, start_time, end_time): argument 376 hqelist = afe.get_host_queue_entries_by_insert_time( 383 return [cls(afe.server, hqe) for hqe in hqelist] [all …]
|
/external/autotest/server/cros/ |
D | host_lock_manager_unittest.py | 74 self.afe = self.mox.CreateMock(frontend.AFE) 75 self.manager = host_lock_manager.HostLockManager(self.afe) 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) 136 manager = self.MockHostLockManager(self.afe) 162 manager = self.MockHostLockManager(self.afe) [all …]
|
/external/autotest/site_utils/suite_scheduler/ |
D | 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([]) 55 self.afe.get_labels(name__startswith=self.prefix).AndRaise(Exception())
|
D | deduping_scheduler_unittest.py | 45 self.afe = self.mox.CreateMock(frontend.AFE) 46 self.scheduler = deduping_scheduler.DedupingScheduler(afe=self.afe) 72 self.afe.get_jobs(name__istartswith=self._BUILD, 77 self.afe.run('create_suite_job', 110 self.afe.get_jobs( 142 self.afe.run('create_suite_job', 176 self.afe.get_jobs( 198 self.afe.get_jobs(name__istartswith=self._BUILD, 203 self.afe.run('create_suite_job', 236 self.afe.get_jobs(name__istartswith=self._BUILD, [all …]
|
/external/autotest/site_utils/ |
D | add_detected_host_labels.py | 40 def add_missing_labels(afe, hostname): argument 67 afe_host = afe.get_hosts(hostname=hostname)[0] 69 label_matches = afe.get_labels(name__in=labels) 82 afe_labels_to_delete = afe.get_labels(name__in=labels_to_delete) 125 afe = frontend.AFE() 130 hostnames = afe.get_hostnames() 132 lambda x: add_missing_labels(afe, x),
|
D | test_runner_utils.py | 114 def fetch_local_suite(autotest_path, suite_predicate, afe, test_arg, remote, argument 150 devserver, fs_getter, afe=afe, 167 afe.get_labels(host__hostname=remote)] 321 from autotest_lib.frontend.afe import direct_afe 412 def _auto_detect_labels(afe, remote): argument 427 new_label = afe.create_label(label) 429 hosts = afe.get_hosts(hostname=remote) 437 def perform_local_run(afe, autotest_path, tests, remote, fast_mode, argument 483 build_label = afe.create_label(cros_version_label) 484 board_label = afe.create_label(constants.BOARD_PREFIX + board) [all …]
|
D | dut_status.py | 258 def _get_host_histories(afe, arguments): argument 281 afe, hostname, arguments.since, arguments.until) 293 def _validate_host_list(afe, arguments): argument 320 afe, arguments.since, arguments.until, 323 histories = _get_host_histories(afe, arguments) 352 def _validate_command(afe, arguments): argument 374 return _validate_host_list(afe, arguments) 450 afe = frontend.AFE(server=arguments.web) 451 history_list = _validate_command(afe, arguments)
|
/external/autotest/frontend/client/src/autotest/afe/create/ |
D | CreateJobViewDisplay.java | 1 package autotest.afe.create; 3 import autotest.afe.CheckBoxPanel; 4 import autotest.afe.CheckBoxPanelDisplay; 5 import autotest.afe.ControlTypeSelect; 6 import autotest.afe.ControlTypeSelectDisplay; 7 import autotest.afe.HostSelector; 8 import autotest.afe.HostSelectorDisplay; 9 import autotest.afe.IButton; 10 import autotest.afe.IButton.ButtonImpl; 11 import autotest.afe.ICheckBox; [all …]
|
/external/autotest/frontend/client/src/autotest/afe/ |
D | TestSelectorDisplay.java | 1 package autotest.afe; 3 import autotest.afe.ITextBox; 4 import autotest.afe.ITextBox.TextBoxImpl; 5 import autotest.afe.TestSelector.IDataTable; 6 import autotest.afe.TestSelector.IDataTable.DataTableImpl; 7 import autotest.afe.TestSelector.ISelectionManager; 8 import autotest.afe.TestSelector.ISelectionManager.SelectionManagerImpl;
|
D | AfeClient.java | 1 package autotest.afe; 3 import autotest.afe.HostDetailView.HostDetailListener; 4 import autotest.afe.HostListView.HostListListener; 5 import autotest.afe.JobDetailView.JobDetailListener; 6 import autotest.afe.JobListView.JobSelectListener; 7 import autotest.afe.create.CreateJobViewPresenter.JobCreateListener; 8 import autotest.afe.create.CreateJobViewTab;
|
/external/autotest/server/cros/dynamic_suite/ |
D | job_status.py | 64 def _abort_jobs_if_timedout(afe, jobs, start_time, timeout_mins): argument 83 afe.run('abort_host_queue_entries', job=job.id) 121 def __init__(self, afe, tko): argument 127 self._afe = afe 171 def _yield_job_results(afe, tko, job): argument 183 entries = afe.run('get_host_queue_entries', job=job.id) 228 def wait_for_child_results(afe, tko, parent_job_id): argument 241 waiter = _JobResultWaiter(afe, tko) 242 waiter.add_jobs(afe.get_jobs(parent_job_id=parent_job_id)) 251 def wait_for_results(afe, tko, jobs): argument [all …]
|
D | 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 results = [result for result in job_status.wait_for_results(self.afe, 133 self.afe.get_jobs(parent_job_id=parent_job_id).AndReturn(jobs[:6]) 143 self.afe.get_jobs(id__in=list(job_id_set), 152 self.afe, 173 results = list(job_status._yield_job_results(self.afe, self.tko, job))
|
/external/autotest/site_utils/stable_images/ |
D | assign_stable_images.py | 200 def __init__(self, afe): argument 201 image_types = [afe.CROS_IMAGE_TYPE, afe.FIRMWARE_IMAGE_TYPE] 203 image_type: afe.get_stable_version_map(image_type) 206 self._cros_map = self._version_maps[afe.CROS_IMAGE_TYPE] 594 afe = frontend_wrappers.RetryingAFE(server=None) 595 updater = arguments.updater_mode(afe) 598 lab_inventory.get_managed_boards(afe)) 600 afe_versions = updater.select_version_map(afe.CROS_IMAGE_TYPE) 610 afe.FIRMWARE_IMAGE_TYPE)
|
/external/autotest/apache/conf/ |
D | django-directives | 28 RewriteRule ^/afe/server/admin/.* - [R=404] 29 RewriteRule ^/afe/server/admin - [R=404] 37 … RewriteRule ^/(afe|new_tko)/server(.*) /usr/local/autotest/frontend/frontend.wsgi [H=wsgi-script] 40 …RewriteRule ^/(afe|new_tko)/server(.*) /usr/lib/python2.7/site-packages/autotest/frontend/frontend… 43 …RewriteRule ^/(afe|new_tko)/server(.*) /usr/lib/python2.6/site-packages/autotest/frontend/frontend… 46 …RewriteRule ^/(afe|new_tko)/server(.*) /usr/lib/python2.5/site-packages/autotest/frontend/frontend… 49 …RewriteRule ^/(afe|new_tko)/server(.*) /usr/lib/python2.4/site-packages/autotest/frontend/frontend… 51 <LocationMatch "/(afe|new_tko)/server(.*)"> 75 <Location ~ "/(afe|new_tko)/server">
|
/external/autotest/server/hosts/ |
D | servo_host.py | 332 def get_attached_duts(self, afe): argument 339 return afe.get_hosts_by_attribute( 352 def _choose_dut_for_synchronized_reboot(self, dut_list, afe): argument 366 afe_hosts = afe.get_hosts(dut_list) 376 def _sync_job_scheduled_for_duts(self, dut_list, afe): argument 387 afe_hosts = afe.get_hosts(dut_list) 389 hqes = afe.get_host_queue_entries(host=afe_host.id, complete=0) 391 job = afe.get_jobs(id=hqe.job.id) 398 def schedule_synchronized_reboot(self, dut_list, afe, force_reboot=False): argument 413 if self._sync_job_scheduled_for_duts(dut_list, afe): [all …]
|
D | moblab_host.py | 65 self.afe = frontend_wrappers.RetryingAFE(timeout_min=timeout_min, 178 self.afe.set_timeout(self.timeout_min) 219 existing_hosts = [host.hostname for host in self.afe.get_hosts()] 294 self.afe.get_hosts() 318 hosts = self.afe.reverify_hosts() 322 while (self.afe.get_special_tasks(is_complete=False) and 326 if not self.afe.get_hosts(status='Ready'): 327 for host in self.afe.get_hosts():
|