// rtt_estimator.h
// 平滑 RTT 估算器（参考 RFC 6298），与 Windows 端 KernelManager 算法一致。
// Linux/macOS 客户端共享：每次心跳 ACK 用 update_from_sample(rtt_ms) 喂一次样本。
//
// 设计要点：
//   - srtt / rttvar / rto 单位为秒；输入是毫秒
//   - 异常值（≤0 或 >30s）丢弃，防止统计被一个瞬时坏样本污染
//   - alpha=1/8, beta=1/4 与 RFC 6298 默认值一致
//
// C++17 inline 全局变量：g_rttEstimator / g_heartbeatInterval 由本头文件直接定义，
// 多翻译单元 include 不会触发 ODR 冲突。
#pragma once

#include <cmath>

struct RttEstimator {
    double srtt   = 0.0;     // 平滑 RTT (秒)
    double rttvar = 0.0;     // RTT 波动 (秒)
    double rto    = 0.0;     // 超时时间 (秒)
    bool   initialized = false;

    void update_from_sample(double rtt_ms)
    {
        // 过滤异常值：RTT应在合理范围内 (0, 30000] 毫秒
        if (rtt_ms <= 0 || rtt_ms > 30000)
            return;

        const double alpha = 1.0 / 8;
        const double beta  = 1.0 / 4;
        double rtt = rtt_ms / 1000.0;

        if (!initialized) {
            srtt = rtt;
            rttvar = rtt / 2.0;
            rto = srtt + 4.0 * rttvar;
            initialized = true;
        } else {
            rttvar = (1.0 - beta) * rttvar + beta * std::fabs(srtt - rtt);
            srtt   = (1.0 - alpha) * srtt + alpha * rtt;
            rto    = srtt + 4.0 * rttvar;
        }

        // 限制最小 RTO（RFC 6298 推荐 1 秒）
        if (rto < 1.0) rto = 1.0;
    }
};

// 进程级全局：所有翻译单元共享同一份估算器与心跳间隔
inline RttEstimator g_rttEstimator;
inline int g_heartbeatInterval = 5; // 默认心跳间隔（秒），可被服务端 CMD_MASTERSETTING 更新