Home
last modified time | relevance | path

Searched defs:attempt (Results 1 – 25 of 93) sorted by relevance

1234

/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/retrying/
DExponentialRetryAlgorithmTest.java76 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/
DStreamingRetryAlgorithmTest.java87 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/
DErrors.kt91 return retryWhen { cause, attempt -> attempt < retries && predicate(cause) } in cause() method
129 var attempt = 0L in retryWhen() variable
/external/skia/infra/bots/recipe_modules/flavor/
Dandroid.py98 def _wait_for_device(self, title, attempt): argument
154 def wait_for_device(attempt): argument
244 def wait_for_device(attempt): argument
260 def wait_for_device(attempt): argument
Dios.py39 def sleep(attempt): argument
110 def uninstall_app(attempt): argument
/external/aws-sdk-java-v2/test/test-utils/src/main/java/software/amazon/awssdk/testutils/
DWaiter.java126 int attempt = 0; in orFailAfter() local
166 private void wait(int attempt) { in wait()
/external/clang/test/CodeGenCXX/
Dwindows-itanium-exceptions.cpp9 void attempt() { in attempt() function
/external/perfetto/src/tracing/core/
Dshared_memory_abi.cc34 inline void WaitBeforeNextAttempt(int attempt) { in WaitBeforeNextAttempt()
163 for (int attempt = 0; attempt < kRetryAttempts; attempt++) { in TryAcquireChunk() local
243 for (int attempt = 0; attempt < kRetryAttempts; attempt++) { in ReleaseChunk() local
/external/pytorch/aten/src/ATen/cuda/
DCUDAGraphsUtils.cuh30 inline void assertNotCapturing(const std::string& attempt) { in assertNotCapturing()
/external/skia/infra/bots/recipe_modules/run/examples/
Dfull.py46 def between_attempts_fn(attempt): argument
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/
DAssertByPollingTest.java72 AtomicInteger attempt = new AtomicInteger(1); in testSucceedsAfterInitialFailure() local
/external/perfetto/src/profiling/memory/
Dscoped_spinlock.cc49 for (size_t attempt = 1; mode == Mode::Blocking || in LockSlow() local
/external/cronet/tot/net/dns/
Ddns_transaction.cc1108 const DnsAttempt* attempt = in ProbeComplete() local
1263 raw_ptr<const DnsAttempt, AcrossTasksDanglingUntriaged> attempt; member
1424 DnsAttempt* attempt = attempts_.back().get(); in MakeUdpAttempt() local
1446 DnsAttempt* attempt = attempts_.back().get(); in MakeHTTPAttempt() local
1519 DnsAttempt* attempt = attempts_.back().get(); in MakeTcpAttempt() local
1561 const DnsAttempt* attempt = attempts_[attempt_number].get(); in OnAttemptComplete() local
1574 void LogResponse(const DnsAttempt* attempt) { in LogResponse()
1707 [](std::unique_ptr<DnsAttempt>& attempt) { in AnyAttemptPending()
/external/cronet/stable/net/dns/
Ddns_transaction.cc1108 const DnsAttempt* attempt = in ProbeComplete() local
1263 raw_ptr<const DnsAttempt, AcrossTasksDanglingUntriaged> attempt; member
1424 DnsAttempt* attempt = attempts_.back().get(); in MakeUdpAttempt() local
1446 DnsAttempt* attempt = attempts_.back().get(); in MakeHTTPAttempt() local
1519 DnsAttempt* attempt = attempts_.back().get(); in MakeTcpAttempt() local
1561 const DnsAttempt* attempt = attempts_[attempt_number].get(); in OnAttemptComplete() local
1574 void LogResponse(const DnsAttempt* attempt) { in LogResponse()
1707 [](std::unique_ptr<DnsAttempt>& attempt) { in AnyAttemptPending()
/external/cronet/stable/net/http/
Dhttp_stream_pool_attempt_manager.cc94 int Start(std::unique_ptr<StreamAttempt> attempt) { in Start()
111 StreamAttempt* attempt() { return attempt_.get(); } in attempt() function in net::HttpStreamPool::AttemptManager::InFlightAttempt
394 HttpStreamPool::AttemptManager::GetSSLConfig(InFlightAttempt* attempt) { in GetSSLConfig()
453 for (auto& attempt : in_flight_attempts_) { in CancelInFlightAttempts() local
1022 std::unique_ptr<StreamAttempt> attempt; in MaybeAttemptConnection() local
1479 std::unique_ptr<InFlightAttempt> attempt = std::move( in RemoveJobFromQueue() local
Dhttp_stream_request.cc75 for (const auto& attempt : attempts) { in AddConnectionAttempts() local
Dhttp_stream_pool_job.cc96 for (const auto& attempt : attempts) { in AddConnectionAttempts() local
/external/cronet/tot/net/http/
Dhttp_stream_pool_attempt_manager.cc94 int Start(std::unique_ptr<StreamAttempt> attempt) { in Start()
111 StreamAttempt* attempt() { return attempt_.get(); } in attempt() function in net::HttpStreamPool::AttemptManager::InFlightAttempt
394 HttpStreamPool::AttemptManager::GetSSLConfig(InFlightAttempt* attempt) { in GetSSLConfig()
453 for (auto& attempt : in_flight_attempts_) { in CancelInFlightAttempts() local
1022 std::unique_ptr<StreamAttempt> attempt; in MaybeAttemptConnection() local
1479 std::unique_ptr<InFlightAttempt> attempt = std::move( in RemoveJobFromQueue() local
Dhttp_stream_request.cc75 for (const auto& attempt : attempts) { in AddConnectionAttempts() local
Dhttp_stream_pool_job.cc96 for (const auto& attempt : attempts) { in AddConnectionAttempts() local
/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/
DCallbackChainRetryingFuture.java137 ApiFuture<ResponseT> attempt = retryingExecutor.submit(CallbackChainRetryingFuture.this); in handle() local
/external/grpc-grpc/test/cpp/end2end/
Dconnection_attempt_injector.cc233 std::unique_ptr<QueuedAttempt> attempt; in Resume() local
244 std::unique_ptr<QueuedAttempt> attempt; in Fail() local
/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dclient.cc194 int attempt = 0; in Connect() local
477 int attempt = 0; in Connect() local
/external/deqp-deps/SPIRV-Tools/source/fuzz/
Dshrinker.cpp138 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/
Dshrinker.cpp138 uint32_t attempt = 0; // Keeps track of the number of shrink attempts that in Run() local

1234