Chinaunix首页 | 论坛 | 博客
  • 博客访问: 832412
  • 博文数量: 97
  • 博客积分: 3042
  • 博客等级: 中校
  • 技术积分: 1610
  • 用 户 组: 普通用户
  • 注册时间: 2010-07-21 11:48
文章存档

2015年(1)

2014年(3)

2013年(4)

2012年(43)

2011年(44)

2010年(2)

分类: LINUX

2012-10-17 14:29:53

函数udp_push_pending_frames用于数据传输,该函数为数据包添加UDP包头,校验数据,将数据发送出去。

  1. static int udp_push_pending_frames(struct sock *sk)
  2. {
  3.     struct udp_sock *up = udp_sk(sk); // 将sk强制转化成struct udp_sock类型
  4.     struct inet_sock *inet = inet_sk(sk); //将sk强制转化成struct  inet_sock类型
  5.     struct flowi *fl = &inet->cork.fl;
  6.     struct sk_buff *skb;
  7.     struct udphdr *uh;
  8.     int err = 0;
  9.     int is_udplite = IS_UDPLITE(sk); //define IS_UDPLITE (__sk)(udp_sk(__sk) ->pcflag)
  10.     __wsum csum = 0;

  11.     //skb_peek 返回指向缓冲区链表的第一个节点指针,这里是拿到socket输出队列中的第一个sk_buff
  12.     if ((skb = skb_peek(&sk->sk_write_queue)) == NULL)
  13.         goto out;

  14.     /*
  15.      * Create a UDP header
  16.      */
  17.     // 得到UDP报文头地址,然后填充相应字段
  18.     uh = udp_hdr(skb);
  19.     uh->source = fl->fl_ip_sport;
  20.     uh->dest = fl->fl_ip_dport;
  21.     uh->len = htons(up->len); //将机器上的16位端口号转换成网络字节序
  22.     uh->check = 0;  
  
    // 如果is_udplite为真,就只计算不分数据的checksum
  1.     if (is_udplite)                  /* UDP-Lite */
  2.         csum = udplite_csum_outgoing(sk, skb);
  3.     //禁用checksum
  4.     else if (sk->sk_no_check == UDP_CSUM_NOXMIT) { /* UDP csum disabled */
  5.         skb->ip_summed = CHECKSUM_NONE;
  6.         goto send;

  7.     } else if (skb->ip_summed == CHECKSUM_PARTIAL) { /* UDP hardware csum *
  8.         udp4_hwcsum_outgoing(sk, skb, fl->fl4_src, fl->fl4_dst, up->len);
  9.         goto send;

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

  12.     // 再对UDP的伪首部进行校验和计算
  13.     uh->check = csum_tcpudp_magic(fl->fl4_src, fl->fl4_dst, up->len,
  14.                  sk->sk_protocol, csum);
  15.     //如果校验和为0,则用另一种零的表达方式(0xffff)来代替0,用于区分没有校验和的情况
  16.     if (uh->check == 0)
  17.         uh->check = CSUM_MANGLED_0;

  18. send:
  19.     // 调用IP网络层的输出函数,将所有sk_buff以一个IP报文发出
  20.     err = ip_push_pending_frames(sk);
  21.     if (err) {
  22.         if (err == -ENOBUFS && !inet->recverr) {
  23.             UDP_INC_STATS_USER(sock_net(sk),
  24.                      UDP_MIB_SNDBUFERRORS, is_udplite);
  25.             err = 0;
  26.         }
  27.     } else
  28.         UDP_INC_STATS_USER(sock_net(sk),
  29.                  UDP_MIB_OUTDATAGRAMS, is_udplite);
  30. out:
  31.     up->len = 0;
  32.     up->pending = 0;
  33.     return err;
  34. }

阅读(2932) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~