Searched refs:retry_policy (Results 1 – 14 of 14) sorted by relevance
86 auto retry_policy = MakeUnique<ClientChannelMethodParams::RetryPolicy>(); in ParseRetryPolicy() local92 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 …]
56 const RetryPolicy* retry_policy() const { return retry_policy_.get(); } in retry_policy() function
1389 const ClientChannelMethodParams::RetryPolicy* retry_policy = in do_retry() local1390 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() local1442 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 …]
69 auto retry_policy = in ParseRetryPolicy() local84 retry_policy->max_attempts = in ParseRetryPolicy()86 if (retry_policy->max_attempts <= 1) { in ParseRetryPolicy()89 } else if (retry_policy->max_attempts > MAX_MAX_RETRY_ATTEMPTS) { in ParseRetryPolicy()93 retry_policy->max_attempts = MAX_MAX_RETRY_ATTEMPTS; in ParseRetryPolicy()99 &retry_policy->initial_backoff, in ParseRetryPolicy()101 retry_policy->initial_backoff == 0) { in ParseRetryPolicy()107 &retry_policy->max_backoff, &error_list) && in ParseRetryPolicy()108 retry_policy->max_backoff == 0) { in ParseRetryPolicy()120 &retry_policy->backoff_multiplier) != 1) { in ParseRetryPolicy()[all …]
94 std::unique_ptr<RetryPolicy> retry_policy) in ClientChannelMethodParsedConfig() argument97 retry_policy_(std::move(retry_policy)) {} in ClientChannelMethodParsedConfig()103 const RetryPolicy* retry_policy() const { return retry_policy_.get(); } in retry_policy() function
546 const ClientChannelMethodParsedConfig::RetryPolicy* retry_policy);1182 method_config == nullptr ? nullptr : method_config->retry_policy()); in SetPollent()3225 const ClientChannelMethodParsedConfig::RetryPolicy* retry_policy) in RetryingCall() argument3229 retry_policy_(retry_policy), in RetryingCall()
76 new_wsi->retry_policy = vhost->retry_policy; in lws_create_new_server_wsi()584 const lws_retry_bo_t *retry_policy) in lws_create_adopt_udp() argument604 if (retry_policy) in lws_create_adopt_udp()605 wsi->retry_policy = retry_policy; in lws_create_adopt_udp()607 wsi->retry_policy = vhost->retry_policy; in lws_create_adopt_udp()
68 wsi->retry_policy = i->retry_and_idle_policy; in lws_client_connect_via_info()70 wsi->retry_policy = &i->context->default_retry; in lws_client_connect_via_info()
284 const lws_retry_bo_t *rbo = wsi->retry_policy; in lws_validity_cb()325 const lws_retry_bo_t *rbo = wsi->retry_policy; in _lws_validity_confirmed_role()
547 const lws_retry_bo_t *retry_policy; member710 const lws_retry_bo_t *retry_policy; member
518 vh->retry_policy = info->retry_and_idle_policy; in lws_create_vhost()520 vh->retry_policy = &context->default_retry; in lws_create_vhost()
431 wsi->retry_policy, cb, ctry); in lws_retry_sul_schedule_retry_wsi()
228 const lws_retry_bo_t *retry_policy);
30 static const lws_retry_bo_t retry_policy = { variable327 NULL, NULL, &retry_policy); in lws_async_dns_init()