Linux tcp_congestion_ops 拥塞控制算法结构体注册机制

tcp_congestion_ops 是 TCP 拥塞控制算法的接口抽象，定义在 include/net/tcp.h 中。所有拥塞控制算法（Cubic、BBR、Reno、Westwood、DCTCP 等）通过该结构体向内核注册。结构体包含拥塞控制状态的初始化、cwnd 在每个 ACK 到达时的更新、丢包事件响应、cwnd_undo（撤销错误减窗）以及 pkts_acked 速率采样等回调函数指针。

```c
struct tcp_congestion_ops {
struct list_head list;
unsigned long flags;
__u32 key;
char name[TCP_CA_NAME_MAX];
struct module *owner;

int (*init)(struct sock *sk);
void (*release)(struct sock *sk);
void (*ssthresh)(struct sock *sk);
u32 (*cwnd)(const struct sock *sk);
void (*cong_control)(struct sock *sk, const struct rate_sample *rs);
void (*cong_avoid)(struct sock *sk, u32 ack, u32 acked);
u32 (*undo_cwnd)(struct sock *sk);
void (*pkts_acked)(struct sock *sk, const struct ack_sample *sample);
void (*set_state)(struct sock *sk, u8 new_state);
...
};
```

算法注册通过 tcp_register_congestion_control 完成，函数将 ops 插入全局链表 tcp_cong_list，由读写锁 tcp_cong_list_lock 保护。模块初始化时调用 tcp_register_congestion_control(&tcp_cubic_ops)，清理时调用 tcp_unregister_congestion_control 从链表中移除。注册过程对 ops->key 做了唯一性检查，防止同一算法重复注册。

```c
int tcp_register_congestion_control(struct tcp_congestion_ops *ca)
{
int ret = 0;

if (!ca->cong_control && (!ca->cong_avoid || !ca->ssthresh))
return -EINVAL;

write_lock(&tcp_cong_list_lock);
if (tcp_ca_find_key(ca->key)) {
ret = -EEXIST;
} else if (!tcp_ca_find(ca->name)) {
list_add_tail_rcu(&ca->list, &tcp_cong_list);
pr_debug("%s registered\n", ca->name);
} else {
ret = -EEXIST;
}
write_unlock(&tcp_cong_list_lock);

return ret;
}
```

关键验证：若未实现 cong_control（BBR 风格），则必须同时实现 cong_avoid 和 ssthresh（classic AIMD 风格），否则返回 -EINVAL。注册时检查 name 的唯一性，但 key 冲突则返回 -EEXIST。list_add_tail_rcu 将新算法追加到链表尾部，使旧算法（如 CUBIC 作为默认）优先级更高——tcp_ca_find 首次匹配就返回，链表头部是内置算法。

运行时，每个 TCP socket 的 icsk_ca_ops 指针通过 tcp_assign_congestion_control 赋值。该函数在 tcp_init_transfer 中调用，决定算法选择优先级：控制面通过 sysctl_tcp_congestion_control 设定，随后检查 TCP_CONGESTION sockopt（setsockopt IPPROTO_TCP TCP_CONGESTION），最后 fallback 到系统默认值。

```c
void tcp_assign_congestion_control(struct sock *sk)
{
struct net *net = sock_net(sk);
struct tcp_congestion_ops *ca;
const char *name = net->ipv4.tcp_congestion_control;

if (sk->sk_txhash)
name = tcp_ca_get_name_by_key(sk->sk_txhash & TCP_CA_KEY_MASK);
if (!name)
name = tcp_ca_get_default(sk);

rcu_read_lock();
ca = tcp_ca_find(name);
if (unlikely(!ca)) {
ca = tcp_ca_find("cubic");
}
if (ca != rcu_dereference(icsk->icsk_ca_ops)) {
rcu_assign_pointer(icsk->icsk_ca_ops, ca);
if (ca->init)
ca->init(sk);
}
rcu_read_unlock();
}
```

这里存在动态切换路径：当 __tcp_transmit_skb 处于 BH 上下文中时，icsk_ca_ops 被 rcu_assign_pointer 切换，读者须使用 rcu_dereference 读取。若在 tcp_ack 中不加 RCU 保护直接读取 icsk_ca_ops->cong_control，在并发 tcp_set_congestion_control 被 setsockopt 调用时会出现读取到空指针或中间状态。内核通过 rcu_read_lock/rcu_dereference 包裹 tcp_cong_control 中所有对 icsk_ca_ops 的访问。

拥塞控制算法切换的竞争条件：tcp_set_congestion_control 被用户态线程调用时持有 lock_sock，而 tcp_ack 运行在 BH 上下文中仅持有 bh_lock_sock。若 tcp_set_congestion_control 调用 ca->release（旧算法析构）且 ca->init（新算法构造），在 release 后 init 前的窗口内如果有 BH 到达并调用 ca->pkts_acked，会读取到已释放的 ca 指针。解决方法是调用 synchronize_net() 等待正在执行的 BH 完成，但 synchronize_net 可能睡眠，因此 tcp_set_congestion_control 必须在进程上下文中调用且不能持有 spinlock。

```c
int tcp_set_congestion_control(struct sock *sk, const char *name, bool load, bool rcu_locked)
{
struct tcp_congestion_ops *ca;
int err;

ca = tcp_ca_find(name);
if (!ca) {
if (!load)
return -ENOENT;
err = request_module("tcp_%s", name);
if (err < 0)
return -ENOENT;
ca = tcp_ca_find(name);
if (!ca)
return -ENOENT;
}

if (!try_module_get(ca->owner))
return -EAGAIN;

tcp_ca_switch(sk, ca);
module_put(ca->owner);
return 0;
}
```

icsk_ca_priv 是拥塞控制算法私有状态的存储区，尺寸固定为 96 字节。CUBIC 使用的结构体 struct bictcp（44 字节）、BBR 使用的 struct bbr（64 字节）均在此区域内，使用前通过 inet_csk_ca(sk) 强制类型转换。当私有状态超出 96 字节时，内核在 tcp_register_congestion_control 中检查 BUILD_BUG_ON 并拒绝注册。私有数据的初始化在 ca->init(sk) 回调中完成，释放时 ca->release(sk) 清理 DCTCP 的 dctcp_shadow 等额外分配内存。

pacing rate 与 cwnd 的协调：tcp_cong_control 调用 ca->cong_control 时传递 struct rate_sample，其中包含 delivered（当前 RTT 内确认的数据量）和 interval_us（确认间隔）。BBR 依赖该数据进行带宽估计，而 CUBIC 则主要使用 ca->cong_avoid 更新 snd_cwnd。两套接口的切换在 tcp_ca_dst 选择的 tcp_cong_control 内部完成：如果 ops->cong_control 不为 NULL，则不调用传统的 cong_avoid/ssthresh 路径。