Home
last modified time | relevance | path

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

/external/grpc-grpc/src/core/ext/filters/client_channel/
Dmethod_params.cc86 auto retry_policy = MakeUnique<ClientChannelMethodParams::RetryPolicy>(); in ParseRetryPolicy() local
92 if (retry_policy->max_attempts != 0) return nullptr; // Duplicate. in ParseRetryPolicy()
94 retry_policy->max_attempts = gpr_parse_nonnegative_int(sub_field->value); in ParseRetryPolicy()
95 if (retry_policy->max_attempts <= 1) return nullptr; in ParseRetryPolicy()
96 if (retry_policy->max_attempts > MAX_MAX_RETRY_ATTEMPTS) { in ParseRetryPolicy()
100 retry_policy->max_attempts = MAX_MAX_RETRY_ATTEMPTS; in ParseRetryPolicy()
103 if (retry_policy->initial_backoff > 0) return nullptr; // Duplicate. in ParseRetryPolicy()
104 if (!ParseDuration(sub_field, &retry_policy->initial_backoff)) { in ParseRetryPolicy()
107 if (retry_policy->initial_backoff == 0) return nullptr; in ParseRetryPolicy()
109 if (retry_policy->max_backoff > 0) return nullptr; // Duplicate. in ParseRetryPolicy()
[all …]
Dmethod_params.h56 const RetryPolicy* retry_policy() const { return retry_policy_.get(); } in retry_policy() function
Dclient_channel.cc1389 const ClientChannelMethodParams::RetryPolicy* retry_policy = in do_retry() local
1390 calld->method_params->retry_policy(); in do_retry()
1391 GPR_ASSERT(retry_policy != nullptr); in do_retry()
1411 .set_initial_backoff(retry_policy->initial_backoff) in do_retry()
1412 .set_multiplier(retry_policy->backoff_multiplier) in do_retry()
1414 .set_max_backoff(retry_policy->max_backoff)); in do_retry()
1441 const ClientChannelMethodParams::RetryPolicy* retry_policy = in maybe_retry() local
1442 calld->method_params->retry_policy(); in maybe_retry()
1443 if (retry_policy == nullptr) return false; in maybe_retry()
1471 if (!retry_policy->retryable_status_codes.Contains(status)) { in maybe_retry()
[all …]