| /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 | 48 def test_info_decorator(func): argument
49 return _TestInfoDecoratorFunc(func, predicate, keyed_info)
86 def decorator(func): argument
87 if not func.__name__.startswith('test_'):
96 func(self, i + 1)
113 i, func.__name__)))
147 def test_tracker_info_decorator(func): argument
150 return _TestTrackerInfoDecoratorFunc(func, predicate, keyed_info)
158 def __init__(self, func, predicate, keyed_info): argument
159 self.func = func
[all …]
|
| D | base_test.py | 481 def _exec_procedure_func(self, func, tr_record): argument
496 func(tr_record)
501 func.__name__, self.current_test_name)
502 tr_record.add_error(func.__name__, e)
598 def get_func_with_retry(self, func, attempts=2): argument
621 return func(*args, **kwargs)
706 def _exec_func(self, func, *args): argument
721 return func(*args)
726 func.__name__, self.TAG)
|
| D | utils.py | 355 def concurrent_exec(func, param_list): argument
374 future_to_params = {executor.submit(func, *p): p for p in param_list}
561 def decorator(func): argument
562 @functools.wraps(func)
568 return func(*args, **kwargs)
571 "seconds.").format(func.__name__, sec))
1045 def wait_until(func, timeout_s, condition=True, sleep_s=1.0): argument
1067 if func() == condition:
1073 'attempted %d times.' % (str(func), timeout_s, count))
|
| /tools/asuite/aidegen/lib/ |
| D | common_util.py | 68 def time_logged(func=None, *, message='', maximum=1): argument
80 if func is None:
83 @wraps(func)
89 return func(*args, **kwargs)
93 func.__module__, func.__name__, timestamp))
368 def back_to_cwd(func): argument
378 @wraps(func)
383 return func(*args, **kwargs)
509 def io_error_handle(func): argument
519 @wraps(func)
[all …]
|
| /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,
279 def __init__(self, event_type, func, filter_fn=None, order=0): argument
281 self.func = func
287 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
|
| /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/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/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/asuite/atest/ |
| D | atest_decorator.py | 29 def fun_var_decorate(func): argument
31 setattr(func, varname, value)
32 return func
|
| /tools/asuite/atest-py2/ |
| D | atest_decorator.py | 29 def fun_var_decorate(func): argument
31 setattr(func, varname, value)
32 return func
|
| /tools/test/connectivity/acts_tests/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()
|
| /tools/asuite/atest/test_finders/ |
| D | test_finder_base.py | 39 def wrapper(func): argument
42 func._registered = True
43 return func
|
| /tools/asuite/atest-py2/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 | 187 def _Wrapper(func): argument
189 return Retry(retry_checker, max_retries, func, sleep_multiplier,
259 def PollAndWait(func, expected_return, timeout_exception, timeout_secs, argument
282 return_value = func(*args, **kwargs)
718 def __call__(self, func): argument
735 result = func(*args, **kargs)
1290 def _Wrapper(func): argument
1299 result = func(*args, **kwargs)
|
| /tools/asuite/atest-py2/metrics/ |
| D | metrics_utils.py | 31 def fun_var_decorate(func): argument
33 setattr(func, varname, value)
34 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/repohooks/rh/ |
| D | config.py | 171 func = functools.partial(rh.hooks.check_custom, options=options)
172 yield rh.hooks.CallableHook(hook, func, scope)
178 func = functools.partial(rh.hooks.BUILTIN_HOOKS[hook],
182 yield rh.hooks.CallableHook(hook, func, scope)
|
| D | hooks_unittest.py | 282 def _test_commit_messages(self, func, accept, msgs, files=None): argument
296 ret = func(self.project, 'commit', desc, diff, options=self.options)
304 def _test_file_filter(self, mock_check, func, files): argument
313 ret = func(self.project, 'commit', 'desc', (), options=self.options)
319 ret = func(self.project, 'commit', 'desc', diff, options=self.options)
|
| /tools/test/connectivity/acts/framework/tests/ |
| D | acts_test_decorators_test.py | 59 def _verify_test_info(self, func): argument
61 test_decorators.test_info(uuid=TEST_TRACKER_UUID)(func)()
308 def _run_with_test_logic(self, func): argument
311 setattr(MockTest, MockTest.TEST_LOGIC_ATTR, func)
|
| /tools/external_updater/ |
| D | external_updater.py | 233 check_parser.set_defaults(func=check)
263 update_parser.set_defaults(func=update)
272 args.func(args)
|