| /external/chromium-trace/catapult/common/py_utils/py_utils/ |
| D | retry_util_unittest.py | 21 @retry_util.RetryOnException(Exception, retries=3)
22 def Test(retries=None): argument
23 del retries
32 @retry_util.RetryOnException(KeyError, retries=5)
33 def Test(retries=None): argument
34 del retries
43 # Waits between retries do follow exponential backoff.
49 @retry_util.RetryOnException(KeyError, retries=3)
50 def Test(retries=None): argument
51 del retries
[all …]
|
| D | retry_util.py | 13 def RetryOnException(exc_type, retries): argument
19 Note: the default number of retries is defined on the decorator, the decorated
20 function *must* also receive a "retries" argument (although its assigned
22 number of retries at the call site.
24 The "unused" retries argument on the decorated function must be given to
30 @retry_util.RetryOnException(OSError, retries=3) # default no. of retries
31 def ProcessSomething(thing, retries=None): # this default value is ignored
32 del retries # Unused. Handled by the decorator.
35 ProcessSomething(a_thing) # retries 3 times.
36 ProcessSomething(b_thing, retries=5) # retries 5 times.
[all …]
|
| /external/chromium-trace/catapult/devil/devil/android/sdk/ |
| D | adb_wrapper.py | 94 raw_version = AdbWrapper._RunAdbCmd(['version'], timeout=2, retries=0)
132 @decorators.WithExplicitTimeoutAndRetries(timeout=60, retries=3)
300 retries=None, argument
348 def _RunDeviceAdbCmd(self, args, timeout, retries, check_error=True): argument
354 retries: Number of retries.
365 retries=retries,
423 def KillServer(cls, timeout=DEFAULT_TIMEOUT, retries=DEFAULT_RETRIES): argument
424 cls._RunAdbCmd(['kill-server'], timeout=timeout, retries=retries)
430 retries=DEFAULT_RETRIES): argument
436 retries: (optional) Number of retries to attempt.
[all …]
|
| /external/chromium-trace/catapult/devil/devil/android/ |
| D | decorators_test.py | 30 def alwaysTimesOut(timeout=None, retries=None): argument
36 alwaysTimesOut(timeout=1, retries=0)
42 """Tests that the base decorator handles the retries logic."""
46 def alwaysRaisesCommandFailedError(timeout=None, retries=None): argument
51 alwaysRaisesCommandFailedError(timeout=30, retries=10)
55 """Tests that the base decorator requires timeout and retries params."""
58 def requiresExplicitTimeoutAndRetries(timeout=None, retries=None): argument
59 return (timeout, retries)
66 requiresExplicitTimeoutAndRetries(retries=0)
70 timeout=expected_timeout, retries=expected_retries))
[all …]
|
| D | decorators.py | 33 retries_func: A callable that returns the retries value.
36 'retries' kwargs, respectively.
44 retries = retries_func(*args, **kwargs)
47 kwargs['retries'] = retries
63 impl, timeout, retries, desc=desc, retry_if_func=retry_if_func)
79 """A decorator that handles timeouts and retries.
81 'timeout' and 'retries' kwargs must be passed to the function.
89 get_retries = lambda *a, **kw: kw['retries']
94 """Returns a decorator that handles timeouts and, in some cases, retries.
96 'timeout' and 'retries' kwargs must be passed to the function.
[all …]
|
| D | battery_utils.py | 205 def SupportsFuelGauge(self, timeout=None, retries=None): argument
210 retries: number of retries
221 def GetFuelGaugeChargeCounter(self, timeout=None, retries=None): argument
229 retries: number of retries
243 def GetPowerData(self, timeout=None, retries=None): argument
248 retries: number of retries
308 def GetBatteryInfo(self, timeout=None, retries=None): argument
313 retries: number of retries
334 def GetCharging(self, timeout=None, retries=None): argument
339 retries: number of retries
[all …]
|
| D | device_utils.py | 508 def IsOnline(self, timeout=None, retries=None): argument
513 retries: number of retries
528 def HasRoot(self, timeout=None, retries=None): argument
547 retries: number of retries
565 def NeedsSU(self, timeout=DEFAULT, retries=DEFAULT): argument
570 retries: number of retries
600 retries=self._default_retries if retries is DEFAULT else retries)
612 def EnableRoot(self, timeout=None, retries=None): argument
617 retries: number of retries
650 def IsUserBuild(self, timeout=None, retries=None): argument
[all …]
|
| /external/chromium-trace/catapult/devil/docs/ |
| D | adb_wrapper.md | 21 retries: (optional) Number of retries to attempt.
43 retries: (optional) Number of retries to attempt.
78 retries: (optional) Number of retries to attempt.
88 retries: (optional) Number of retries to attempt.
101 retries: (optional) Number of retries to attempt.
111 retries: (optional) Number of retries to attempt.
133 retries: (optional) Number of retries to attempt.
155 retries: (optional) Number of retries to attempt.
175 retries: (optional) Number of retries to attempt.
198 retries: (optional) Number of retries to attempt.
[all …]
|
| D | device_utils.md | 14 retries: number of retries
57 retries: number of retries
83 retries: number of retries
96 retries: number of retries
125 retries: number of retries
145 retries: number of retries
159 retries: number of retries
176 retries: number of retries
226 retries: number of retries
288 retries: number of retries
[all …]
|
| /external/autotest/client/common_lib/cros/ |
| D | vpd_utils.py | 26 def dump_vpd_log(host, force=True, retries=3): argument
34 @param retries: Number of times to try rerunning the command in case of
39 retry_util.RetryException(error.AutoservRunError, retries, host.run,
43 def vpd_get(host, key, partition='RW_VPD', retries=3): argument
50 @param retries: Number of times to try rerunning the command in case of
57 return retry_util.RetryException(error.AutoservRunError, retries,
67 retries=3): argument
79 @param retries: Number of times to try rerunning the command in case of
87 retry_util.RetryException(error.AutoservRunError, retries,
91 dump_vpd_log(host, force=force_dump, retries=retries)
[all …]
|
| /external/autotest/server/cros/ap_configurators/ |
| D | ap_batch_locker.py | 28 @attribute retries: an integer, max number of retry attempts to lock ap.
32 def __init__(self, configurator, retries): argument
36 @param retries: an integer, max number of retry attempts to lock ap.
40 self.retries = retries
44 """@return class name, ap host name, lock status and retries."""
45 return 'class: %s, host name: %s, to_be_locked = %s, retries = %d' % (
49 self.retries)
52 def construct_ap_lockers(ap_spec, retries, hostname_matching_only=False, argument
57 @param retries: an integer, max number of retry attempts to lock ap.
71 ap_lockers_list.append(ApLocker(ap, retries))
[all …]
|
| /external/bazelbuild-rules_python/tests/envsubst/ |
| D | envsubst_tests.bzl | 23 envsubst("--retries=$PIP_RETRIES", ["PIP_RETRIES"], {"PIP_RETRIES": "5"}.get),
24 ).equals("--retries=5")
27 envsubst("--retries=$PIP_RETRIES", [], {"PIP_RETRIES": "5"}.get),
28 ).equals("--retries=$PIP_RETRIES")
31 envsubst("--retries=$PIP_RETRIES", ["PIP_RETRIES"], {}.get),
32 ).equals("--retries=")
38 envsubst("--retries=${PIP_RETRIES}", ["PIP_RETRIES"], {"PIP_RETRIES": "5"}.get),
39 ).equals("--retries=5")
42 envsubst("--retries=${PIP_RETRIES}", [], {"PIP_RETRIES": "5"}.get),
43 ).equals("--retries=${PIP_RETRIES}")
[all …]
|
| /external/autotest/server/cros/clique_lib/ |
| D | clique_dut_locker.py | 46 """@return class name, dut host name, lock status and retries."""
73 @attribute retries: an integer, max number of retry attempts to lock DUT.
78 def __init__(self, dut_spec, retries): argument
83 @param retries: an integer, max number of retry attempts to lock DUT.
86 self.retries = retries
90 """@return class name, dut host name, lock status and retries."""
91 return 'class: %s, host name: %s, to_be_locked = %s, retries = %d' % (
95 self.retries)
102 retries.
112 def __init__(self, lock_manager, dut_pool_spec, retries=MAX_RETRIES): argument
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | clustering_ops_test.cc | 46 // Number of retries for tests.
91 #define RUN_BM_KmeansPlusPlusInitialization(retries) \ argument
92 BENCHMARK_KMEANS_PLUS_PLUS(k10Points, k2Centers, k100Dim, retries); \
93 BENCHMARK_KMEANS_PLUS_PLUS(k10Points, k5Centers, k100Dim, retries); \
94 BENCHMARK_KMEANS_PLUS_PLUS(k10Points, k10Centers, k100Dim, retries); \
95 BENCHMARK_KMEANS_PLUS_PLUS(k100Points, k10Centers, k100Dim, retries); \
96 BENCHMARK_KMEANS_PLUS_PLUS(k100Points, k20Centers, k100Dim, retries); \
97 BENCHMARK_KMEANS_PLUS_PLUS(k100Points, k50Centers, k100Dim, retries); \
98 BENCHMARK_KMEANS_PLUS_PLUS(k100Points, k100Centers, k100Dim, retries); \
99 BENCHMARK_KMEANS_PLUS_PLUS(k1kPoints, k100Centers, k100Dim, retries); \
[all …]
|
| /external/vboot_reference/firmware/stub/ |
| D | tpm_lite_stub.c | 85 int retries = 0; in TpmExecute() local
90 for ( ; retries < COMM_RETRY_MAX_NUM; ++retries) { in TpmExecute()
95 if (retries == 0) { in TpmExecute()
99 retries + 1, strerror(errno)); in TpmExecute()
108 "%d vs %u (%d retries, first error %d)\n", in TpmExecute()
109 n, in_len, retries, first_errno); in TpmExecute()
115 for (retries = 0, first_errno = 0; in TpmExecute()
116 retries < COMM_RETRY_MAX_NUM; ++retries) { in TpmExecute()
121 if (retries == 0) { in TpmExecute()
125 retries + 1, strerror(errno)); in TpmExecute()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Errors.kt | 60 * Retries collection of the given flow up to [retries] times when an exception that matches the
66 …* The default value of [retries] parameter is [Long.MAX_VALUE]. This value effectively means to re…
68 * and [predicate] is not called when it reaches the given number of [retries]:
71 * retryWhen { cause, attempt -> attempt < retries && predicate(cause) }
84 * @throws IllegalArgumentException when [retries] is not positive.
87 retries: Long = Long.MAX_VALUE, in retry()
90 require(retries > 0) { "Expected positive amount of retries, but had $retries" } in <lambda>()
91 return retryWhen { cause, attempt -> attempt < retries && predicate(cause) } in cause()
95 * Retries collection of the given flow when an exception occurs in the upstream flow and the
100 …* For example, the following call retries the flow forever if the error is caused by `IOException`…
[all …]
|
| /external/openthread/tests/scripts/expect/ |
| D | cli-mac.exp | 34 send "mac retries direct 5\n"
36 send "mac retries direct\n"
40 send "mac retries indirect 2\n"
42 send "mac retries indirect\n"
50 send "mac retries\n"
52 send "mac retries something_invalid\n"
54 send "mac retries direct 256\n"
56 send "mac retries indirect 256\n"
|
| /external/autotest/client/cros/cellular/pseudomodem/ |
| D | sim.py | 136 'retries' : pin_retries
140 'retries' : puk_retries
194 Returns the number of unlock retries left.
196 @returns: The number of unlock retries for each lock type the SIM
200 retries = dbus.Dictionary(signature='uu')
202 return retries
204 retries[dbus.types.UInt32(k)] = dbus.types.UInt32(v['retries'])
205 return retries
289 # - if the number of retries left for |lock_data| drops down to 0,
302 # remaining retries.
[all …]
|
| /external/trusty/arm-trusted-firmware/drivers/ufs/ |
| D | ufs.c | 40 * -EAGAIN - non-fatal error, retries are sufficient
66 /* NL/TL/DME error requires retries */ in ufs_uic_error_handler()
93 * -EAGAIN - non-fatal error, retries are sufficient
164 int result, retries; in ufshc_send_uic_cmd() local
169 for (retries = 0; retries < 100; retries++) { in ufshc_send_uic_cmd()
176 if (retries >= 100) { in ufshc_send_uic_cmd()
198 int result, retries; in ufshc_dme_get() local
212 for (retries = 0; retries < UFS_UIC_COMMAND_RETRIES; ++retries) { in ufshc_dme_get()
221 if (retries >= UFS_UIC_COMMAND_RETRIES) in ufshc_dme_get()
231 int result, retries; in ufshc_dme_set() local
[all …]
|
| /external/arm-trusted-firmware/drivers/ufs/ |
| D | ufs.c | 60 int result, retries; in ufshc_dme_get() local
69 for (retries = 0; retries < 100; retries++) { in ufshc_dme_get()
75 if (retries >= 100) in ufshc_dme_get()
82 for (retries = 0; retries < UFS_UIC_COMMAND_RETRIES; ++retries) { in ufshc_dme_get()
90 if (retries >= UFS_UIC_COMMAND_RETRIES) in ufshc_dme_get()
101 int result, retries; in ufshc_dme_set() local
112 for (retries = 0; retries < UFS_UIC_COMMAND_RETRIES; ++retries) { in ufshc_dme_set()
120 if (retries >= UFS_UIC_COMMAND_RETRIES) in ufshc_dme_set()
129 int retries; in ufshc_hce_enable() local
135 for (retries = 0; retries < HCE_ENABLE_INNER_RETRIES; ++retries) { in ufshc_hce_enable()
[all …]
|
| /external/pytorch/tools/linter/adapters/ |
| D | ruff_linter.py | 102 retries: int = 0,
109 remaining_retries = retries
121 retries - remaining_retries,
122 retries,
134 "--retries",
218 retries: int,
236 retries=retries,
300 retries: int,
321 retries=retries,
428 retries=args.retries,
[all …]
|
| D | black_linter.py | 71 retries: int,
74 remaining_retries = retries
84 retries - remaining_retries,
85 retries,
93 retries: int,
103 retries=retries,
178 "--retries",
216 executor.submit(check_file, x, args.retries, args.timeout): x
|
| D | clangformat_linter.py | 69 retries: int,
72 remaining_retries = retries
82 retries - remaining_retries,
83 retries,
92 retries: int,
100 retries=retries,
180 "--retries",
237 executor.submit(check_file, x, binary, args.retries, args.timeout): x
|
| /external/arm-trusted-firmware/drivers/rpi3/mailbox/ |
| D | rpi3_mbox.c | 26 unsigned int retries; in rpi3_vc_mailbox_request_send() local
35 retries = 0U; in rpi3_vc_mailbox_request_send()
40 retries++; in rpi3_vc_mailbox_request_send()
41 if (retries == RPI3_MAILBOX_MAX_RETRIES) { in rpi3_vc_mailbox_request_send()
53 retries = 0U; in rpi3_vc_mailbox_request_send()
58 retries++; in rpi3_vc_mailbox_request_send()
59 if (retries == RPI3_MAILBOX_MAX_RETRIES) { in rpi3_vc_mailbox_request_send()
|
| /external/trusty/arm-trusted-firmware/drivers/rpi3/mailbox/ |
| D | rpi3_mbox.c | 26 unsigned int retries; in rpi3_vc_mailbox_request_send() local
35 retries = 0U; in rpi3_vc_mailbox_request_send()
40 retries++; in rpi3_vc_mailbox_request_send()
41 if (retries == RPI3_MAILBOX_MAX_RETRIES) { in rpi3_vc_mailbox_request_send()
53 retries = 0U; in rpi3_vc_mailbox_request_send()
58 retries++; in rpi3_vc_mailbox_request_send()
59 if (retries == RPI3_MAILBOX_MAX_RETRIES) { in rpi3_vc_mailbox_request_send()
|