作者: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也不是很麻烦。看来有望很快把发送数据的流程看完了,脉络也就清楚了。