Home
last modified time | relevance | path

Searched refs:backoff (Results 1 – 25 of 67) sorted by relevance

123

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAtomicBackoffTest.java35 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/
Dbackoff_test.cc45 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/syzkaller/vendor/google.golang.org/grpc/internal/backoff/
Dbackoff.go23 package backoff package
63 backoff, max := float64(baseDelay), float64(bc.MaxDelay)
64 for backoff < max && retries > 0 {
65 backoff *= factor
68 if backoff > max {
69 backoff = max
73 backoff *= 1 + jitter*(grpcrand.Float64()*2-1)
74 if backoff < 0 {
77 return time.Duration(backoff)
/external/autotest/server/cros/dynamic_suite/
Dfrontend_wrappers_unittest.py22 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,
Dfrontend_wrappers.py31 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/swiftshader/src/Reactor/
DMutexLock.hpp89 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/swiftshader/src/Common/
DMutexLock.hpp89 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/swiftshader/src/System/
DMutexLock.hpp89 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/ltp/tools/genload/
Dstress.c475 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 …]
Dgenload.c475 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/syzkaller/vendor/google.golang.org/api/gensupport/
Dresumable.go161 backoff := rx.Backoff
162 if backoff == nil {
163 backoff = DefaultBackoffStrategy()
187 pause, retry = backoff.Pause()
200 backoff.Reset()
Dretry.go28 func Retry(ctx context.Context, f func() (*http.Response, error), backoff BackoffStrategy) (*http.R…
38 pause, retry := backoff.Pause()
/external/autotest/client/site_tests/autoupdate_Backoff/
Dautoupdate_Backoff.py43 def run_once(self, image_url, image_size, sha256, backoff): argument
53 backoff=backoff, num_urls=1)
66 if backoff:
Dcontrol8 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.'
/external/autotest/server/site_tests/autoupdate_OmahaResponse/
Dcontrol.local21 test_backoff: tests that we do/dont backoff when an update fails.
22 backoff: True if we should backoff. False otherwise.
34 bad_metadata_size=False, test_backoff=True, backoff=True,
Dcontrol.backoff_disabled.full8 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)
Dautoupdate_OmahaResponse.py23 bad_metadata_size=False, test_backoff=False, backoff=False): argument
61 backoff=backoff)
Dcontrol.backoff_enabled.full7 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)
/external/compiler-rt/lib/tsan/rtl/
Dtsan_mutex.cc235 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/grpc-grpc/test/core/util/
Dreconnect_server.cc38 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/
Dreconnect_interop_server.cc130 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/syzkaller/vendor/github.com/googleapis/gax-go/
Dcall_option.go73 backoff: bo,
79 backoff Backoff member
91 return r.backoff.Pause(), true
/external/tensorflow/tensorflow/lite/models/smartreply/demo/app/src/main/java/com/example/android/smartreply/
DSmartReplyClient.java62 String[] backoff = loadBackoffList(); in loadModel() local
63 storage = loadJNI(model, backoff); in loadModel()
119 private native long loadJNI(MappedByteBuffer buffer, String[] backoff); in loadJNI() argument
/external/curl/docs/cmdline-opts/
Dretry-delay.d7 failed with a transient error (it changes the default backoff time algorithm
9 used. Setting this delay to zero will make curl use the default backoff time.
/external/grpc-grpc/doc/
Dconnection-backoff.md6 requests) and instead do some form of exponential backoff.
10 1. MULTIPLIER (factor with which to multiply backoff after a failed retry)
12 1. MAX_BACKOFF (upper bound on backoff)

123