/tools/test/connectivity/acts/framework/acts/libs/ |
D | version_selector.py | 22 def _fully_qualified_name(func): argument 30 return '%s:%s' % (func.__module__, func.__qualname__) 79 def decorator(func): argument 80 if isinstance(func, (staticmethod, classmethod)): 83 func_name = func.__name__ 103 version_selector.add_fn(func, min_version, max_version) 137 def __init__(self, level, func, direction): argument 147 self.func = func 164 return self.entry_list[0].func.__name__ 254 % (self.entry_list[0].func.__qualname__, [all …]
|
/tools/test/connectivity/acts/framework/tests/event/ |
D | event_subscription_test.py | 43 func = Mock() 44 subscription = EventSubscription(Mock(), func, 49 self.assertFalse(func.called) 53 func = Mock() 54 subscription = EventSubscription(Mock(), func, 58 self.assertTrue(func.called)
|
D | subscription_bundle_test.py | 35 func = object() 41 package.add(event, func, event_filter=event_filter, order=order) 46 self.assertEqual(subscription._func, func)
|
/tools/test/connectivity/acts/framework/acts/ |
D | test_decorators.py | 40 def test_info_decoractor(func): argument 41 return _TestInfoDecoratorFunc(func, predicate, keyed_info) 71 def __init__(self, func, predicate, keyed_info): argument 72 self.func = func 75 self.__name__ = func.__name__ 92 result = self.func(*args, **kwargs) 129 if hasattr(self.func, 'gather'): 130 extras = self.func.gather(*args, **kwargs)
|
D | utils.py | 352 def concurrent_exec(func, param_list): argument 371 future_to_params = {executor.submit(func, *p): p for p in param_list} 558 def decorator(func): argument 559 @functools.wraps(func) 565 return func(*args, **kwargs) 568 "seconds.").format(func.__name__, sec)) 1042 def wait_until(func, timeout_s, condition=True, sleep_s=1.0): argument 1064 if func() == condition: 1070 'attempted %d times.' % (str(func), timeout_s, count))
|
/tools/asuite/aidegen/lib/ |
D | common_util.py | 62 def time_logged(func=None, *, message='', maximum=1): argument 74 if func is None: 77 @wraps(func) 83 return func(*args, **kwargs) 87 func.__module__, func.__name__, timestamp)) 362 def back_to_cwd(func): argument 372 @wraps(func) 377 return func(*args, **kwargs) 503 def io_error_handle(func): argument 513 @wraps(func) [all …]
|
/tools/tradefederation/core/atest/ |
D | atest_decorator.py | 29 def fun_var_decorate(func): argument 31 setattr(func, varname, value) 32 return func
|
/tools/asuite/atest/ |
D | atest_decorator.py | 29 def fun_var_decorate(func): argument 31 setattr(func, varname, value) 32 return func
|
/tools/test/connectivity/acts/framework/acts/event/ |
D | subscription_handle.py | 22 def __init__(self, event_type, func, event_filter=None, order=0): argument 24 self._func = func 57 def _wrap_call(self, func): argument 60 return func(*args, **kwargs) 62 return func(self._owner, *args, **kwargs)
|
D | decorators.py | 27 def __init__(self, func): argument 28 super().__init__(event_type, func, 38 def __init__(self, func): argument 39 super().__init__(event_type, func,
|
D | event_bus.py | 40 def register(self, event_type, func, filter_fn=None, order=0): argument 61 subscription = EventSubscription(event_type, func, 184 def register(event_type, func, filter_fn=None, order=0): argument 204 return _event_bus.register(event_type, func, filter_fn=filter_fn, 274 def __init__(self, event_type, func, filter_fn=None, order=0): argument 276 self.func = func 282 self.registration_id = _event_bus.register(self.event_type, self.func,
|
D | event_subscription.py | 28 def __init__(self, event_type, func, event_filter=None, order=0): argument 30 self._func = func
|
D | subscription_bundle.py | 28 def add(self, event_type, func, event_filter=None, argument 38 subscription = EventSubscription(event_type, func,
|
/tools/test/connectivity/acts/tests/google/bt/ |
D | relay_tool.py | 86 func = getattr(relay_device, func_name) 87 signature = inspect.signature(func) 88 docstring = func.__doc__ 148 func = getattr(relay_device, args.command[0]) 150 ret = func(*args.command[1:]) 156 if len(e.args) == 1 and func.__name__ in e.args[0]:
|
/tools/asuite/atest/test_finders/ |
D | test_finder_base.py | 39 def wrapper(func): argument 42 func._registered = True 43 return func
|
/tools/tradefederation/core/atest/test_finders/ |
D | test_finder_base.py | 39 def wrapper(func): argument 42 func._registered = True 43 return func
|
/tools/asuite/atest/metrics/ |
D | metrics_utils.py | 31 def fun_var_decorate(func): argument 33 setattr(func, varname, value) 34 return func
|
/tools/tradefederation/core/atest/metrics/ |
D | metrics_utils.py | 31 def fun_var_decorate(func): argument 33 setattr(func, varname, value) 34 return func
|
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/ |
D | FtraceLine.kt | 57 func: DataSlice, funcDetails: BufferReader) { in set() 63 _function = func in set() 150 val func = sliceTo(ftraceLine.function) { skipUntil { it == ':'.toByte() } } in parseLine() constant 154 timestamp, func, _reader) in parseLine()
|
/tools/test/connectivity/acts/framework/tests/ |
D | acts_test_decorators_test.py | 56 def _verify_test_tracker_info(self, func): argument 58 test_decorators.test_tracker_info(uuid=TEST_TRACKER_UUID)(func)() 168 def _run_with_test_logic(self, func): argument 171 setattr(MockTest, MockTest.TEST_LOGIC_ATTR, func)
|
/tools/test/connectivity/acts/framework/tests/test_utils/power/tel/lab/ |
D | ensure_valid_calibration_table_test.py | 50 def _assert_no_exception(self, func, *args, **kwargs): argument 52 func(*args, **kwargs)
|
/tools/external_updater/ |
D | archive_utils.py | 89 for ext, func in ARCHIVE_TYPES.items(): 91 return func
|
D | external_updater.py | 240 check_parser.set_defaults(func=check) 261 update_parser.set_defaults(func=update) 270 args.func(args)
|
/tools/asuite/atest/test_runners/ |
D | test_runner_base.py | 91 def handle_subprocess(self, subproc, func): argument 100 func()
|
/tools/test/connectivity/acts/tests/google/tel/live/ |
D | TelLiveStressFdrTest.py | 83 func = getattr(self, method) 85 check_result = func() 103 func = getattr(self, method) 104 if not func(): 108 func = getattr(self, method) 110 func_result = func()
|