| /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/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 | 41 def test_info_decorator(func): argument
42 return _TestInfoDecoratorFunc(func, predicate, keyed_info)
77 def decorator(func): argument
78 if not func.__name__.startswith('test_'):
87 func(self)
104 i, func.__name__)))
146 def __init__(self, func, predicate, keyed_info): argument
147 self.func = func
150 self.__name__ = func.__name__
151 self.__doc__ = func.__doc__
[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)
592 def get_func_with_retry(self, func, attempts=2): argument
615 return func(*args, **kwargs)
700 def _exec_func(self, func, *args): argument
715 return func(*args)
720 func.__name__, self.TAG)
|
| D | utils.py | 353 def concurrent_exec(func, param_list): argument
372 future_to_params = {executor.submit(func, *p): p for p in param_list}
560 def decorator(func): argument
561 @functools.wraps(func)
567 return func(*args, **kwargs)
570 "seconds.").format(func.__name__, sec))
1047 def wait_until(func, timeout_s, condition=True, sleep_s=1.0): argument
1069 if func() == condition:
1075 'attempted %d times.' % (str(func), timeout_s, count))
|
| /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,
|
| /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/acloud/internal/lib/ |
| D | utils.py | 186 def _Wrapper(func): argument
188 return Retry(retry_checker, max_retries, func, sleep_multiplier,
258 def PollAndWait(func, expected_return, timeout_exception, timeout_secs, argument
281 return_value = func(*args, **kwargs)
718 def __call__(self, func): argument
735 result = func(*args, **kargs)
1280 def _Wrapper(func): argument
1289 result = func(*args, **kwargs)
|
| /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/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()
|
| D | TelLiveRebootStressTest.py | 103 func = getattr(self, method)
105 check_result = func()
122 func = getattr(self, method)
123 if not func():
131 func = getattr(self, method)
133 func_result = func()
|
| /tools/repohooks/rh/ |
| D | hooks_unittest.py | 264 def _test_commit_messages(self, func, accept, msgs, files=None): argument
278 ret = func(self.project, 'commit', desc, diff, options=self.options)
286 def _test_file_filter(self, mock_check, func, files): argument
295 ret = func(self.project, 'commit', 'desc', (), options=self.options)
301 ret = func(self.project, 'commit', 'desc', diff, options=self.options)
|
| /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/repohooks/tools/ |
| D | checkpatch.pl | 5393 my $func = $1;
5395 "$func(NULL) is safe and this check is probably not required\n" . $hereprev) &&
5405 if ($lines[$linenr - 1] =~ /^\+(\t+)$func\s*\(\s*$tested\s*\)\s*;\s*$/) {
5538 my $func = $constant_func;
5539 $func =~ s/^__constant_//;
5541 "$constant_func should be $func\n" . $herecurr) &&
5543 $fixed[$fixlinenr] =~ s/\b$constant_func\b/$func/g;
6413 my $func = $entry->[0];
6425 my $test = "\\b$func\\s*\\(${skip_args}($FuncArg(?:\\|\\s*$FuncArg)*)\\s*[,\\)]";
6429 if (!($func =~ /^(?:module_param|proc_create)/ && $val eq "0") &&
|
| /tools/test/connectivity/acts/framework/tests/ |
| D | acts_test_decorators_test.py | 57 def _verify_test_tracker_info(self, func): argument
59 test_decorators.test_tracker_info(uuid=TEST_TRACKER_UUID)(func)()
204 def _run_with_test_logic(self, func): argument
207 setattr(MockTest, MockTest.TEST_LOGIC_ATTR, func)
|
| /tools/asuite/atest/ |
| D | atest_decorator.py | 29 def fun_var_decorate(func): argument
31 setattr(func, varname, value)
32 return func
|
| /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/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/external_updater/ |
| D | external_updater.py | 228 check_parser.set_defaults(func=check)
250 update_parser.set_defaults(func=update)
259 args.func(args)
|