| /aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/retrying/ |
| H A D | BasicRetryingFutureTest.java | 67 RetryAlgorithm<Integer> retryAlgorithm = mock(RetryAlgorithm.class); in testHandleAttemptDoesNotThrowNPEWhenLogLevelLowerThanFiner() local
74 Mockito.when(retryAlgorithm.createFirstAttempt(ArgumentMatchers.<RetryingContext>any())) in testHandleAttemptDoesNotThrowNPEWhenLogLevelLowerThanFiner()
77 retryAlgorithm.createNextAttempt( in testHandleAttemptDoesNotThrowNPEWhenLogLevelLowerThanFiner()
84 retryAlgorithm.shouldRetry( in testHandleAttemptDoesNotThrowNPEWhenLogLevelLowerThanFiner()
94 new BasicRetryingFuture<>(callable, retryAlgorithm, retryingContext); in testHandleAttemptDoesNotThrowNPEWhenLogLevelLowerThanFiner()
108 RetryAlgorithm<Integer> retryAlgorithm = mock(RetryAlgorithm.class); in testUsesRetryingContext() local
114 Mockito.when(retryAlgorithm.createFirstAttempt(retryingContext)) in testUsesRetryingContext()
117 retryAlgorithm.createNextAttempt( in testUsesRetryingContext()
124 retryAlgorithm.shouldRetry( in testUsesRetryingContext()
132 new BasicRetryingFuture<>(callable, retryAlgorithm, retryingContext); in testUsesRetryingContext()
[all …]
|
| H A D | ScheduledRetryingExecutorTest.java | 63 protected RetryingExecutorWithContext<String> getExecutor(RetryAlgorithm<String> retryAlgorithm) { in getExecutor() argument
64 return getRetryingExecutor(retryAlgorithm, scheduler); in getExecutor()
76 RetryAlgorithm<String> retryAlgorithm, ScheduledExecutorService scheduler) { in getRetryingExecutor() argument
77 return new ScheduledRetryingExecutor<>(retryAlgorithm, scheduler); in getRetryingExecutor()
|
| H A D | DirectRetryingExecutorTest.java | 40 protected RetryingExecutorWithContext<String> getExecutor(RetryAlgorithm<String> retryAlgorithm) { in getExecutor() argument
41 return new DirectRetryingExecutor<>(retryAlgorithm); in getExecutor()
|
| H A D | AbstractRetryingExecutorTest.java | 88 RetryAlgorithm<String> retryAlgorithm); in getExecutor() argument
306 RetryAlgorithm<String> retryAlgorithm =
313 RetryingExecutorWithContext<String> executor = getExecutor(retryAlgorithm);
|
| /aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/ |
| H A D | BasicRetryingFuture.java | 62 private final RetryAlgorithm<ResponseT> retryAlgorithm; field in BasicRetryingFuture
74 RetryAlgorithm<ResponseT> retryAlgorithm, in BasicRetryingFuture() argument
77 this.retryAlgorithm = checkNotNull(retryAlgorithm); in BasicRetryingFuture()
80 this.attemptSettings = retryAlgorithm.createFirstAttempt(context); in BasicRetryingFuture()
171 retryAlgorithm.createNextAttempt(retryingContext, throwable, response, attemptSettings); in handleAttempt()
173 retryAlgorithm.shouldRetry(retryingContext, throwable, response, nextAttemptSettings); in handleAttempt()
195 if (retryAlgorithm.shouldRetryBasedOnResult(retryingContext, throwable, response)) { in handleAttempt()
|
| H A D | ScheduledRetryingExecutor.java | 60 private final RetryAlgorithm<ResponseT> retryAlgorithm; field in ScheduledRetryingExecutor
71 RetryAlgorithm<ResponseT> retryAlgorithm, ScheduledExecutorService scheduler) { in ScheduledRetryingExecutor() argument
72 this.retryAlgorithm = retryAlgorithm; in ScheduledRetryingExecutor()
102 return new CallbackChainRetryingFuture<>(callable, retryAlgorithm, this, context); in createFuture()
|
| H A D | DirectRetryingExecutor.java | 51 private final RetryAlgorithm<ResponseT> retryAlgorithm; field in DirectRetryingExecutor
60 public DirectRetryingExecutor(RetryAlgorithm<ResponseT> retryAlgorithm) { in DirectRetryingExecutor() argument
61 this.retryAlgorithm = checkNotNull(retryAlgorithm); in DirectRetryingExecutor()
86 return new BasicRetryingFuture<>(callable, retryAlgorithm, context); in createFuture()
|
| H A D | CallbackChainRetryingFuture.java | 60 RetryAlgorithm<ResponseT> retryAlgorithm, in CallbackChainRetryingFuture() argument
63 super(callable, retryAlgorithm, context); in CallbackChainRetryingFuture()
|
| /aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/ |
| H A D | Callables.java | 70 RetryAlgorithm<ResponseT> retryAlgorithm = in retrying() local
75 new ScheduledRetryingExecutor<>(retryAlgorithm, clientContext.getExecutor()); in retrying()
95 StreamingRetryAlgorithm<Void> retryAlgorithm = in retrying() local
101 new ScheduledRetryingExecutor<>(retryAlgorithm, clientContext.getExecutor()); in retrying()
|
| /aosp_15_r20/external/sdk-platform-java/java-core/google-cloud-core/src/main/java/com/google/cloud/ |
| H A D | RetryHelper.java | 72 RetryAlgorithm<V> retryAlgorithm = new RetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in run() local
73 RetryingExecutor<V> executor = new DirectRetryingExecutor<>(retryAlgorithm); in run()
|