| /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/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)
127 if hasattr(self.func, 'gather'):
128 extras = self.func.gather(*args, **kwargs)
|
| D | utils.py | 332 def concurrent_exec(func, param_list): argument
351 future_to_params = {executor.submit(func, *p): p for p in param_list}
538 def decorator(func): argument
539 @functools.wraps(func)
545 return func(*args, **kwargs)
548 "seconds.").format(func.__name__, sec))
996 def wait_until(func, timeout_s, condition=True, sleep_s=1.0): argument
1018 if func() == condition:
1024 'attempted %d times.' % (str(func), timeout_s, count))
|
| D | base_test.py | 570 def _exec_procedure_func(self, func, tr_record): argument
585 func(tr_record)
590 func.__name__, self.current_test_name)
591 tr_record.add_error(func.__name__, e)
692 def get_func_with_retry(self, func, attempts=2): argument
712 return func(*args, **kwargs)
793 def _exec_func(self, func, *args): argument
808 return func(*args)
813 func.__name__, self.TAG)
|
| /tools/test/connectivity/acts/framework/acts/event/ |
| 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 | 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_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/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/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/aidegen/lib/ |
| D | common_util.py | 57 def time_logged(func=None, *, message='', maximum=1): argument
69 if func is None:
72 @wraps(func)
78 return func(*args, **kwargs)
82 func.__module__, func.__name__, timestamp))
|
| /tools/test/connectivity/acts/framework/tests/ |
| D | acts_test_decorators_test.py | 54 def _verify_test_tracker_info(self, func): argument
56 test_decorators.test_tracker_info(uuid=TEST_TRACKER_UUID)(func)()
107 def _run_with_test_logic(self, func): argument
110 setattr(MockTest, MockTest.TEST_LOGIC_ATTR, 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/tradefederation/core/atest/test_finders/ |
| D | test_finder_base.py | 39 def wrapper(func): argument
42 func._registered = True
43 return func
|
| /tools/acloud/internal/lib/ |
| D | utils.py | 171 def _Wrapper(func): argument
173 return Retry(retry_checker, max_retries, func, sleep_multiplier,
243 def PollAndWait(func, expected_return, timeout_exception, timeout_secs, argument
266 return_value = func(*args, **kwargs)
737 def __call__(self, func): argument
754 result = func(*args, **kargs)
1169 def _Wrapper(func): argument
1178 result = func(*args, **kwargs)
|
| /tools/tradefederation/core/atest/metrics/ |
| D | metrics_utils.py | 29 def fun_var_decorate(func): argument
31 setattr(func, varname, value)
32 return func
|
| /tools/repohooks/rh/ |
| D | hooks_unittest.py | 247 def _test_commit_messages(self, func, accept, msgs, files=None): argument
261 ret = func(self.project, 'commit', desc, diff, options=self.options)
269 def _test_file_filter(self, mock_check, func, files): argument
278 ret = func(self.project, 'commit', 'desc', (), options=self.options)
284 ret = func(self.project, 'commit', 'desc', diff, options=self.options)
|
| D | shell_unittest.py | 43 def _assertEqual(self, func, test_input, test_output, result): argument
47 (func, test_input, test_output, result, diff))
|
| /tools/external_updater/ |
| D | external_updater.py | 236 check_parser.set_defaults(func=check)
257 update_parser.set_defaults(func=update)
266 args.func(args)
|
| D | archive_utils.py | 89 for ext, func in ARCHIVE_TYPES.items():
91 return func
|
| /tools/test/connectivity/acts/framework/acts/libs/metrics/ |
| D | bindings.py | 42 def _inner(func): argument
43 return Binding(inner=func, arg_modifier=_arg_modifier, before=_before,
|
| /tools/test/connectivity/acts/tests/google/tel/live/ |
| D | TelLiveRebootStressTest.py | 106 func = getattr(self, method)
108 check_result = func()
126 func = getattr(self, method)
127 if not func():
131 func = getattr(self, method)
133 func_result = func()
|
| /tools/tradefederation/core/atest/test_runners/ |
| D | test_runner_base.py | 93 def handle_subprocess(self, subproc, func): argument
102 func()
|