Home
last modified time | relevance | path

Searched refs:hedgingPolicy (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServiceConfigInterceptor.java136 final HedgingPolicy hedgingPolicy; field in ServiceConfigInterceptor.MethodInfo
170 hedgingPolicy = hedgingPolicyMap == null in MethodInfo()
171 ? HedgingPolicy.DEFAULT : hedgingPolicy(hedgingPolicyMap, maxHedgedAttemptsLimit); in MethodInfo()
253 private static HedgingPolicy hedgingPolicy( in hedgingPolicy() method in ServiceConfigInterceptor
254 Map<String, Object> hedgingPolicy, int maxAttemptsLimit) { in hedgingPolicy() argument
256 ServiceConfigUtil.getMaxAttemptsFromHedgingPolicy(hedgingPolicy), in hedgingPolicy()
262 ServiceConfigUtil.getHedgingDelayNanosFromHedgingPolicy(hedgingPolicy), in hedgingPolicy()
268 ServiceConfigUtil.getNonFatalStatusCodesFromHedgingPolicy(hedgingPolicy); in hedgingPolicy()
301 final HedgingPolicy hedgingPolicy = getHedgingPolicyFromConfig(method); in interceptCall() local
305 return hedgingPolicy; in interceptCall()
[all …]
DServiceConfigUtil.java151 static Integer getMaxAttemptsFromHedgingPolicy(Map<String, Object> hedgingPolicy) { in getMaxAttemptsFromHedgingPolicy() argument
152 if (!hedgingPolicy.containsKey(HEDGING_POLICY_MAX_ATTEMPTS_KEY)) { in getMaxAttemptsFromHedgingPolicy()
155 return getDouble(hedgingPolicy, RETRY_POLICY_MAX_ATTEMPTS_KEY).intValue(); in getMaxAttemptsFromHedgingPolicy()
159 static Long getHedgingDelayNanosFromHedgingPolicy(Map<String, Object> hedgingPolicy) { in getHedgingDelayNanosFromHedgingPolicy() argument
160 if (!hedgingPolicy.containsKey(HEDGING_POLICY_HEDGING_DELAY_KEY)) { in getHedgingDelayNanosFromHedgingPolicy()
163 String rawHedgingDelay = getString(hedgingPolicy, HEDGING_POLICY_HEDGING_DELAY_KEY); in getHedgingDelayNanosFromHedgingPolicy()
172 static List<String> getNonFatalStatusCodesFromHedgingPolicy(Map<String, Object> hedgingPolicy) { in getNonFatalStatusCodesFromHedgingPolicy() argument
173 if (!hedgingPolicy.containsKey(HEDGING_POLICY_NON_FATAL_STATUS_CODES_KEY)) { in getNonFatalStatusCodesFromHedgingPolicy()
176 return checkStringList(getList(hedgingPolicy, HEDGING_POLICY_NON_FATAL_STATUS_CODES_KEY)); in getNonFatalStatusCodesFromHedgingPolicy()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java134 final HedgingPolicy hedgingPolicy, in RecordedRetriableStream() argument
148 return hedgingPolicy; in RecordedRetriableStream()