| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/retrying/ |
| D | ExponentialRetryAlgorithmTest.java | 76 TimedAttemptSettings attempt = algorithm.createFirstAttempt(); in testCreateFirstAttempt() local
89 TimedAttemptSettings attempt = algorithm.createFirstAttempt(retryingContext); in testCreateFirstAttemptOverride() local
156 TimedAttemptSettings attempt = algorithm.createFirstAttempt(); in testShouldRetryTrue() local
166 TimedAttemptSettings attempt = algorithm.createFirstAttempt(); in testShouldRetryFalseOnMaxAttempts() local
188 TimedAttemptSettings attempt = algorithm.createFirstAttempt(); in testShouldRetryFalseOnMaxTimeout() local
|
| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/ |
| D | StreamingRetryAlgorithmTest.java | 87 TimedAttemptSettings attempt = algorithm.createFirstAttempt(context); in testFirstAttemptUsesDefaultSettings() local
103 TimedAttemptSettings attempt = algorithm.createFirstAttempt(context); in testFirstAttemptUsesContextSettings() local
121 TimedAttemptSettings attempt = in testNextAttemptReturnsNullWhenShouldNotRetry() local
151 TimedAttemptSettings attempt = algorithm.createNextAttempt(context, exception, null, first); in testNextAttemptReturnsResultAlgorithmSettingsWhenShouldRetry() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Errors.kt | 95 return retryWhen { cause, attempt -> attempt < retries && predicate(cause) } in cause() method
133 var attempt = 0L in retryWhen() variable
|
| /external/skia/infra/bots/recipe_modules/flavor/ |
| D | android.py | 82 def _wait_for_device(self, title, attempt): argument
138 def wait_for_device(attempt): argument
225 def wait_for_device(attempt): argument
241 def wait_for_device(attempt): argument
|
| D | ios.py | 39 def sleep(attempt): argument
101 def uninstall_app(attempt): argument
|
| /external/aws-sdk-java-v2/test/test-utils/src/main/java/software/amazon/awssdk/testutils/ |
| D | Waiter.java | 126 int attempt = 0; in orFailAfter() local
166 private void wait(int attempt) { in wait()
|
| /external/clang/test/CodeGenCXX/ |
| D | windows-itanium-exceptions.cpp | 9 void attempt() { in attempt() function
|
| /external/perfetto/src/tracing/core/ |
| D | shared_memory_abi.cc | 34 inline void WaitBeforeNextAttempt(int attempt) { in WaitBeforeNextAttempt()
162 for (int attempt = 0; attempt < kRetryAttempts; attempt++) { in TryAcquireChunk() local
240 for (int attempt = 0; attempt < kRetryAttempts; attempt++) { in ReleaseChunk() local
|
| /external/skia/infra/bots/recipe_modules/run/examples/ |
| D | full.py | 46 def between_attempts_fn(attempt): argument
|
| /external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/ |
| D | AssertByPollingTest.java | 72 AtomicInteger attempt = new AtomicInteger(1); in testSucceedsAfterInitialFailure() local
|
| /external/perfetto/src/profiling/memory/ |
| D | scoped_spinlock.cc | 49 for (size_t attempt = 1; mode == Mode::Blocking || in LockSlow() local
|
| /external/cronet/net/dns/ |
| D | dns_transaction.cc | 1104 const DnsAttempt* attempt = in ProbeComplete() local
1256 raw_ptr<const DnsAttempt, AcrossTasksDanglingUntriaged> attempt; member
1417 DnsAttempt* attempt = attempts_.back().get(); in MakeUdpAttempt() local
1439 DnsAttempt* attempt = attempts_.back().get(); in MakeHTTPAttempt() local
1512 DnsAttempt* attempt = attempts_.back().get(); in MakeTcpAttempt() local
1554 const DnsAttempt* attempt = attempts_[attempt_number].get(); in OnAttemptComplete() local
1567 void LogResponse(const DnsAttempt* attempt) { in LogResponse()
1700 [](std::unique_ptr<DnsAttempt>& attempt) { in AnyAttemptPending()
|
| /external/cronet/net/http/ |
| D | http_stream_request.cc | 78 for (const auto& attempt : attempts) in AddConnectionAttempts() local
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/ |
| D | CallbackChainRetryingFuture.java | 137 ApiFuture<ResponseT> attempt = retryingExecutor.submit(CallbackChainRetryingFuture.this); in handle() local
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | connection_attempt_injector.cc | 233 std::unique_ptr<QueuedAttempt> attempt; in Resume() local
244 std::unique_ptr<QueuedAttempt> attempt; in Fail() local
|
| /external/perfetto/src/kallsyms/ |
| D | lazy_kernel_symbolizer.cc | 100 for (int attempt = 1; attempt <= 50; ++attempt) { in ScopedKptrUnrestrict() local
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | client.cc | 194 int attempt = 0; in Connect() local
477 int attempt = 0; in Connect() local
|
| /external/python/absl-py/absl/flags/ |
| D | _helpers.py | 172 def get_flag_suggestions(attempt, longopt_list): argument
|
| /external/deqp-deps/SPIRV-Tools/source/fuzz/ |
| D | shrinker.cpp | 138 uint32_t attempt = 0; // Keeps track of the number of shrink attempts that in Run() local
|
| /external/angle/third_party/spirv-tools/src/source/fuzz/ |
| D | shrinker.cpp | 138 uint32_t attempt = 0; // Keeps track of the number of shrink attempts that in Run() local
|
| /external/swiftshader/third_party/SPIRV-Tools/source/fuzz/ |
| D | shrinker.cpp | 138 uint32_t attempt = 0; // Keeps track of the number of shrink attempts that in Run() local
|
| /external/sdv/vsomeip/third_party/boost/range/test/algorithm_test/ |
| D | random_shuffle.cpp | 98 for (int attempt = 0; !shuffled && (attempt < MAX_RETRIES); ++attempt) in test_random_shuffle_nogen_impl() local
|
| /external/mbedtls/library/ |
| D | rsa_alt_helpers.c | 56 uint16_t attempt; /* Number of current attempt */ in mbedtls_rsa_deduce_primes() local
|
| /external/openthread/third_party/mbedtls/repo/library/ |
| D | rsa_internal.c | 56 uint16_t attempt; /* Number of current attempt */ in mbedtls_rsa_deduce_primes() local
|
| /external/tensorflow/tensorflow/core/lib/io/snappy/ |
| D | snappy_test.cc | 144 for (int attempt = 0; attempt < 2; ++attempt) { in TestMultipleWrites() local
182 for (int attempt = 0; attempt < 2; ++attempt) { in TestMultipleWritesInputStream() local
|