OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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