| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AtomicBackoffTest.java | 35 AtomicBackoff backoff = new AtomicBackoff("test", 8); in backoff_doesNotChangeStateGet() local
36 AtomicBackoff.State state = backoff.getState(); in backoff_doesNotChangeStateGet()
38 state.backoff(); in backoff_doesNotChangeStateGet()
44 AtomicBackoff backoff = new AtomicBackoff("test", 3); in backoff_doubles() local
45 backoff.getState().backoff(); in backoff_doubles()
46 assertEquals(6, backoff.getState().get()); in backoff_doubles()
48 backoff.getState().backoff(); in backoff_doubles()
49 assertEquals(12, backoff.getState().get()); in backoff_doubles()
51 backoff.getState().backoff(); in backoff_doubles()
52 assertEquals(24, backoff.getState().get()); in backoff_doubles()
[all …]
|
| /external/grpc-grpc/test/core/backoff/ |
| D | backoff_test.cc | 45 BackOff backoff(options); in TEST() local
47 grpc_millis next_attempt_start_time = backoff.NextAttemptTime(); in TEST()
51 next_attempt_start_time = backoff.NextAttemptTime(); in TEST()
68 BackOff backoff(options); in TEST() local
69 grpc_millis next = backoff.NextAttemptTime(); in TEST()
83 BackOff backoff(options); in TEST() local
88 grpc_millis next = backoff.NextAttemptTime(); in TEST()
91 next = backoff.NextAttemptTime(); in TEST()
94 next = backoff.NextAttemptTime(); in TEST()
97 next = backoff.NextAttemptTime(); in TEST()
[all …]
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | frontend_wrappers_unittest.py | 22 backoff = 2
26 max_retry = frontend_wrappers.convert_timeout_to_retry(backoff,
34 backoff = 2
41 backoff, timeout_min_lower_limit, delay_sec)
44 backoff, timeout_min_at_limit, delay_sec)
47 backoff, timeout_min_upper_limit, delay_sec)
60 backoff = 2
64 max_retry = frontend_wrappers.convert_timeout_to_retry(backoff,
75 backoff = 2
79 max_retry = frontend_wrappers.convert_timeout_to_retry(backoff,
|
| D | frontend_wrappers.py | 31 def convert_timeout_to_retry(backoff, timeout_min, delay_sec): argument
46 numerator = math.log10(1 - (total_sleep / delay_sec) * (1 - backoff))
47 denominator = math.log10(backoff)
89 backoff = 2
90 max_retry = convert_timeout_to_retry(backoff, self.timeout_min,
121 dargs['backoff_factor'] = backoff
|
| /external/oss-fuzz/infra/ |
| D | retry.py | 31 def get_delay(num_try, delay, backoff): argument
33 return delay * (backoff**(num_try - 1))
38 backoff=2, argument
44 assert backoff >= 1
62 sleep(get_delay(num_try, delay, backoff))
|
| /external/swiftshader/src/Common/ |
| D | MutexLock.hpp | 89 int backoff = 1; in lock() local
93 if(backoff <= 64) in lock()
95 for(int i = 0; i < backoff; i++) in lock()
140 backoff *= 2; in lock()
146 backoff = 1; in lock()
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | array.rs | 157 let backoff = Backoff::new(); in start_send() localVariable
203 backoff.spin(); in start_send()
216 backoff.spin(); in start_send()
220 backoff.snooze(); in start_send()
246 let backoff = Backoff::new(); in start_recv() localVariable
285 backoff.spin(); in start_recv()
306 backoff.spin(); in start_recv()
310 backoff.snooze(); in start_recv()
349 let backoff = Backoff::new(); in send() localVariable
356 if backoff.is_completed() { in send()
[all …]
|
| D | list.rs | 54 let backoff = Backoff::new(); in wait_write() localVariable
56 backoff.snooze(); in wait_write()
86 let backoff = Backoff::new(); in wait_next() localVariable
92 backoff.snooze(); in wait_next()
197 let backoff = Backoff::new(); in start_send() localVariable
214 backoff.snooze(); in start_send()
272 backoff.spin(); in start_send()
299 let backoff = Backoff::new(); in start_recv() localVariable
309 backoff.snooze(); in start_recv()
343 backoff.snooze(); in start_recv()
[all …]
|
| /external/ltp/tools/genload/ |
| D | stress.c | 475 long backoff = global_backoff * forks; in hogcpu() local
477 dbg(stdout, "using backoff sleep of %lius for hogcpu\n", backoff); in hogcpu()
485 usleep(backoff); in hogcpu()
551 long backoff = global_backoff * forks; in hogio() local
553 dbg(stdout, "using backoff sleep of %lius for hogio\n", backoff); in hogio()
561 usleep(backoff); in hogio()
627 long backoff = global_backoff * forks; in hogvm() local
629 dbg(stdout, "using backoff sleep of %lius for hogvm\n", backoff); in hogvm()
642 usleep(backoff); in hogvm()
750 long backoff = global_backoff * forks; in hoghdd() local
[all …]
|
| D | genload.c | 475 long backoff = global_backoff * forks; in hogcpu() local
477 dbg(stdout, "using backoff sleep of %lius for hogcpu\n", backoff); in hogcpu()
485 usleep(backoff); in hogcpu()
551 long backoff = global_backoff * forks; in hogio() local
553 dbg(stdout, "using backoff sleep of %lius for hogio\n", backoff); in hogio()
561 usleep(backoff); in hogio()
627 long backoff = global_backoff * forks; in hogvm() local
629 dbg(stdout, "using backoff sleep of %lius for hogvm\n", backoff); in hogvm()
642 usleep(backoff); in hogvm()
750 long backoff = global_backoff * forks; in hoghdd() local
[all …]
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | context.rs | 124 let backoff = Backoff::new(); in wait_packet() localVariable
130 backoff.snooze(); in wait_packet()
140 let backoff = Backoff::new(); in wait_until() localVariable
147 if backoff.is_completed() { in wait_until()
150 backoff.snooze(); in wait_until()
|
| /external/autotest/server/site_tests/autoupdate_OmahaResponse/ |
| D | autoupdate_OmahaResponse.py | 21 bad_metadata_size=False, test_backoff=False, backoff=False, argument
62 backoff=backoff)
|
| D | control.local | 21 test_backoff: tests that we do/dont backoff when an update fails.
22 backoff: True if we should backoff. False otherwise.
34 test_backoff=True, backoff=True, running_at_desk=True,
|
| D | control.backoff_enabled.full | 7 PURPOSE = "Tests second update attempt fails if backoff is enabled."
14 Test we cannot update when we fail the first attempt and backoff is enabled.
24 test_backoff=True, backoff=True, **args_dict)
|
| D | control.backoff_disabled.full | 8 PURPOSE = "Tests second update attempt succeeds if backoff is disabled."
14 Test we can update when we fail the first attempt and backoff is disabled.
24 test_backoff=True, backoff=False, **args_dict)
|
| /external/autotest/client/site_tests/autoupdate_Backoff/ |
| D | control | 8 Client side test of the update_engine backoff mechanism.
9 This will be called from the server tests: autoupdate_OmahaResponse.backoff*
13 PURPOSE = 'Client side test of the update_engine backoff mechanism.'
|
| D | autoupdate_Backoff.py | 44 def run_once(self, payload_url, backoff): argument
61 response_props = {'disable_payload_backoff': not backoff,
75 if backoff:
|
| /external/compiler-rt/lib/tsan/rtl/ |
| D | tsan_mutex.cc | 235 for (Backoff backoff; backoff.Do();) { in Lock() local
241 StatInc(cur_thread(), stat_type_, backoff.Contention()); in Lock()
265 for (Backoff backoff; backoff.Do();) { in ReadLock() local
269 StatInc(cur_thread(), stat_type_, backoff.Contention()); in ReadLock()
|
| /external/llvm-project/compiler-rt/lib/tsan/rtl/ |
| D | tsan_mutex.cpp | 234 for (Backoff backoff; backoff.Do();) { in Lock() local
240 StatInc(cur_thread(), stat_type_, backoff.Contention()); in Lock()
264 for (Backoff backoff; backoff.Do();) { in ReadLock() local
268 StatInc(cur_thread(), stat_type_, backoff.Contention()); in ReadLock()
|
| /external/grpc-grpc/test/core/util/ |
| D | reconnect_server.cc | 38 double expected_backoff = 1000.0, backoff; in pretty_print_backoffs() local
43 backoff = gpr_time_to_millis(diff); in pretty_print_backoffs()
46 i, backoff / 1000.0, expected_backoff / 1000.0, in pretty_print_backoffs()
47 (backoff - expected_backoff) * 100.0 / expected_backoff); in pretty_print_backoffs()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | reconnect_interop_server.cc | 130 double backoff = gpr_time_to_millis( in Verify() local
134 if (backoff < min_backoff - kTransmissionDelay || in Verify()
135 backoff > max_backoff + kTransmissionDelay) { in Verify()
138 response->add_backoff_ms(static_cast<int32_t>(backoff)); in Verify()
|
| /external/webrtc/rtc_tools/testing/ |
| D | utils.py | 32 backoff = pow(2, i)
33 print('Got %s, retrying in %d seconds...' % (exception, backoff))
34 time.sleep(backoff)
|
| /external/scudo/standalone/tests/ |
| D | mutex_test.cpp | 43 void backoff() { in backoff() function in TestData
69 Data->backoff(); in lockThread()
78 Data->backoff(); in tryThread()
|
| /external/llvm-project/compiler-rt/lib/scudo/standalone/tests/ |
| D | mutex_test.cpp | 43 void backoff() { in backoff() function in TestData
69 Data->backoff(); in lockThread()
78 Data->backoff(); in tryThread()
|
| /external/curl/docs/cmdline-opts/ |
| D | retry-delay.d | 8 failed with a transient error (it changes the default backoff time algorithm
10 used. Setting this delay to zero will make curl use the default backoff time.
|