Linux内核中流量控制(19)

本文档的Copyleft归yfydz所有，使用GPL发布，可以自由拷贝，转载，转载时请保持文档的完整性，严禁用于任何商业用途。
msn: [e-mail]
来源：http://yfydz.cublog.cn

7.10 U32

Ugly (or Universal) 32bit key Packet Classifier，丑陋(或通用)的32位关键数据包分类器
U32和RSVP类似, 但能更详细清楚地定义各中协议的参数, 比较符合通常的使用习惯, 而且这些参数都看成U32数来进行匹配的, 目前使用得比较多, 其代码在net/sched/cls_u32.c中定义。

7.10.1 数据结构和过滤器操作结构

/* include/linux/pkt_cls.h */
// u32关键字匹配
struct tc_u32_key
{
// 数值和掩码
 __u32  mask;
 __u32  val;
// 偏移量和偏移掩码
 int  off;
 int  offmask;
};

// u32选择子结构
struct tc_u32_sel
{
// 标志
 unsigned char  flags;
// 偏移移动数
 unsigned char  offshift;
// key(匹配条件)的数量
 unsigned char  nkeys;
// 偏移掩码
 __u16   offmask;
// 偏移值
 __u16   off;
 short   offoff;
 short   hoff;
 __u32   hmask;
// 具体的匹配key结构
 struct tc_u32_key keys[0];
};

// u32标志结构
struct tc_u32_mark
{
// 值
 __u32  val;
// 掩码
 __u32  mask;
// 匹配成功的数据包数量
 __u32  success;
};
struct tc_u32_pcnt
{
 __u64 rcnt;
 __u64 rhit;
 __u64 kcnts[0];
};

/* net/sched/cls_u32.c */
// u32核心节点，用来定义一条tc filter规则中的U32匹配
struct tc_u_knode
{
// 下一项
 struct tc_u_knode *next;
// 句柄
 u32   handle;
// 指向上层的hnode
 struct tc_u_hnode *ht_up;
// TCF扩展结构
 struct tcf_exts  exts;
#ifdef CONFIG_NET_CLS_IND
// 网卡设备名称
 char                     indev[IFNAMSIZ];
#endif
 u8   fshift;
// TCF分类结果
 struct tcf_result res;
// 指向下层的hnode
 struct tc_u_hnode *ht_down;
#ifdef CONFIG_CLS_U32_PERF
 struct tc_u32_pcnt *pf;
#endif
#ifdef CONFIG_CLS_U32_MARK
// MARK标志
 struct tc_u32_mark mark;
#endif
// 选择子, 也就是匹配条件
 struct tc_u32_sel sel;
};

// u32的哈希节点， 相当于RSVP的会话节点
struct tc_u_hnode
{
// 下一项hnode
 struct tc_u_hnode *next;
// 句柄
 u32   handle;
// 优先权
 u32   prio;
// 回指u_common结构
 struct tc_u_common *tp_c;
// 引用数
 int   refcnt;
// 哈希链表数量
 unsigned  divisor;
// knode哈希链表, 这个参数应该取名kt好了
 struct tc_u_knode *ht[1];
};

// u32通用节点，相当于RSVP的根节点
struct tc_u_common
{
// 下一项common节点
 struct tc_u_common *next;
// 指向hnode的哈希表
 struct tc_u_hnode *hlist;
// Qdisc结构
 struct Qdisc  *q;
// 引用值
 int   refcnt;
 u32   hgenerator;
};
// u32根节点指针，作为全局变量, 用来链接所有的common节点, 每个节点是按Qdisc进行区分的
static struct tc_u_common *u32_list;

// u32扩展映射结构
static struct tcf_ext_map u32_ext_map = {
 .action = TCA_U32_ACT,
 .police = TCA_U32_POLICE
};
 
// 操作结构
static struct tcf_proto_ops cls_u32_ops = {
 .next  = NULL,
 .kind  = "u32",
 .classify = u32_classify,
 .init  = u32_init,
 .destroy = u32_destroy,
 .get  = u32_get,
 .put  = u32_put,
 .change  = u32_change,
 .delete  = u32_delete,
 .walk  = u32_walk,
 .dump  = u32_dump,
 .owner  = THIS_MODULE,
};

7.10.2 初始化
 
static int u32_init(struct tcf_proto *tp)
{
 struct tc_u_hnode *root_ht;
 struct tc_u_common *tp_c;
// 遍历u32链表, 查找是否已经有和该Qdisc相同的u32节点, 也就是说可以同时在不同的Qdisc
// 的数据包分类中使用u32
 for (tp_c = u32_list; tp_c; tp_c = tp_c->next)
  if (tp_c->q == tp->q)
   break;
// 分配hnode结构作为根
 root_ht = kzalloc(sizeof(*root_ht), GFP_KERNEL);
 if (root_ht == NULL)
  return -ENOBUFS;
// 初始化hnode参数
 root_ht->divisor = 0;
// 节点索引值
 root_ht->refcnt++;
// 句柄, 是hnode类型的, 低20位为0
 root_ht->handle = tp_c ? gen_new_htid(tp_c) : 0x80000000;
// 优先权
 root_ht->prio = tp->prio;

// 如果相应Qdisc的u32同样节点不存在
 if (tp_c == NULL) {
// 新分配common节点空间
  tp_c = kzalloc(sizeof(*tp_c), GFP_KERNEL);
  if (tp_c == NULL) {
   kfree(root_ht);
   return -ENOBUFS;
  }
// 设置Qdisc
  tp_c->q = tp->q;
// 加到u32通用节点链表头位置
  tp_c->next = u32_list;
  u32_list = tp_c;
 }
// 通用结构引用增加
 tp_c->refcnt++;
// 将hnode添加到u_common结构的哈希链表头
 root_ht->next = tp_c->hlist;
 tp_c->hlist = root_ht;
 root_ht->tp_c = tp_c;
// TCF过滤规则表的根节点设置为该hnode
 tp->root = root_ht;
// TCF数据是hnode所在u_common结构
 tp->data = tp_c;
 return 0;
}
 
7.10.3 分类

static int u32_classify(struct sk_buff *skb, struct tcf_proto *tp, struct tcf_result *res)
{
// 构造一个堆栈
 struct {
  struct tc_u_knode *knode;
  u8    *ptr;
 } stack[TC_U32_MAXDEPTH];
// u32根节点
 struct tc_u_hnode *ht = (struct tc_u_hnode*)tp->root;
// IP头指针
 u8 *ptr = skb->nh.raw;
 struct tc_u_knode *n;
 int sdepth = 0;
 int off2 = 0;
// 选择参数初始化为0
 int sel = 0;
#ifdef CONFIG_CLS_U32_PERF
 int j;
#endif
 int i, r;
next_ht:
// 通过选择参数指定的knode哈希表头
 n = ht->ht[sel];
next_knode:
// 如果链表非空
 if (n) {
  struct tc_u32_key *key = n->sel.keys;
#ifdef CONFIG_CLS_U32_PERF
  n->pf->rcnt +=1;
  j = 0;
#endif
#ifdef CONFIG_CLS_U32_MARK
// 比较数据包中的nfmark值是否匹配
  if ((skb->nfmark & n->mark.mask) != n->mark.val) {
// 不匹配, 找下一个knode
   n = n->next;
   goto next_knode;
  } else {
// mark匹配成功, 计数增加
   n->mark.success++;
  }
#endif
// 遍历所有的U32匹配条件, 可包括地址,端口,ICMP类型/CODE,AH/ESP的SPI等
  for (i = n->sel.nkeys; i>0; i--, key++) {
// 所有U32匹配条件都是通过参数偏移量定义参数的位置
// 匹配方法是取从数据包IP头开始的指定偏移量的32位数据, 然后和指定的值和掩码进行匹配计算
// 如果匹配, 计算结果为0
// 但完全使用偏移值来定义数据是有问题的, 比如TCP/UDP的端口, 都是固定偏移为20, 也就是
// 普通最小IP包长的情况, 但如果该数据包带有IP选项使IP头长超过20时, 匹配就会失败
   if ((*(u32*)(ptr+key->off+(off2&key->offmask))^key->val)&key->mask) {
// 匹配失败, 找下一个knode节点
    n = n->next;
    goto next_knode;
   }
#ifdef CONFIG_CLS_U32_PERF
   n->pf->kcnts[j] +=1;
   j++;
#endif
  }
//
  if (n->ht_down == NULL) {
check_terminal:
// 如果带TERMINAL标志, 可以准备返回了
   if (n->sel.flags&TC_U32_TERMINAL) {
// 为分类结果结构赋值
    *res = n->res;
#ifdef CONFIG_NET_CLS_IND
// 最后比较一下网卡参数
    if (!tcf_match_indev(skb, n->indev)) {
// 如果比较失败, 转下一个knode
     n = n->next;
     goto next_knode;
    }
#endif
#ifdef CONFIG_CLS_U32_PERF
    n->pf->rhit +=1;
#endif
// TCf扩展处理
    r = tcf_exts_exec(skb, &n->exts, res);
    if (r < 0) {
// 失败的话转下一个knode
     n = n->next;
     goto next_knode;
    }
// 返回成功
    return r;
   }
// 没TERMINAL标志, 转下一knode
   n = n->next;
   goto next_knode;
  }
// ht_down非空,转下一层
  /* PUSH */
// 检查层次数, 过大的话返回失败
  if (sdepth >= TC_U32_MAXDEPTH)
   goto deadloop;
// 将knode节点n推入堆栈, 也保存当前的IP头指针值
  stack[sdepth].knode = n;
  stack[sdepth].ptr = ptr;
  sdepth++;

// ht_down非空的清空
// 当前的hnode更新为ht_down
  ht = n->ht_down;
  sel = 0;
// 该hnode匹配条件非空, 计算选择参数
  if (ht->divisor)
   sel = ht->divisor&u32_hash_fold(*(u32*)(ptr+n->sel.hoff), &n->sel,n->fshift);
// 以下检查选择结构参数是否可用, 暂时不可用的话进行一些处理使之可用
// 检查一下选择结构标志, 不带这些标志的话可以直接使用了
  if (!(n->sel.flags&(TC_U32_VAROFFSET|TC_U32_OFFSET|TC_U32_EAT)))
   goto next_ht;
// 至少带了这3个标志之一的情况
// 设置了TC_U32_OFFSET或TC_U32_VAROFFSET, 计算偏移off2
  if (n->sel.flags&(TC_U32_OFFSET|TC_U32_VAROFFSET)) {
   off2 = n->sel.off + 3;
   if (n->sel.flags&TC_U32_VAROFFSET)
    off2 += ntohs(n->sel.offmask & *(u16*)(ptr+n->sel.offoff)) >>n->sel.offshift;
   off2 &= ~3;
  }
// 如果设置了EAT标志, 更新IP头指针位置
  if (n->sel.flags&TC_U32_EAT) {
   ptr += off2;
   off2 = 0;
  }
// ptr指针还在合法范围内, 可以继续循环了
  if (ptr < skb->tail)
   goto next_ht;
// 否则进行出堆栈操作了
 }
 /* POP */
// knode节点n为空, 到底了, sdepth如果非0, 进行出堆栈操作
 if (sdepth--) {
// 弹出堆栈底的knode节点
  n = stack[sdepth].knode;
// hnode更新为ht_up
  ht = n->ht_up;
// 恢复IP头指针
  ptr = stack[sdepth].ptr;
// 跳转到检查是否可以终止了
  goto check_terminal;
 }
// 堆栈空的, 分类失败
 return -1;
deadloop:
 if (net_ratelimit())
  printk("cls_u32: dead loop\n");
 return -1;
}
 
7.10.4 释放
 
static void u32_destroy(struct tcf_proto *tp)
{
// u32_common节点
 struct tc_u_common *tp_c = tp->data;
// 将tcf_proto的根节点交换为NULL, 准备将原来的节点保存到root_ht进行释放操作
 struct tc_u_hnode *root_ht = xchg(&tp->root, NULL);
 BUG_TRAP(root_ht != NULL);
// rooh_ht非空的话, 释放root_ht
 if (root_ht && --root_ht->refcnt == 0)
  u32_destroy_hnode(tp, root_ht);
// 减少common节点的引用数, 到0的话进行删除
 if (--tp_c->refcnt == 0) {
  struct tc_u_hnode *ht;
  struct tc_u_common **tp_cp;
// 遍历u32链表
  for (tp_cp = &u32_list; *tp_cp; tp_cp = &(*tp_cp)->next) {
// 查找匹配的common节点
   if (*tp_cp == tp_c) {
// 将该节点从链表中断开
    *tp_cp = tp_c->next;
    break;
   }
  }
// 遍历hnode链表删除每个hnode内部参数
  for (ht=tp_c->hlist; ht; ht = ht->next)
   u32_clear_hnode(tp, ht);
// 释放hnode链表本身元素
  while ((ht = tp_c->hlist) != NULL) {
   tp_c->hlist = ht->next;
   BUG_TRAP(ht->refcnt == 0);
   kfree(ht);
  };
// 释放common节点空间
  kfree(tp_c);
 }
// TCF_PROTO结构中的data参数清空
 tp->data = NULL;
}

// 释放hnode
static int u32_destroy_hnode(struct tcf_proto *tp, struct tc_u_hnode *ht)
{
// u32的common节点
 struct tc_u_common *tp_c = tp->data;
 struct tc_u_hnode **hn;
 BUG_TRAP(!ht->refcnt);
// 清除hnode
 u32_clear_hnode(tp, ht);
// 遍历u32_common的hnode链表
 for (hn = &tp_c->hlist; *hn; hn = &(*hn)->next) {
// 查找hnode节点
  if (*hn == ht) {
// 找到的话从链表中断开
   *hn = ht->next;
// 释放空间
   kfree(ht);
   return 0;
  }
 }
 BUG_TRAP(0);
 return -ENOENT;
}

// 清除hnode内部参数
static void u32_clear_hnode(struct tcf_proto *tp, struct tc_u_hnode *ht)
{
 struct tc_u_knode *n;
 unsigned h;
// 遍历所有链表
 for (h=0; h<=ht->divisor; h++) {
// 遍历链表所有knode节点
  while ((n = ht->ht[h]) != NULL) {
// 将knode节点从链表中断开
   ht->ht[h] = n->next;
// 释放knode
   u32_destroy_key(tp, n);
  }
 }
}

// 释放knode
static int u32_destroy_key(struct tcf_proto *tp, struct tc_u_knode *n)
{
// 和过滤器解除绑定
 tcf_unbind_filter(tp, &n->res);
// 释放TCF扩展结构
 tcf_exts_destroy(tp, &n->exts);
// 减少ht_down的引用数
 if (n->ht_down)
  n->ht_down->refcnt--;
// 释放实际knode空间
#ifdef CONFIG_CLS_U32_PERF
 kfree(n->pf);
#endif
 kfree(n);
 return 0;
}
 
7.10.5 获取

// 根据handle查找hnode结构
static unsigned long u32_get(struct tcf_proto *tp, u32 handle)
{
 struct tc_u_hnode *ht;
 struct tc_u_common *tp_c = tp->data;
// handle的高12位
 if (TC_U32_HTID(handle) == TC_U32_ROOT)
// 如果handle是根的话, 返回tcf_proto的
  ht = tp->root;
 else
// 根据handle值查找hnode
  ht = u32_lookup_ht(tp_c, TC_U32_HTID(handle));

// 找不到的话返回0
 if (!ht)
  return 0;
// handle的低20位为0的话直接返回
 if (TC_U32_KEY(handle) == 0)
  return (unsigned long)ht;
// 否则查找knode
 return (unsigned long)u32_lookup_key(ht, handle);
}

// 查找hnode
static __inline__ struct tc_u_hnode *
u32_lookup_ht(struct tc_u_common *tp_c, u32 handle)
{
 struct tc_u_hnode *ht;
// 遍历common节点的hnode链表, 查找和handle值匹配的hnode
 for (ht = tp_c->hlist; ht; ht = ht->next)
  if (ht->handle == handle)
   break;
 return ht;
}

// 查找knode
static __inline__ struct tc_u_knode *
u32_lookup_key(struct tc_u_hnode *ht, u32 handle)
{
 unsigned sel;
 struct tc_u_knode *n = NULL;
// handle的第12~19位作为选择值
 sel = TC_U32_HASH(handle);
// 过大的话返回失败
 if (sel > ht->divisor)
  goto out;
// 遍历hnode的第sel个哈希表, 查找和handle值匹配的hnode
 for (n = ht->ht[sel]; n; n = n->next)
  if (n->handle == handle)
   break;
out:
 return n;
}

7.10.6 放下
// 空函数
static void u32_put(struct tcf_proto *tp, unsigned long f)
{
}
 
7.10.7 修改

// 增加和修改tc filter规则时调用
static int u32_change(struct tcf_proto *tp, unsigned long base, u32 handle,
        struct rtattr **tca,
        unsigned long *arg)
{
// U32的common结构
 struct tc_u_common *tp_c = tp->data;
 struct tc_u_hnode *ht;
 struct tc_u_knode *n;
 struct tc_u32_sel *s;
// 配置参数
 struct rtattr *opt = tca[TCA_OPTIONS-1];
 struct rtattr *tb[TCA_U32_MAX];
 u32 htid;
 int err;
// 参数为空, 返回
 if (opt == NULL)
  return handle ? -EINVAL : 0;
// 对参数进行解析, 解析结果返回到tb数组中, 解析失败返回
 if (rtattr_parse_nested(tb, TCA_U32_MAX, opt) < 0)
  return -EINVAL;
// 如果knode非空, 是修改操作
 if ((n = (struct tc_u_knode*)*arg) != NULL) {
// 如果knode节点的handle的低20位为0, 是hnode, 返回错误
  if (TC_U32_KEY(n->handle) == 0)
   return -EINVAL;
// 设置参数
  return u32_set_parms(tp, base, n->ht_up, n, tb, tca[TCA_RATE-1]);
 }
// knode为空
// DIVISOR参数非空, 表示要建立hnode
 if (tb[TCA_U32_DIVISOR-1]) {
// 获取DIVISOR参数
  unsigned divisor = *(unsigned*)RTA_DATA(tb[TCA_U32_DIVISOR-1]);
// 该参数不能大于256
  if (--divisor > 0x100)
   return -EINVAL;
// 检查输入的handle如果表示knode的handle, 返回失败
  if (TC_U32_KEY(handle))
   return -EINVAL;
// 如果handle为0, 重新生成一个hnode类型的handle, 该handle低20位为0
  if (handle == 0) {
   handle = gen_new_htid(tp->data);
   if (handle == 0)
    return -ENOMEM;
  }
// 分配hnode节点
  ht = kzalloc(sizeof(*ht) + divisor*sizeof(void*), GFP_KERNEL);
  if (ht == NULL)
   return -ENOBUFS;
// 填充hnode基本参数
  ht->tp_c = tp_c;
  ht->refcnt = 0;
  ht->divisor = divisor;
  ht->handle = handle;
  ht->prio = tp->prio;
  ht->next = tp_c->hlist;
// 将hnode和common结构挂钩
  tp_c->hlist = ht;
// hnode地址作为返回结果
  *arg = (unsigned long)ht;
  return 0;
 }
// 如果U32的哈希参数存在
 if (tb[TCA_U32_HASH-1]) {
// 读取hnodeID
  htid = *(unsigned*)RTA_DATA(tb[TCA_U32_HASH-1]);
// HTID是高12位
  if (TC_U32_HTID(htid) == TC_U32_ROOT) {
// 如果为U32的根ID
// hnode取值为TCF_PROTO结构的根
   ht = tp->root;
   htid = ht->handle;
  } else {
// 否则根据此hnodeID查找hnode
   ht = u32_lookup_ht(tp->data, TC_U32_HTID(htid));
// 没找到, 返回错误
   if (ht == NULL)
    return -EINVAL;
  }
 } else {
// 哈希参数不存在, 按根节点处理
  ht = tp->root;
  htid = ht->handle;
 }
// U32_HASH是取第12~19位
 if (ht->divisor < TC_U32_HASH(htid))
  return -EINVAL;
 if (handle) {
// 输入handle非0时
  if (TC_U32_HTID(handle) && TC_U32_HTID(handle^htid))
   return -EINVAL;
// 确保handle是knode类型的handle, 低12位非0
  handle = htid | TC_U32_NODE(handle);
 } else
// 重新分配knode类型的handle, 低12位非0
  handle = gen_new_kid(ht, htid);
// 必须有选择结构参数
 if (tb[TCA_U32_SEL-1] == 0 ||
     RTA_PAYLOAD(tb[TCA_U32_SEL-1]) < sizeof(struct tc_u32_sel))
  return -EINVAL;
// 提取选择结构
 s = RTA_DATA(tb[TCA_U32_SEL-1]);
// 分配knode和nkeys个key结构
 n = kzalloc(sizeof(*n) + s->nkeys*sizeof(struct tc_u32_key), GFP_KERNEL);
 if (n == NULL)
  return -ENOBUFS;
#ifdef CONFIG_CLS_U32_PERF
// 分配PERF结构和nkeys个64位数
 n->pf = kzalloc(sizeof(struct tc_u32_pcnt) + s->nkeys*sizeof(u64), GFP_KERNEL);
 if (n->pf == NULL) {
  kfree(n);
  return -ENOBUFS;
 }
#endif
// 拷贝选择结构
 memcpy(&n->sel, s, sizeof(*s) + s->nkeys*sizeof(struct tc_u32_key));
// knode的上层hnode
 n->ht_up = ht;
// 基本
 n->handle = handle;
{
// 计算fshift参数, 也去保证mask最低位为1, fshift就是原来mask中为1的最低位的位置
 u8 i = 0;
 u32 mask = s->hmask;
 if (mask) {
  while (!(mask & 1)) {
   i++;
   mask>>=1;
  }
 }
 n->fshift = i;
}
#ifdef CONFIG_CLS_U32_MARK
// 处理U32的mark参数
 if (tb[TCA_U32_MARK-1]) {
  struct tc_u32_mark *mark;
// 如果mark参数非法, 返回失败
  if (RTA_PAYLOAD(tb[TCA_U32_MARK-1]) < sizeof(struct tc_u32_mark)) {
#ifdef CONFIG_CLS_U32_PERF
   kfree(n->pf);
#endif
   kfree(n);
   return -EINVAL;
  }
// 读取mark结构
  mark = RTA_DATA(tb[TCA_U32_MARK-1]);
// 拷贝到knode中
  memcpy(&n->mark, mark, sizeof(struct tc_u32_mark));
  n->mark.success = 0;
 }
#endif
// 设置新knode的参数
 err = u32_set_parms(tp, base, ht, n, tb, tca[TCA_RATE-1]);
 if (err == 0) {
// 命令成功
  struct tc_u_knode **ins;
// 遍历和handle相应的哈希链表找插入位置, 链表是按handle的低12位值排序,
// 小的在前, 大的在后
  for (ins = &ht->ht[TC_U32_HASH(handle)]; *ins; ins = &(*ins)->next)
   if (TC_U32_NODE(handle) < TC_U32_NODE((*ins)->handle))
    break;
// 将新knode插入链表
  n->next = *ins;
  wmb();
  *ins = n;
// knode地址作为结果返回
  *arg = (unsigned long)n;
  return 0;
 }
// 修改参数失败, 释放分配的空间
#ifdef CONFIG_CLS_U32_PERF
 kfree(n->pf);
#endif
 kfree(n);
 return err;
}

// 设置U32参数
static int u32_set_parms(struct tcf_proto *tp, unsigned long base,
    struct tc_u_hnode *ht,
    struct tc_u_knode *n, struct rtattr **tb,
    struct rtattr *est)
{
 int err;
 struct tcf_exts e;
// TCF扩展参数合法性处理
 err = tcf_exts_validate(tp, tb, est, &e, &u32_ext_map);
 if (err < 0)
  return err;
 err = -EINVAL;
// 如果设置了U32_LINK参数
 if (tb[TCA_U32_LINK-1]) {
// 以LINK参数作为handle
  u32 handle = *(u32*)RTA_DATA(tb[TCA_U32_LINK-1]);
  struct tc_u_hnode *ht_down = NULL;
// 如果handle的低20位为空, 错误
  if (TC_U32_KEY(handle))
   goto errout;
  if (handle) {
// handle非0的话, 根据此handle查找hnode准备作为knode的下层hnode
   ht_down = u32_lookup_ht(ht->tp_c, handle);
// 找不到, 返回错误
   if (ht_down == NULL)
    goto errout;
   ht_down->refcnt++;
  }
  tcf_tree_lock(tp);
// 设置knode节点的下层hnode,
  ht_down = xchg(&n->ht_down, ht_down);
  tcf_tree_unlock(tp);
// 减少原来的下层hnode的引用数
  if (ht_down)
   ht_down->refcnt--;
 }
// 如果设置了类别ID的话
 if (tb[TCA_U32_CLASSID-1]) {
// 设置返回结果的类别ID, 绑定过滤器
  n->res.classid = *(u32*)RTA_DATA(tb[TCA_U32_CLASSID-1]);
  tcf_bind_filter(tp, &n->res, base);
 }
#ifdef CONFIG_NET_CLS_IND
// 如果设置了网卡参数
 if (tb[TCA_U32_INDEV-1]) {
// 设置网卡
  int err = tcf_change_indev(tp, n->indev, tb[TCA_U32_INDEV-1]);
  if (err < 0)
   goto errout;
 }
#endif
// TCF扩展部分的修改
 tcf_exts_change(tp, &n->exts, &e);
 return 0;
errout:
 tcf_exts_destroy(tp, &e);
 return err;
}

7.10.8 删除

static int u32_delete(struct tcf_proto *tp, unsigned long arg)
{
// 要删除的hnode
 struct tc_u_hnode *ht = (struct tc_u_hnode*)arg;
// 为空的话直接返回成功
 if (ht == NULL)
  return 0;
// handle低20位非空, 删除相应的knode
 if (TC_U32_KEY(ht->handle))
  return u32_delete_key(tp, (struct tc_u_knode*)ht);
// 否则如果是根节点的返回错误, 根节点不能删除
 if (tp->root == ht)
  return -EINVAL;
// 释放hnode
 if (--ht->refcnt == 0)
  u32_destroy_hnode(tp, ht);
 return 0;
}

// 删除knode
static int u32_delete_key(struct tcf_proto *tp, struct tc_u_knode* key)
{
 struct tc_u_knode **kp;
// hnode通过key的ht_up获取
 struct tc_u_hnode *ht = key->ht_up;
 if (ht) {
// 哈希号是key的handle的12~19位确定
// 遍历链表
  for (kp = &ht->ht[TC_U32_HASH(key->handle)]; *kp; kp = &(*kp)->next) {
   if (*kp == key) {
// key匹配, 找到
    tcf_tree_lock(tp);
// 从链表中断开
    *kp = key->next;
    tcf_tree_unlock(tp);
// 释放key
    u32_destroy_key(tp, key);
    return 0;
   }
  }
 }
 BUG_TRAP(0);
 return 0;
}
 

7.10.9 遍历

static void u32_walk(struct tcf_proto *tp, struct tcf_walker *arg)
{
 struct tc_u_common *tp_c = tp->data;
 struct tc_u_hnode *ht;
 struct tc_u_knode *n;
 unsigned h;
 if (arg->stop)
  return;
 for (ht = tp_c->hlist; ht; ht = ht->next) {
  if (ht->prio != tp->prio)
   continue;
  if (arg->count >= arg->skip) {
   if (arg->fn(tp, (unsigned long)ht, arg) < 0) {
    arg->stop = 1;
    return;
   }
  }
  arg->count++;
  for (h = 0; h <= ht->divisor; h++) {
   for (n = ht->ht[h]; n; n = n->next) {
    if (arg->count < arg->skip) {
     arg->count++;
     continue;
    }
    if (arg->fn(tp, (unsigned long)n, arg) < 0) {
     arg->stop = 1;
     return;
    }
    arg->count++;
   }
  }
 }
}

7.10.10 输出

static int u32_dump(struct tcf_proto *tp, unsigned long fh,
       struct sk_buff *skb, struct tcmsg *t)
{
// 输出knode节点(U32匹配规则)的参数
 struct tc_u_knode *n = (struct tc_u_knode*)fh;
// 缓冲区定位
 unsigned char  *b = skb->tail;
 struct rtattr *rta;
// 为空, 返回
 if (n == NULL)
  return skb->len;
// 句柄
 t->tcm_handle = n->handle;
 rta = (struct rtattr*)b;
// 选项标志
 RTA_PUT(skb, TCA_OPTIONS, 0, NULL);
// U32_KEY是低20位
 if (TC_U32_KEY(n->handle) == 0) {
// 低20位为0, 表示是参数是hnode节点, 不是knode
  struct tc_u_hnode *ht = (struct tc_u_hnode*)fh;
  u32 divisor = ht->divisor+1;
// 输出DIVISOR
  RTA_PUT(skb, TCA_U32_DIVISOR, 4, &divisor);
 } else {
// 低20位非0, 表示确实是knode
// 输出选择子结构和匹配的key结构
  RTA_PUT(skb, TCA_U32_SEL,
   sizeof(n->sel) + n->sel.nkeys*sizeof(struct tc_u32_key),
   &n->sel);
// 输出上层hnode的ID值
  if (n->ht_up) {
   u32 htid = n->handle & 0xFFFFF000;
   RTA_PUT(skb, TCA_U32_HASH, 4, &htid);
  }
// 输出类别ID
  if (n->res.classid)
   RTA_PUT(skb, TCA_U32_CLASSID, 4, &n->res.classid);
// 输出下层hnode的handle值
  if (n->ht_down)
   RTA_PUT(skb, TCA_U32_LINK, 4, &n->ht_down->handle);
#ifdef CONFIG_CLS_U32_MARK
// 输出U32的mark值
  if (n->mark.val || n->mark.mask)
   RTA_PUT(skb, TCA_U32_MARK, sizeof(n->mark), &n->mark);
#endif
// 输出TCF扩展, 动作或策略
  if (tcf_exts_dump(skb, &n->exts, &u32_ext_map) < 0)
   goto rtattr_failure;
#ifdef CONFIG_NET_CLS_IND
// 输出网卡设备名称
  if(strlen(n->indev))
   RTA_PUT(skb, TCA_U32_INDEV, IFNAMSIZ, n->indev);
#endif
#ifdef CONFIG_CLS_U32_PERF
  RTA_PUT(skb, TCA_U32_PCNT,
  sizeof(struct tc_u32_pcnt) + n->sel.nkeys*sizeof(u64),
   n->pf);
#endif
 }
 rta->rta_len = skb->tail - b;
// 如果是knode, 输出统计参数
 if (TC_U32_KEY(n->handle))
  if (tcf_exts_dump_stats(skb, &n->exts, &u32_ext_map) < 0)
   goto rtattr_failure;
 return skb->len;
rtattr_failure:
 skb_trim(skb, b - skb->data);
 return -1;
}

...... 待续 ......