Home
last modified time | relevance | path

Searched refs:afe (Results 1 – 25 of 166) sorted by relevance

1234567

/external/autotest/site_utils/stable_images/
Dstable_version_unittest.py73 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 …]
Dstable_version.py89 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 …]
Dassign_stable_images.py74 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/
Dinstall.py179 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/
Dmanage_powerunit_info.py55 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/
Ddirect_afe_unittest.py7 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/
Dcli2hbs.sh29 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/
Dfrontend.py29 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 …]
Dsite_utils.py139 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/
Drf_switch_utils.py23 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/
Dadd_detected_host_labels.py44 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),
Ddut_status.py264 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)
Dtest_runner_utils.py182 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 …]
Dbalance_pools.py190 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 …]
Ddump_suite_report.py48 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/
Dstatus_history.py45 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 …]
Dsuite_report.py171 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/
DCreateJobViewDisplay.java1 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/
DTestSelectorDisplay.java1 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;
DAfeClient.java1 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;
DClassFactory.java1 package autotest.afe;
3 import autotest.afe.create.CreateJobViewPresenter.JobCreateListener;
4 import autotest.afe.create.CreateJobViewTab;
/external/autotest/server/hosts/
Dmoblab_host.py90 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/
Dsuite_unittest.py71 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/
Dmoblab_Setup.py36 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/
DJSR166TestCase.java302 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 …]

1234567