| /tools/test/connectivity/acts/framework/acts/controllers/buds_lib/ |
| D | tako_trace_logger.py | 22 def __init__(self, *args, **kwargs): argument
23 super().__init__(*args, **kwargs)
32 return lambda *args, **kwargs: self._logger.log(level, *args, **kwargs)
34 def step(self, msg, *args, **kwargs): argument
36 self._log_with(self._logger_level('STEP'), 1, msg, *args, **kwargs)
38 def device(self, msg, *args, **kwargs): argument
40 self._log_with(self._logger_level('DEVICE'), 1, msg, *args, **kwargs)
42 def suite(self, msg, *args, **kwargs): argument
44 self._log_with(self._logger_level('SUITE'), 1, msg, *args, **kwargs)
46 def case(self, msg, *args, **kwargs): argument
[all …]
|
| /tools/test/connectivity/acts/framework/acts/ |
| D | tracelogger.py | 41 def _log_with(self, logging_lambda, trace_level, msg, *args, **kwargs): argument
43 logging_lambda('%s %s' % (msg, trace_info), *args, **kwargs)
45 def exception(self, msg, *args, **kwargs): argument
46 self._log_with(self._logger.exception, 5, msg, *args, **kwargs)
48 def debug(self, msg, *args, **kwargs): argument
49 self._log_with(self._logger.debug, 3, msg, *args, **kwargs)
51 def error(self, msg, *args, **kwargs): argument
52 self._log_with(self._logger.error, 3, msg, *args, **kwargs)
54 def warn(self, msg, *args, **kwargs): argument
55 self._log_with(self._logger.warn, 1, msg, *args, **kwargs)
[all …]
|
| D | test_decorators.py | 86 def __call__(self, *args, **kwargs): argument
92 result = self.func(*args, **kwargs)
109 gathered_extras = self._gather_local_info(None, *args, **kwargs)
121 def gather(self, *args, **kwargs): argument
130 extras = self.func.gather(*args, **kwargs)
134 self._gather_local_info(extras, *args, **kwargs)
138 def _gather_local_info(self, gather_into, *args, **kwargs): argument
150 if not self.predicate or self.predicate(args, kwargs):
181 def __call__(self, *args, **kwargs): argument
186 return self.target(self.instance, *args, **kwargs)
[all …]
|
| D | dict_object.py | 28 def __init__(self, *args, **kwargs): argument
38 super(DictObject, self).update(**kwargs)
|
| D | error.py | 9 def __init__(self, *args, **kwargs): argument
13 self.extra = kwargs
|
| /tools/test/connectivity/acts/framework/acts/libs/test_binding/ |
| D | binding.py | 59 def __call__(self, *args, **kwargs): argument
65 full_args, kwargs = self.arg_modifier(self.inner, *full_args,
66 **kwargs)
69 self.before(self.inner, *full_args, **kwargs)
73 result = self.inner(*full_args, **kwargs)
76 self.after(self.inner, result, *full_args, **kwargs)
88 **kwargs)
|
| /tools/tradefederation/core/atest/tools/ |
| D | atest_tools.py | 103 **kwargs): argument
113 prunenames = kwargs.pop('prunenames', ' '.join(PRUNENAMES))
114 prunepaths = kwargs.pop('prunepaths', os.path.join(search_root, 'out'))
115 if kwargs:
116 raise TypeError('Unexpected **kwargs: %r' % kwargs)
296 def index_targets(output_cache=constants.LOCATE_CACHE, **kwargs): argument
313 class_index = kwargs.pop('class_index', constants.CLASS_INDEX)
314 qclass_index = kwargs.pop('qclass_index', constants.QCLASS_INDEX)
315 package_index = kwargs.pop('package_index', constants.PACKAGE_INDEX)
316 cc_class_index = kwargs.pop('cc_class_index', constants.CC_CLASS_INDEX)
[all …]
|
| /tools/asuite/atest/tools/ |
| D | atest_tools.py | 98 **kwargs): argument
108 prunenames = kwargs.pop('prunenames', ' '.join(PRUNENAMES))
109 prunepaths = kwargs.pop('prunepaths', os.path.join(search_root, 'out'))
110 if kwargs:
111 raise TypeError('Unexpected **kwargs: %r' % kwargs)
300 def index_targets(output_cache=constants.LOCATE_CACHE, **kwargs): argument
318 class_index = kwargs.pop('class_index', constants.CLASS_INDEX)
319 qclass_index = kwargs.pop('qclass_index', constants.QCLASS_INDEX)
320 package_index = kwargs.pop('package_index', constants.PACKAGE_INDEX)
321 cc_class_index = kwargs.pop('cc_class_index', constants.CC_CLASS_INDEX)
[all …]
|
| /tools/repohooks/rh/ |
| D | utils.py | 191 kwargs = {}
194 kwargs['timeout'] = 60
195 proc.wait_lock_breaker(**kwargs)
238 def _lock_breaker(self, func, *args, **kwargs): argument
248 return func(*args, **kwargs)
253 return func(*args, **kwargs)
255 def poll_lock_breaker(self, *args, **kwargs): argument
257 return self._lock_breaker(self.poll, *args, **kwargs)
259 def wait_lock_breaker(self, *args, **kwargs): argument
261 return self._lock_breaker(self.wait, *args, **kwargs)
[all …]
|
| D | hooks.py | 202 def _run(cmd, **kwargs): argument
204 kwargs.setdefault('combine_stdout_stderr', True)
205 kwargs.setdefault('capture_output', True)
206 kwargs.setdefault('check', False)
209 kwargs.setdefault('input', '')
210 return rh.utils.run(cmd, **kwargs)
269 def _fixup_func_caller(cmd, **kwargs): argument
277 result = _run(cmd, **kwargs)
284 def _check_cmd(hook_name, project, commit, cmd, fixup_func=None, **kwargs): argument
287 _run(cmd, **kwargs),
[all …]
|
| /tools/test/connectivity/acts/framework/acts/event/ |
| D | subscription_handle.py | 58 def _wrapped_call(*args, **kwargs): argument
60 return func(*args, **kwargs)
62 return func(self._owner, *args, **kwargs)
65 def __call__(self, *args, **kwargs): argument
66 return self._func(*args, **kwargs)
|
| D | decorators.py | 65 def init_replacement(self, *args, **kwargs): argument
66 old_init(self, *args, **kwargs)
|
| /tools/test/connectivity/acts/framework/tests/libs/test_bindings/ |
| D | binding_test.py | 39 def inner(*args, **kwargs): argument
41 self.inner_kwargs = kwargs
55 def inner(*args, **kwargs): argument
67 def inner(*args, **kwargs): argument
105 def arg_modifier(_, *args, **kwargs): argument
107 new_kwargs = dict(kwargs, kw='value')
111 def inner(*args, **kwargs): argument
113 self.inner_kwargs = kwargs
|
| /tools/test/connectivity/acts/framework/tests/metrics/ |
| D | logger_test.py | 43 kwargs = {'mock' : Mock()}
44 logger = MetricLogger.for_test_case(*args, **kwargs)
46 proxy_cls.assert_called_once_with(MetricLogger, args, kwargs)
51 kwargs = {'mock': Mock()}
52 logger = MetricLogger.for_test_class(*args, **kwargs)
54 proxy_cls.assert_called_once_with(MetricLogger, args, kwargs)
61 kwargs = {'mock': Mock()}
62 logger = TestLogger.for_test_case(*args, **kwargs)
64 proxy_cls.assert_called_once_with(TestLogger, args, kwargs)
71 kwargs = {'mock': Mock()}
[all …]
|
| /tools/test/connectivity/acts/framework/acts/controllers/ |
| D | adb.py | 185 def _exec_adb_cmd(self, name, arg_str, **kwargs): argument
187 **kwargs)
189 def _exec_cmd_nb(self, cmd, **kwargs): argument
196 return job.run_async(cmd, **kwargs)
198 def _exec_adb_cmd_nb(self, name, arg_str, **kwargs): argument
200 **kwargs)
279 def adb_call(*args, **kwargs): argument
282 return self._exec_adb_cmd(clean_name, arg_str, **kwargs)
|
| D | fastboot.py | 79 def args(self, *args, **kwargs): argument
80 return job.run(' '.join((self.fastboot_str, ) + args), **kwargs).stdout
83 def fastboot_call(*args, **kwargs): argument
86 return self._exec_fastboot_cmd(clean_name, arg_str, **kwargs)
|
| /tools/test/connectivity/acts/framework/acts/libs/ |
| D | version_selector.py | 217 def __call__(self, *args, **kwargs): argument
233 level = self.get_version(self.instance, *args, **kwargs)
235 level = self.get_version(*args, **kwargs)
238 for key, value in kwargs.items():
267 return func(*args, **kwargs)
269 return func(self.instance, *args, **kwargs)
|
| /tools/acloud/internal/lib/ |
| D | driver_test_lib.py | 33 def Patch(self, *args, **kwargs): argument
46 patcher = mock.patch.object(*args, **kwargs)
|
| /tools/asuite/aidegen/lib/ |
| D | common_util.py | 78 def wrapper(*args, **kwargs): argument
83 return func(*args, **kwargs)
373 def wrapper(*args, **kwargs): argument
377 return func(*args, **kwargs)
514 def wrapper(*args, **kwargs): argument
517 return func(*args, **kwargs)
548 def decorated(*args, **kwargs): argument
558 if arg_name not in kwargs:
560 arg_val = kwargs.get(arg_name)
567 return func(*args, **kwargs)
|
| /tools/asuite/atest/ |
| D | asuite_metrics.py | 37 def log_event(metrics_url, dummy_key_fallback=True, **kwargs): argument
57 if kwargs:
58 data.update(kwargs)
|
| /tools/tradefederation/core/atest/ |
| D | asuite_metrics.py | 43 def log_event(metrics_url, dummy_key_fallback=True, **kwargs): argument
63 if kwargs:
64 data.update(kwargs)
|
| /tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
| D | rpc_client.py | 118 def rpc(self, name, *args, **kwargs): argument
119 future = self._executor.submit(name, *args, **kwargs)
125 def rpc_call(*args, **kwargs): argument
127 self._rpc_client.__getattr__(name), *args, **kwargs)
352 def rpc_call(*args, **kwargs): argument
353 return self.rpc(name, *args, **kwargs)
|
| /tools/asuite/atest/metrics/ |
| D | metrics_base.py | 101 def __new__(cls, **kwargs): argument
121 if field in kwargs:
122 fields_and_values[field] = kwargs.pop(field)
|
| /tools/tradefederation/core/atest/metrics/ |
| D | metrics_base.py | 101 def __new__(cls, **kwargs): argument
121 if field in kwargs:
122 fields_and_values[field] = kwargs.pop(field)
|
| /tools/asuite/atest/test_runners/ |
| D | test_runner_base.py | 55 def __init__(self, results_dir, **kwargs): argument
64 if kwargs:
65 logging.debug('ignoring the following args: %s', kwargs)
|