| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | RetryPolicy.java | 33 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()
|
| D | ServiceConfigInterceptor.java | 135 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 …]
|
| D | RetriableStream.java | 67 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/src/core/ext/filters/client_channel/ |
| D | method_params.h | 41 struct RetryPolicy { struct
56 const RetryPolicy* retry_policy() const { return retry_policy_.get(); } in retry_policy() argument
72 UniquePtr<RetryPolicy> retry_policy_;
|
| D | method_params.cc | 84 UniquePtr<ClientChannelMethodParams::RetryPolicy> ParseRetryPolicy( in ParseRetryPolicy()
86 auto retry_policy = MakeUnique<ClientChannelMethodParams::RetryPolicy>(); in ParseRetryPolicy()
|
| D | client_channel.cc | 1389 const ClientChannelMethodParams::RetryPolicy* retry_policy = in do_retry()
1441 const ClientChannelMethodParams::RetryPolicy* retry_policy = in maybe_retry()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | resolver_result_parsing.h | 84 struct RetryPolicy { struct
94 std::unique_ptr<RetryPolicy> retry_policy) in ClientChannelMethodParsedConfig() argument
103 const RetryPolicy* retry_policy() const { return retry_policy_.get(); } in retry_policy()
108 std::unique_ptr<RetryPolicy> retry_policy_;
|
| D | resolver_result_parsing.cc | 66 std::unique_ptr<ClientChannelMethodParsedConfig::RetryPolicy> ParseRetryPolicy( in ParseRetryPolicy()
70 absl::make_unique<ClientChannelMethodParsedConfig::RetryPolicy>(); in ParseRetryPolicy()
363 std::unique_ptr<ClientChannelMethodParsedConfig::RetryPolicy> retry_policy; in ParsePerMethodParams()
|
| D | client_channel.cc | 546 const ClientChannelMethodParsedConfig::RetryPolicy* retry_policy);
830 const ClientChannelMethodParsedConfig::RetryPolicy* retry_policy_ = nullptr;
3225 const ClientChannelMethodParsedConfig::RetryPolicy* retry_policy) in RetryingCall()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | RetryPolicyTest.java | 74 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()
|
| D | RetriableStreamTest.java | 107 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()
|
| D | ServiceConfigInterceptorTest.java | 111 .isEqualTo(RetryPolicy.DEFAULT); in handleUpdateNotCalledBeforeInterceptCall()
|
| /external/volley/src/test/java/com/android/volley/toolbox/ |
| D | RequestTest.java | 26 import com.android.volley.RetryPolicy;
47 assertNotNull(Request.class.getMethod("setRetryPolicy", RetryPolicy.class)); in publicMethods()
|
| D | HttpStackConformanceTest.java | 13 import com.android.volley.RetryPolicy;
39 @Mock private RetryPolicy mMockRetryPolicy;
|
| D | BasicNetworkTest.java | 36 import com.android.volley.RetryPolicy;
62 @Mock private RetryPolicy mMockRetryPolicy;
|
| D | BasicAsyncNetworkTest.java | 38 import com.android.volley.RetryPolicy;
67 @Mock private RetryPolicy mMockRetryPolicy;
|
| /external/volley/src/main/java/com/android/volley/ |
| D | RetryPolicy.java | 40 public interface RetryPolicy { interface
|
| D | Request.java | 114 private RetryPolicy mRetryPolicy;
214 public Request<?> setRetryPolicy(RetryPolicy retryPolicy) { in setRetryPolicy()
584 public RetryPolicy getRetryPolicy() { in getRetryPolicy()
|
| D | DefaultRetryPolicy.java | 20 public class DefaultRetryPolicy implements RetryPolicy {
|
| /external/volley/src/main/java/com/android/volley/toolbox/ |
| D | NetworkUtility.java | 29 import com.android.volley.RetryPolicy;
123 final RetryPolicy retryPolicy = request.getRetryPolicy(); in attemptRetryOnException()
|