网络子系统56_ip协议分片重组_重组分片

转：http://blog.csdn.net/nerdx/article/details/12717817

//调用路径ip_defrag->ip_frag_reasm
//  所有ip分片都被接收到时，重组ip数据包
//  判断ip所有分片都接收到的条件：
//      1.FIRST_IN, LAST_IN
//      2.meat = len，即 根据offset推断出的最大封包长度等于已接收到的封包长度

//  重组过程：
//      1.将sk_buff链表从ipq->fragments取下
//      2.将第一个分片以后的分片挂在第一个分片的frag_list域
//      3.从分片子系统使用内存中减去该ip数据包的内存
//      4.返回第一个分片
1.1 static struct sk_buff *ip_frag_reasm(struct ipq *qp, struct net_device *dev)
{
    struct iphdr *iph;
    struct sk_buff *fp, *head = qp->fragments;
    int len;
    int ihlen;
    //
    ipq_kill(qp);


    //ip报头+ip选项大小
    ihlen = head->nh.iph->ihl*4;
    //ipq->len只包括ip有效载荷的长度
    len = ihlen + qp->len;//ip分包总长度
    //ip报文最大长度为64k
    if(len > 65535)
        goto out_oversize;
    //由于第一个skb是通过skb_cloned构造，则需要重新拷贝一份skb缓存区
    //skb_cloned与skb_shared区别：
    //  1.skb_cloned 表示该sk_buff与另一个sk_buff共享同一个缓存区
    //  2.skb_shared 表示该sk_buff引用计数大于1
    if (skb_cloned(head) && pskb_expand_head(head, 0, 0, GFP_ATOMIC))
        goto out_nomem;

    //保证第一个ip分片没有frag_list
    //  解决办法：
    //      1.创建一个新的sk_buff
    //      2.将该分片的frag_list添加到新sk_buff的frag_list上
    //      3.更新该skb，新skb的长度
    if (skb_shinfo(head)->frag_list) {
        struct sk_buff *clone;
        int i, plen = 0;

        if ((clone = alloc_skb(0, GFP_ATOMIC)) == NULL)
            goto out_nomem;
        clone->next = head->next;
        head->next = clone;
        skb_shinfo(clone)->frag_list = skb_shinfo(head)->frag_list;
        skb_shinfo(head)->frag_list = NULL;
        for (i=0; inr_frags; i++)
            plen += skb_shinfo(head)->frags[i].size;
        clone->len = clone->data_len = head->data_len - plen;
        head->data_len -= clone->len;
        head->len -= clone->len;
        clone->csum = 0;
        clone->ip_summed = head->ip_summed;
        atomic_add(clone->truesize, &ip_frag_mem);
    }

    //将ipq中，属于同一ip数据包的所有sk_buff，链接到第一个ip分片的frag_list上
    //  即： first->frag_list = first->next
    skb_shinfo(head)->frag_list = head->next;
    skb_push(head, head->data - head->nh.raw);
    atomic_sub(head->truesize, &ip_frag_mem);//减去ip分片子系统使用的内存

    //通过第一个skb，统计该ip数据包的总长度
    for (fp=head->next; fp; fp = fp->next) {
        head->data_len += fp->len;
        head->len += fp->len;
        if (head->ip_summed != fp->ip_summed)//只要有其中一个分片的校验和失效，则标记第一个分片的校验和失效
            head->ip_summed = CHECKSUM_NONE;
        else if (head->ip_summed == CHECKSUM_HW)//已经由硬件计算了校验和
            head->csum = csum_add(head->csum, fp->csum);//l4校验和保存在sk_buff->csum
        head->truesize += fp->truesize;
        atomic_sub(fp->truesize, &ip_frag_mem);
    }

    head->next = NULL;
    head->dev = dev;
    head->stamp = qp->stamp;//skb的时间戳为最后一个分片到达的时间戳

    iph = head->nh.iph;
    iph->frag_off = 0;
    iph->tot_len = htons(len);
    IP_INC_STATS_BH(IPSTATS_MIB_REASMOKS);
    qp->fragments = NULL;
    return head;

out_nomem:
    NETDEBUG(if (net_ratelimit())
             printk(KERN_ERR
            "IP: queue_glue: no memory for gluing queue %p\n",
            qp));
    goto out_fail;
out_oversize:
    if (net_ratelimit())
        printk(KERN_INFO
            "Oversized IP packet from %d.%d.%d.%d.\n",
            NIPQUAD(qp->saddr));
out_fail:
    IP_INC_STATS_BH(IPSTATS_MIB_REASMFAILS);
    return NULL;
}