| /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
44 AtomicBackoff backoff = new AtomicBackoff("test", 3); in backoff_doubles() local
61 AtomicBackoff backoff = new AtomicBackoff("test", 8); in backoff_oncePerState() local
74 AtomicBackoff backoff = new AtomicBackoff("test", 8); in backoff_twiceForEquivalentState_noChange() local
84 AtomicBackoff backoff = new AtomicBackoff("test", 8); in backoff_delayed() local
99 AtomicBackoff backoff = new AtomicBackoff("test", tooLarge); in largeLong() local
|
| /external/grpc-grpc/test/core/backoff/ |
| D | backoff_test.cc | 45 BackOff backoff(options); in TEST() local
68 BackOff backoff(options); in TEST() local
83 BackOff backoff(options); in TEST() local
138 BackOff backoff(options); in TEST() local
|
| /external/oss-fuzz/infra/ |
| D | retry.py | 31 def get_delay(num_try, delay, backoff): argument
38 backoff=2, argument
|
| /external/ltp/tools/genload/ |
| D | stress.c | 475 long backoff = global_backoff * forks; in hogcpu() local
551 long backoff = global_backoff * forks; in hogio() local
627 long backoff = global_backoff * forks; in hogvm() local
750 long backoff = global_backoff * forks; in hoghdd() local
|
| D | genload.c | 475 long backoff = global_backoff * forks; in hogcpu() local
551 long backoff = global_backoff * forks; in hogio() local
627 long backoff = global_backoff * forks; in hogvm() local
750 long backoff = global_backoff * forks; in hoghdd() local
|
| /external/rust/crates/crossbeam-channel/src/ |
| D | context.rs | 126 let backoff = Backoff::new(); in wait_packet() localVariable
142 let backoff = Backoff::new(); in wait_until() localVariable
|
| /external/rust/crates/crossbeam-queue/src/ |
| D | seg_queue.rs | 45 let backoff = Backoff::new(); in wait_write() localVariable
74 let backoff = Backoff::new(); in wait_next() localVariable
188 let backoff = Backoff::new(); in push() localVariable
283 let backoff = Backoff::new(); in pop() localVariable
|
| D | array_queue.rs | 129 let backoff = Backoff::new(); in push_or_else() localVariable
276 let backoff = Backoff::new(); in pop() localVariable
|
| /external/rust/crates/crossbeam-utils/src/ |
| D | lib.rs | 92 mod backoff; module
|
| /external/rust/crates/crossbeam-channel/src/flavors/ |
| D | list.rs | 59 let backoff = Backoff::new(); in wait_write() localVariable
88 let backoff = Backoff::new(); in wait_next() localVariable
199 let backoff = Backoff::new(); in start_send() localVariable
301 let backoff = Backoff::new(); in start_recv() localVariable
447 let backoff = Backoff::new(); in recv() localVariable
569 let backoff = Backoff::new(); in discard_all_messages() localVariable
|
| D | array.rs | 142 let backoff = Backoff::new(); in start_send() localVariable
232 let backoff = Backoff::new(); in start_recv() localVariable
340 let backoff = Backoff::new(); in send() localVariable
400 let backoff = Backoff::new(); in recv() localVariable
|
| /external/compiler-rt/lib/tsan/rtl/ |
| D | tsan_mutex.cc | 235 for (Backoff backoff; backoff.Do();) { in Lock() local
265 for (Backoff backoff; backoff.Do();) { in ReadLock() local
|
| /external/autotest/client/site_tests/autoupdate_Backoff/ |
| D | autoupdate_Backoff.py | 45 def run_once(self, payload_url, backoff): argument
|
| /external/autotest/server/site_tests/autoupdate_OmahaResponse/ |
| D | autoupdate_OmahaResponse.py | 22 bad_metadata_size=False, test_backoff=False, backoff=False, argument
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AtomicBackoff.java | 63 public void backoff() { in backoff() method in AtomicBackoff.State
|
| /external/cronet/base/allocator/partition_allocator/ |
| D | spinning_mutex.cc | 55 int backoff = 1; in AcquireSpinThenBlock() local
|
| /external/grpc-grpc/test/core/util/ |
| D | reconnect_server.cc | 38 double expected_backoff = 1000.0, backoff; in pretty_print_backoffs() local
|
| /external/autotest/client/common_lib/cros/ |
| D | retry.py | 149 exception_to_raise=None, label=None, callback=None, backoff=1): argument
|
| /external/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-binance/ |
| D | policy.json | 7 "backoff": [1000, 2000, 3000, 4000, 5000], array
|
| /external/rust/crates/crossbeam-utils/src/atomic/ |
| D | seq_lock.rs | 48 let backoff = Backoff::new(); in write() localVariable
|
| D | seq_lock_wide.rs | 80 let backoff = Backoff::new(); in write() localVariable
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | client.cc | 212 int backoff = 1 << std::min(14, attempt); in Connect() local
497 int backoff = 1 << std::min(14, attempt); in Connect() local
|
| /external/rust/crates/crossbeam-deque/src/ |
| D | deque.rs | 1209 let backoff = Backoff::new(); in wait_write() localVariable
1238 let backoff = Backoff::new(); in wait_next() localVariable
1353 let backoff = Backoff::new(); in push() localVariable
1432 let backoff = Backoff::new(); in steal() localVariable
1568 let backoff = Backoff::new(); in steal_batch_with_limit() localVariable
1766 let backoff = Backoff::new(); in steal_batch_with_limit_and_pop() localVariable
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | frontend_wrappers.py | 32 def convert_timeout_to_retry(backoff, timeout_min, delay_sec): argument
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | reconnect_interop_server.cc | 130 double backoff = gpr_time_to_millis( in Verify() local
|