reconnect_policy.cpp

Go to the documentation of this file.

// SPDX-License-Identifier: Apache-2.0
#include <entropic/mcp/reconnect_policy.h>
 
#include <algorithm>
#include <cmath>
#include <random>
 
namespace entropic {
 
ReconnectPolicy::ReconnectPolicy(
    uint32_t base_delay_ms,
    uint32_t max_delay_ms,
    uint32_t max_retries,
    double backoff_factor)
    : base_delay_ms_(base_delay_ms),
      max_delay_ms_(max_delay_ms),
      max_retries_(max_retries),
      backoff_factor_(backoff_factor) {}
 
ReconnectPolicy::ReconnectPolicy(const ReconnectConfig& config)
    : base_delay_ms_(config.base_delay_ms),
      max_delay_ms_(config.max_delay_ms),
      max_retries_(config.max_retries),
      backoff_factor_(config.backoff_factor) {}
 
uint32_t ReconnectPolicy::delay_ms(uint32_t attempt) const {
    double raw = static_cast<double>(base_delay_ms_) *
                 std::pow(backoff_factor_, static_cast<double>(attempt));
    double capped = std::min(raw, static_cast<double>(max_delay_ms_));
 
    // Add jitter: uniform random in [0, 10% of delay]
    thread_local std::mt19937 rng(std::random_device{}());
    double jitter_range = capped * 0.1;
    std::uniform_real_distribution<double> dist(0.0, jitter_range);
 
    return static_cast<uint32_t>(capped + dist(rng));
}
 
bool ReconnectPolicy::exhausted(uint32_t attempt) const {
    if (max_retries_ == 0) {
        return false;
    }
    return attempt >= max_retries_;
}
 
} // namespace entropic