Home
last modified time | relevance | path

Searched refs:retryPolicy (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServiceConfigInterceptor.java135 final RetryPolicy retryPolicy; field in ServiceConfigInterceptor.MethodInfo
165 retryPolicy = retryPolicyMap == null in MethodInfo()
166 ? RetryPolicy.DEFAULT : retryPolicy(retryPolicyMap, maxRetryAttemptsLimit); in MethodInfo()
177 timeoutNanos, waitForReady, maxInboundMessageSize, maxOutboundMessageSize, retryPolicy); in hashCode()
190 && Objects.equal(this.retryPolicy, that.retryPolicy); in equals()
200 .add("retryPolicy", retryPolicy) in toString()
205 private static RetryPolicy retryPolicy(Map<String, Object> retryPolicy, int maxAttemptsLimit) { in retryPolicy() argument
207 ServiceConfigUtil.getMaxAttemptsFromRetryPolicy(retryPolicy), in retryPolicy()
213 ServiceConfigUtil.getInitialBackoffNanosFromRetryPolicy(retryPolicy), in retryPolicy()
221 ServiceConfigUtil.getMaxBackoffNanosFromRetryPolicy(retryPolicy), in retryPolicy()
[all …]
DServiceConfigUtil.java101 static Integer getMaxAttemptsFromRetryPolicy(Map<String, Object> retryPolicy) { in getMaxAttemptsFromRetryPolicy() argument
102 if (!retryPolicy.containsKey(RETRY_POLICY_MAX_ATTEMPTS_KEY)) { in getMaxAttemptsFromRetryPolicy()
105 return getDouble(retryPolicy, RETRY_POLICY_MAX_ATTEMPTS_KEY).intValue(); in getMaxAttemptsFromRetryPolicy()
109 static Long getInitialBackoffNanosFromRetryPolicy(Map<String, Object> retryPolicy) { in getInitialBackoffNanosFromRetryPolicy() argument
110 if (!retryPolicy.containsKey(RETRY_POLICY_INITIAL_BACKOFF_KEY)) { in getInitialBackoffNanosFromRetryPolicy()
113 String rawInitialBackoff = getString(retryPolicy, RETRY_POLICY_INITIAL_BACKOFF_KEY); in getInitialBackoffNanosFromRetryPolicy()
122 static Long getMaxBackoffNanosFromRetryPolicy(Map<String, Object> retryPolicy) { in getMaxBackoffNanosFromRetryPolicy() argument
123 if (!retryPolicy.containsKey(RETRY_POLICY_MAX_BACKOFF_KEY)) { in getMaxBackoffNanosFromRetryPolicy()
126 String rawMaxBackoff = getString(retryPolicy, RETRY_POLICY_MAX_BACKOFF_KEY); in getMaxBackoffNanosFromRetryPolicy()
135 static Double getBackoffMultiplierFromRetryPolicy(Map<String, Object> retryPolicy) { in getBackoffMultiplierFromRetryPolicy() argument
[all …]
DRetriableStream.java69 private RetryPolicy retryPolicy; field in RetriableStream
588 if (retryPolicy == null) { in closed()
589 retryPolicy = retryPolicyProvider.get(); in closed()
590 nextBackoffIntervalNanos = retryPolicy.initialBackoffNanos; in closed()
593 RetryPlan retryPlan = makeRetryDecision(retryPolicy, status, trailers); in closed()
636 private RetryPlan makeRetryDecision(RetryPolicy retryPolicy, Status status, Metadata trailer) { in makeRetryDecision() argument
639 boolean isRetryableStatusCode = retryPolicy.retryableStatusCodes.contains(status.getCode()); in makeRetryDecision()
658 if (retryPolicy.maxAttempts > substream.previousAttempts + 1 && !isThrottled) { in makeRetryDecision()
664 (long) (nextBackoffIntervalNanos * retryPolicy.backoffMultiplier), in makeRetryDecision()
665 retryPolicy.maxBackoffNanos); in makeRetryDecision()
[all …]
/external/volley/src/main/java/com/android/volley/toolbox/
DBasicNetwork.java241 RetryPolicy retryPolicy = request.getRetryPolicy(); in attemptRetryOnException() local
245 retryPolicy.retry(exception); in attemptRetryOnException()
/external/volley/src/main/java/com/android/volley/
DRequest.java211 public Request<?> setRetryPolicy(RetryPolicy retryPolicy) { in setRetryPolicy() argument
212 mRetryPolicy = retryPolicy; in setRetryPolicy()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplTest.java2601 Map<String, Object> retryPolicy = new HashMap<String, Object>(); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail() local
2602 retryPolicy.put("maxAttempts", 3D); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2603 retryPolicy.put("initialBackoff", "10s"); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2604 retryPolicy.put("maxBackoff", "30s"); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2605 retryPolicy.put("backoffMultiplier", 2D); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2606 retryPolicy.put("retryableStatusCodes", Arrays.<Object>asList("UNAVAILABLE")); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
2611 methodConfig.put("retryPolicy", retryPolicy); in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
DRetriableStreamTest.java133 final RetryPolicy retryPolicy, in RecordedRetriableStream() argument
142 return retryPolicy; in RecordedRetriableStream()