HomeSort by relevance Sort by last modified time
    Searched refs:retryPolicy (Results 1 - 8 of 8) sorted by null

  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
ServiceConfigInterceptor.java 135 final RetryPolicy retryPolicy;
165 retryPolicy = retryPolicyMap == null
166 ? RetryPolicy.DEFAULT : retryPolicy(retryPolicyMap, maxRetryAttemptsLimit);
177 timeoutNanos, waitForReady, maxInboundMessageSize, maxOutboundMessageSize, retryPolicy);
190 && Objects.equal(this.retryPolicy, that.retryPolicy);
200 .add("retryPolicy", retryPolicy)
    [all...]
ServiceConfigUtil.java 47 private static final String METHOD_CONFIG_RETRY_POLICY_KEY = "retryPolicy";
101 static Integer getMaxAttemptsFromRetryPolicy(Map<String, Object> retryPolicy) {
102 if (!retryPolicy.containsKey(RETRY_POLICY_MAX_ATTEMPTS_KEY)) {
105 return getDouble(retryPolicy, RETRY_POLICY_MAX_ATTEMPTS_KEY).intValue();
109 static Long getInitialBackoffNanosFromRetryPolicy(Map<String, Object> retryPolicy) {
110 if (!retryPolicy.containsKey(RETRY_POLICY_INITIAL_BACKOFF_KEY)) {
113 String rawInitialBackoff = getString(retryPolicy, RETRY_POLICY_INITIAL_BACKOFF_KEY);
122 static Long getMaxBackoffNanosFromRetryPolicy(Map<String, Object> retryPolicy) {
123 if (!retryPolicy.containsKey(RETRY_POLICY_MAX_BACKOFF_KEY)) {
126 String rawMaxBackoff = getString(retryPolicy, RETRY_POLICY_MAX_BACKOFF_KEY)
    [all...]
RetriableStream.java 67 private final RetryPolicy.Provider retryPolicyProvider;
69 private RetryPolicy retryPolicy;
101 RetryPolicy.Provider retryPolicyProvider, HedgingPolicy.Provider hedgingPolicyProvider,
588 if (retryPolicy == null) {
589 retryPolicy = retryPolicyProvider.get();
590 nextBackoffIntervalNanos = retryPolicy.initialBackoffNanos;
593 RetryPlan retryPlan = makeRetryDecision(retryPolicy, status, trailers);
636 private RetryPlan makeRetryDecision(RetryPolicy retryPolicy, Status status, Metadata trailer)
    [all...]
  /external/volley/src/main/java/com/android/volley/
Request.java 111 private RetryPolicy mRetryPolicy;
211 public Request<?> setRetryPolicy(RetryPolicy retryPolicy) {
212 mRetryPolicy = retryPolicy;
559 public RetryPolicy getRetryPolicy() {
  /external/volley/src/main/java/com/android/volley/toolbox/
BasicNetwork.java 30 import com.android.volley.RetryPolicy;
241 RetryPolicy retryPolicy = request.getRetryPolicy();
245 retryPolicy.retry(exception);
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
ManagedChannelImplTest.java     [all...]
RetriableStreamTest.java 107 private static final RetryPolicy RETRY_POLICY =
108 new RetryPolicy(
133 final RetryPolicy retryPolicy,
139 new RetryPolicy.Provider() {
141 public RetryPolicy get() {
142 return retryPolicy;
    [all...]
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 

Completed in 148 milliseconds