Home
last modified time | relevance | path

Searched refs:RetryPolicy (Results 1 – 16 of 16) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DRetryPolicy.java33 final class RetryPolicy { class
41 static final RetryPolicy DEFAULT =
42 new RetryPolicy(1, 0, 0, 1, Collections.<Status.Code>emptySet());
48 RetryPolicy( in RetryPolicy() method in RetryPolicy
73 if (!(other instanceof RetryPolicy)) { in equals()
76 RetryPolicy that = (RetryPolicy) other; in equals()
103 RetryPolicy get(); in get()
DServiceConfigInterceptor.java135 final RetryPolicy retryPolicy;
166 ? RetryPolicy.DEFAULT : retryPolicy(retryPolicyMap, maxRetryAttemptsLimit); in MethodInfo()
205 private static RetryPolicy retryPolicy(Map<String, Object> retryPolicy, int maxAttemptsLimit) { in retryPolicy()
246 return new RetryPolicy( in retryPolicy()
282 static final CallOptions.Key<RetryPolicy.Provider> RETRY_POLICY_KEY =
293 final RetryPolicy retryPolicy = getRetryPolicyFromConfig(method); in interceptCall()
294 final class ImmediateRetryPolicyProvider implements RetryPolicy.Provider { in interceptCall()
296 public RetryPolicy get() { in interceptCall()
310 retryPolicy.equals(RetryPolicy.DEFAULT) || hedgingPolicy.equals(HedgingPolicy.DEFAULT), in interceptCall()
317 final class DelayedRetryPolicyProvider implements RetryPolicy.Provider { in interceptCall()
[all …]
DRetriableStream.java67 private final RetryPolicy.Provider retryPolicyProvider;
69 private RetryPolicy retryPolicy;
101 RetryPolicy.Provider retryPolicyProvider, HedgingPolicy.Provider hedgingPolicyProvider, in RetriableStream()
636 private RetryPlan makeRetryDecision(RetryPolicy retryPolicy, Status status, Metadata trailer) { in makeRetryDecision()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetryPolicyTest.java74 RetryPolicy.DEFAULT, in getRetryPolicies()
79 RetryPolicy.DEFAULT, in getRetryPolicies()
85 new RetryPolicy( in getRetryPolicies()
95 new RetryPolicy( in getRetryPolicies()
105 RetryPolicy.DEFAULT, in getRetryPolicies()
110 new RetryPolicy( in getRetryPolicies()
DRetriableStreamTest.java107 private static final RetryPolicy RETRY_POLICY =
108 new RetryPolicy(
133 final RetryPolicy retryPolicy, in RecordedRetriableStream()
139 new RetryPolicy.Provider() { in RecordedRetriableStream()
141 public RetryPolicy get() { in RecordedRetriableStream()
DServiceConfigInterceptorTest.java111 .isEqualTo(RetryPolicy.DEFAULT); in handleUpdateNotCalledBeforeInterceptCall()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dmethod_params.h41 struct RetryPolicy { struct
56 const RetryPolicy* retry_policy() const { return retry_policy_.get(); } in retry_policy() argument
72 UniquePtr<RetryPolicy> retry_policy_;
Dmethod_params.cc84 UniquePtr<ClientChannelMethodParams::RetryPolicy> ParseRetryPolicy( in ParseRetryPolicy()
86 auto retry_policy = MakeUnique<ClientChannelMethodParams::RetryPolicy>(); in ParseRetryPolicy()
Dclient_channel.cc1389 const ClientChannelMethodParams::RetryPolicy* retry_policy = in do_retry()
1441 const ClientChannelMethodParams::RetryPolicy* retry_policy = in maybe_retry()
/external/volley/src/test/java/com/android/volley/toolbox/
DRequestTest.java26 import com.android.volley.RetryPolicy;
47 assertNotNull(Request.class.getMethod("setRetryPolicy", RetryPolicy.class)); in publicMethods()
DHttpStackConformanceTest.java13 import com.android.volley.RetryPolicy;
39 @Mock private RetryPolicy mMockRetryPolicy;
DBasicNetworkTest.java35 import com.android.volley.RetryPolicy;
61 @Mock private RetryPolicy mMockRetryPolicy;
/external/volley/src/main/java/com/android/volley/
DRequest.java111 private RetryPolicy mRetryPolicy;
211 public Request<?> setRetryPolicy(RetryPolicy retryPolicy) { in setRetryPolicy()
559 public RetryPolicy getRetryPolicy() { in getRetryPolicy()
DRetryPolicy.java40 public interface RetryPolicy { interface
DDefaultRetryPolicy.java20 public class DefaultRetryPolicy implements RetryPolicy {
/external/volley/src/main/java/com/android/volley/toolbox/
DBasicNetwork.java30 import com.android.volley.RetryPolicy;
241 RetryPolicy retryPolicy = request.getRetryPolicy(); in attemptRetryOnException()