/external/autotest/site_utils/stable_images/ |
D | stable_version_unittest.py | 73 def _dispatch_command_success(self, afe, argv, name_called): argument 81 stable_version._dispatch_command(afe, arguments) 87 afe = object() 90 stable_version._dispatch_command(afe, arguments) 95 afe = object() 97 afe, argv, 'list_all_mappings') 98 called_mock.assert_called_once_with(afe, None) 103 afe = object() 105 afe, argv, 'list_all_mappings') 106 called_mock.assert_called_once_with(afe, argv[2]) [all …]
|
D | stable_version.py | 89 def __init__(self, afe, dry_run): argument 90 self._afe = afe 92 self._version_map = afe.get_stable_version_map(self.TYPE) 248 def _create_version_map_handler(image_type, afe, dry_run): argument 249 return _IMAGE_TYPE_HANDLERS[image_type](afe, dry_run) 252 def _requested_mapping_handlers(afe, image_type): argument 269 yield _create_version_map_handler(image_type, afe, True) 272 yield cls(afe, True) 275 def list_all_mappings(afe, image_type): argument 286 for handler in _requested_mapping_handlers(afe, image_type): [all …]
|
D | assign_stable_images.py | 74 def __init__(self, afe, dry_run): argument 82 image_types = [afe.CROS_IMAGE_TYPE, afe.FIRMWARE_IMAGE_TYPE] 84 image_type: afe.get_stable_version_map(image_type) 87 self._cros_map = self._version_maps[afe.CROS_IMAGE_TYPE] 341 afe = frontend_wrappers.RetryingAFE(server=arguments.web) 342 updater = _VersionUpdater(afe, dry_run=arguments.dry_run) 344 cros_versions = updater.select_version_map(afe.CROS_IMAGE_TYPE) 348 lab_inventory.get_managed_boards(afe))) 353 fw_versions = updater.select_version_map(afe.FIRMWARE_IMAGE_TYPE)
|
/external/autotest/site_utils/deployment/ |
D | install.py | 179 def _update_build(afe, report_log, arguments): argument 184 def _create_host(hostname, afe, afe_host): argument 198 'host_info_store': afe_store.AfeStore(hostname, afe), 245 def _update_host_attributes(afe, hostname, host_attrs): argument 255 afe.set_host_attribute(servo_constants.SERVO_HOST_ATTR, 258 afe.set_host_attribute(servo_constants.SERVO_PORT_ATTR, 262 afe.set_host_attribute(servo_constants.SERVO_SERIAL_ATTR, 287 def _wait_for_idle(afe, host_id): argument 297 afe_host = afe.get_hosts(id=host_id)[0] 305 def _ensure_host_idle(afe, afe_host): 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 …]
|
/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/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/ |
D | frontend.py | 29 from autotest_lib.frontend.afe import rpc_client_lib 209 def __init__(self, afe): argument 210 self._afe = afe 745 def __init__(self, afe, hash): argument 746 self.afe = afe 779 return self.afe.run('label_add_hosts', id=self.name, hosts=hosts) 785 return self.afe.run('label_remove_hosts', id=self.name, hosts=hosts) 800 self.afe.log('Adding hosts %s to ACL %s' % (hosts, self.name)) 801 return self.afe.run('acl_group_add_hosts', self.id, hosts) 805 self.afe.log('Removing hosts %s from ACL %s' % (hosts, self.name)) [all …]
|
D | site_utils.py | 139 def get_labels_from_afe(hostname, label_prefix, afe): argument 153 labels = afe.get_labels(name__startswith=label_prefix, 159 def get_label_from_afe(hostname, label_prefix, afe): argument 172 labels = get_labels_from_afe(hostname, label_prefix, afe) 177 def get_board_from_afe(hostname, afe): argument 189 return get_label_from_afe(hostname, constants.BOARD_PREFIX, afe) 192 def get_build_from_afe(hostname, afe): argument 204 build = get_label_from_afe(hostname, prefix + ':', afe) 358 def lock_host_with_labels(afe, lock_manager, labels): argument 375 potential_hosts = afe.get_hosts(multiple_labels=labels) [all …]
|
/external/autotest/server/cros/network/ |
D | rf_switch_utils.py | 23 afe = frontend.AFE( 26 rf_switch_hosts = afe.get_hosts(label=RF_SWITCH_LABEL, locked=False) 30 if afe.lock_host(rf_switch.hostname, LOCK_REASON): 45 afe = frontend.AFE( 47 afe.unlock_hosts([rf_switch_host.hostname]) 48 rf_switch = afe.get_hosts(hostnames=(rf_switch_host.hostname,))
|
/external/autotest/site_utils/ |
D | add_detected_host_labels.py | 44 def add_missing_labels(afe, hostname): argument 71 afe_host = afe.get_hosts(hostname=hostname)[0] 73 label_matches = afe.get_labels(name__in=labels) 86 afe_labels_to_delete = afe.get_labels(name__in=labels_to_delete) 129 afe = frontend.AFE() 134 hostnames = afe.get_hostnames() 136 lambda x: add_missing_labels(afe, x),
|
D | dut_status.py | 264 def _get_host_histories(afe, arguments): argument 287 afe, hostname, arguments.since, arguments.until) 299 def _validate_host_list(afe, arguments): argument 331 afe, arguments.since, arguments.until, labels.getlabels()) 333 histories = _get_host_histories(afe, arguments) 362 def _validate_command(afe, arguments): argument 384 return _validate_host_list(afe, arguments) 462 afe = frontend.AFE(server=arguments.web) 463 history_list = _validate_command(afe, arguments)
|
D | test_runner_utils.py | 182 def fetch_local_suite(autotest_path, suite_predicate, afe, test_arg, remote, argument 220 devserver, fs_getter, afe=afe, 240 afe.get_labels(host__hostname=remote)] 399 from autotest_lib.frontend.afe import direct_afe 490 def _auto_detect_labels(afe, remote): argument 506 new_label = afe.create_label(label) 508 hosts = afe.get_hosts(hostname=remote) 517 def perform_local_run(afe, argument 576 build_label = afe.create_label(cros_version_label) 577 board_label = afe.create_label(constants.BOARD_PREFIX + board) [all …]
|
D | balance_pools.py | 190 def __init__(self, afe, pool, labels, start_time, end_time): argument 199 self.total_hosts = self._get_hosts(afe, start_time, end_time) 202 def _get_hosts(self, afe, start_time, end_time): argument 204 afe, start_time, end_time, self.labels.getlabels()) 374 def _balance_model(arguments, afe, pool, labels, start_time, end_time): argument 388 spare_pool = _DUTPool(afe, arguments.spare, labels, start_time, end_time) 389 main_pool = _DUTPool(afe, pool, labels, start_time, end_time) 576 def infer_balancer_targets(afe, arguments, pools): argument 591 inventory = lab_inventory.get_inventory(afe) 627 afe = frontend_wrappers.RetryingAFE(server=arguments.web) [all …]
|
D | dump_suite_report.py | 48 afe = frontend_wrappers.RetryingAFE(timeout_min=5, delay_sec=10, 49 server=options.afe) 63 suite_job_id, afe=afe, tko=tko,
|
/external/autotest/server/lib/ |
D | status_history.py | 45 from autotest_lib.frontend.afe import models as afe_models 231 def get_tasks(cls, afe, host_id, start_time, end_time): argument 249 tasks = afe.get_host_special_tasks( 258 def get_status_task(cls, afe, host_id, end_time): argument 274 task = afe.get_host_status_task(host_id, query_end) 340 def get_hqes(cls, afe, host_id, start_time, end_time): argument 358 hqelist = afe.get_host_queue_entries_by_insert_time( 441 def get_host_history(cls, afe, hostname, start_time, end_time): argument 457 afehost = afe.get_hosts(hostname=hostname)[0] 458 return cls(afe, afehost, start_time, end_time) [all …]
|
D | suite_report.py | 171 def generate_suite_report(suite_job_id, afe=None, tko=None, argument 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)) 231 histories = [HostJobHistory.get_host_history(afe, hostname,
|
/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;
|
D | ClassFactory.java | 1 package autotest.afe; 3 import autotest.afe.create.CreateJobViewPresenter.JobCreateListener; 4 import autotest.afe.create.CreateJobViewTab;
|
/external/autotest/server/hosts/ |
D | moblab_host.py | 90 self.afe = frontend_wrappers.RetryingAFE(timeout_min=timeout_min, 180 self.afe.set_timeout(self.timeout_min) 202 existing_hosts = [host.hostname for host in self.afe.get_hosts()] 297 self.afe.get_hosts() 313 hosts = self.afe.reverify_hosts() 320 while (self.afe.get_special_tasks(is_complete=False) and 324 if not self.afe.get_hosts(status='Ready'): 325 for host in self.afe.get_hosts():
|
/external/autotest/server/cros/dynamic_suite/ |
D | suite_unittest.py | 71 self.afe = self.mox.CreateMock(frontend.AFE) 273 afe=self.afe, tko=self.tko) 335 job_mock = self.afe.create_job( 383 afe=self.afe, tko=self.tko, 414 afe=self.afe, tko=self.tko) 435 afe=self.afe, tko=self.tko, 456 afe=self.afe, tko=self.tko) 490 afe=self.afe, tko=self.tko, 513 afe=self.afe, tko=self.tko, 540 afe=self.afe, tko=self.tko) [all …]
|
/external/autotest/server/site_tests/moblab_Setup/ |
D | moblab_Setup.py | 36 afe = frontend.AFE(server='localhost', user='moblab') 39 live_statuses = afe.host_statuses(live=True) 42 for host in afe.get_hosts():
|
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
D | JSR166TestCase.java | 302 AssertionFailedError afe = new AssertionFailedError(t.toString()); in tearDown() local 303 afe.initCause(t); in tearDown() 304 throw afe; in tearDown() 424 AssertionFailedError afe = new AssertionFailedError("unexpected exception: " + t); in threadUnexpectedException() local 425 afe.initCause(t); in threadUnexpectedException() 426 throw afe; in threadUnexpectedException() 643 AssertionFailedError afe = new AssertionFailedError("Unexpected InterruptedException"); in sleep() 644 afe.initCause(ie); in sleep() 645 throw afe; in sleep() 1125 AssertionFailedError afe = new AssertionFailedError("Unexpected exception: " + e); [all …]
|