作者：gfree.wind@gmail.com
博客：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也不是很麻烦。看来有望很快把发送数据的流程看完了，脉络也就清楚了。
