struct Qdisc {
    int             (*enqueue)(struct sk_buff *skb, struct Qdisc *sch); // 入隊操作
    struct sk_buff* (*dequeue)(struct Qdisc *sch);      // 出隊操作
    struct Qdisc_ops *ops;             // Qdisc操作函數(shù)集
    struct netdev_queue *dev_queue;    // 關(guān)聯(lián)的網(wǎng)絡(luò)設(shè)備隊列
};

struct Qdisc_ops {
    struct Qdisc_ops *next;
    const struct Qdisc_class_ops *cl_ops; // Class操作函數(shù)集
    int (*enqueue)(struct sk_buff *, struct Qdisc *);
    struct sk_buff * (*dequeue)(struct Qdisc *);
    // ... 其他鉤子函數(shù)（init, destroy, reset等）
};

struct tcf_proto {
    __be16 protocol;          // 匹配的協(xié)議（如ETH_P_IP）
    struct tcf_proto_ops *ops; // Filter操作函數(shù)集
    struct tcf_result result; // 分類結(jié)果（指向Class）
};

graph TD
    A[數(shù)據(jù)包到達] --> B{設(shè)備是否啟用TC？}
    B -->|是| C[調(diào)用dev_queue_xmit()]
    C --> D[執(zhí)行__dev_xmit_skb()]
    D --> E[調(diào)用sch_direct_xmit() -> qdisc->enqueue()]
    E --> F[Qdisc特定入隊邏輯]
    F --> G[按調(diào)度算法緩存/丟棄]

static struct sk_buff *pfifo_fast_dequeue(struct Qdisc *sch) {
    struct sk_buff *skb = __qdisc_dequeue_head(&sch->q);
    return skb;
}

struct sk_buff *htb_dequeue(struct Qdisc *sch) {
    while ((skb = htb_do_dequeue(sch, prio, band)) != NULL) {
        // 按類別優(yōu)先級和令牌桶算法出隊
    }
}

struct htb_class {
    struct Qdisc_class_common common;
    struct psched_ratecfg rate;   // 速率配置
    struct psched_ratecfg ceil;   // 上限配置
    s64 tokens, ctokens;          // 令牌計數(shù)
    struct htb_class *parent;     // 父類指針
};

static int netem_enqueue(struct sk_buff *skb, struct Qdisc *sch) {
    if (loss_condition) { // 按概率丟包
        kfree_skb(skb);
        return NET_XMIT_SUCCESS;
    }
    if (delay_calculated) { // 計算延遲時間
        tfifo = netem_skb_cb(skb);
        tfifo->time_to_send = now + delay;
    }
    __qdisc_enqueue_tail(skb, &sch->q); // 加入延遲隊列
}

static int u32_classify(struct sk_buff *skb, const struct tcf_proto *tp, struct tcf_result *res) {
    struct tc_u32_key *key = tp->data;
    if (skb->len < key->off + 4) // 檢查偏移量是否有效
        return -1;
    if (*(u32*)(skb->data + key->off) == key->val) // 匹配關(guān)鍵值
        res->classid = key->classid; // 設(shè)置分類ID
}

static int cls_bpf_classify(struct sk_buff *skb, const struct tcf_proto *tp, struct tcf_result *res) {
    struct cls_bpf_prog *prog = tp->data;
    int ret = bpf_prog_run(prog->filter, skb); // 執(zhí)行eBPF程序
    if (ret == TC_ACT_SHOT) return -1;         // 丟棄包
    res->classid = ret;                        // 設(shè)置分類ID
}

// net/sched/sch_api.c
static int tc_ctl_tfilter(struct sk_buff *skb, struct nlmsghdr *n) {
    struct net *net = sock_net(skb->sk);
    struct tcmsg *tcm = nlmsg_data(n);
    struct net_device *dev = __dev_get_by_index(net, tcm->tcm_ifindex);
    // 解析并調(diào)用qdisc/class/filter操作函數(shù)
}

?
static struct sk_buff *fq_codel_dequeue(struct Qdisc *sch) {
    struct fq_codel_flow *flow;
    list_for_each_entry(flow, &q->new_flows, flowchain) {
        skb = flow->head;
        if (codel_time_after(skb->tstamp, now)) // 檢查是否需延遲
            continue;
        // ... 出隊邏輯
    }
}

?

tc -s qdisc show dev eth0

perf record -e 'net:net_dev_queue' -e 'net:net_dev_xmit'

net/sched/
├── sch_generic.c     // Qdisc基礎(chǔ)框架
├── sch_htb.c         // HTB實現(xiàn)
├── sch_netem.c       // Netem實現(xiàn)
├── cls_api.c         // Filter框架
├── cls_u32.c         // U32分類器
├── act_api.c         // Action框架
└── act_mirred.c      // 重定向Action