UDP socket流程（12）——udp_push_pending_frames

作者：[e-mail]

博客：linuxfocus.blog.chinaunix.net

本来按照昨天的想法，是想把ip_append_data以及之前遇到的问题和不解整理思考一下的，但今天还是想把send的流程走完，再总结比较好，那么就开始下一个API——udp_push_pending_frames吧。

这个API用于将所有pending的数据用一个UDP 数据包发送出去。

/*
 * Push out all pending data as one UDP datagram. Socket is locked.
 */
static int udp_push_pending_frames(struct sock *sk)
{
    struct udp_sock  *up = udp_sk(sk);
    struct inet_sock *inet = inet_sk(sk);
    struct flowi *fl = &inet->cork.fl;
    struct sk_buff *skb;
    struct udphdr *uh;
    int err = 0;
    int is_udplite = IS_UDPLITE(sk);
    __wsum csum = 0;

    /* Grab the skbuff where UDP header space exists. */
    /*
    拿到该socket输出队列中的第一个sk_buff，在后面会设置第一个sk_buff的传输层包头。
    因为所有的pending的数据用一个UDP数据包发送，所有设置一个sk_buff的传输层包头即可。
     */
    if ((skb = skb_peek(&sk->sk_write_queue)) == NULL)
        goto out;

    /*
     * Create a UDP header
     */
    /* 得到UDP报文头地址， 实际上仍然使用的是sk_buff的空间 */
    uh = udp_hdr(skb);
    /* 设置报文头的各个域*/
    uh->source = fl->fl_ip_sport;
    uh->dest = fl->fl_ip_dport;
    uh->len = htons(up->len);
    uh->check = 0;

      

     /* 

     下面是针对不同的checksum情况，进行计算checksum

     1. udplite：只计算部分数据的checksum，代替正常的UDP checksum（包含报文头和数据）；

     2. checksum 被disabled：不需要计算checksum；

     3. 由硬件计算checksum；

     4. 正常的UDP checksum计算

     */

    if (is_udplite)                   /*     UDP-Lite      */
        csum  = udplite_csum_outgoing(sk, skb);

    else if (sk->sk_no_check == UDP_CSUM_NOXMIT) {   /* UDP csum disabled */

        skb->ip_summed = CHECKSUM_NONE;
        goto send;

    } else if (skb->ip_summed == CHECKSUM_PARTIAL) { /* UDP hardware csum */

        udp4_hwcsum_outgoing(sk, skb, fl->fl4_src, fl->fl4_dst, up->len);
        goto send;

    } else                         /*   `normal' UDP    */
        csum = udp_csum_outgoing(sk, skb);

    /* add protocol-dependent pseudo-header */
    /* 再对UDP的伪首部进行校验和计算 */
    uh->check = csum_tcpudp_magic(fl->fl4_src, fl->fl4_dst, up->len,
                      sk->sk_protocol, csum);
    /* 如果校验和为0，则用另一种零的表达方式（0xffff）来代替0，用于区分没有校验和的情况 */
    if (uh->check == 0)
        uh->check = CSUM_MANGLED_0;

send:
    /* 调用IP网络层的输出函数，将所有sk_buff以一个IP报文发出 */
    err = ip_push_pending_frames(sk);
    if (err) {
        if (err == -ENOBUFS && !inet->recverr) {
            UDP_INC_STATS_USER(sock_net(sk),
                       UDP_MIB_SNDBUFERRORS, is_udplite);
            err = 0;
        }
    } else
        UDP_INC_STATS_USER(sock_net(sk),
                   UDP_MIB_OUTDATAGRAMS, is_udplite);
out:
    up->len = 0;
    up->pending = 0;
    return err;
}

今天这个API比较简单，后面的ip_push_pending_frames也不是很麻烦。看来有望很快把发送数据的流程看完了，脉络也就清楚了。