UDP socket流程(12)——udp_push_pending_frames

简介: 作者:gfree.wind@gmail.com博客:linuxfocus.blog.chinaunix.net本来按照昨天的想法,是想把ip_append_data以及之前遇到的问题和不解整理思考一下的,但今天还是想把send的流程走完,再总结比较好,那么就开始下一个API——udp_push_pending_frames吧。
作者:gfree.wind@gmail.com
博客:linuxfocus.blog.chinaunix.net

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

这个API用于将所有pending的数据用一个UDP 数据包发送出去。
  1. /*
  2.  * Push out all pending data as one UDP datagram. Socket is locked.
  3.  */
  4. static int udp_push_pending_frames(struct sock *sk)
  5. {
  6.     struct udp_sock *up = udp_sk(sk);
  7.     struct inet_sock *inet = inet_sk(sk);
  8.     struct flowi *fl = &inet->cork.fl;
  9.     struct sk_buff *skb;
  10.     struct udphdr *uh;
  11.     int err = 0;
  12.     int is_udplite = IS_UDPLITE(sk);
  13.     __wsum csum = 0;

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

  21.     /*
  22.      * Create a UDP header
  23.      */
  24.     /* 得到UDP报文头地址, 实际上仍然使用的是sk_buff的空间 */
  25.     uh = udp_hdr(skb);
  26.     /* 设置报文头的各个域*/
  27.     uh->source = fl->fl_ip_sport;
  28.     uh->dest = fl->fl_ip_dport;
  29.     uh->len = htons(up->len);
  30.     uh->check = 0;
      
     /* 
     下面是针对不同的checksum情况,进行计算checksum
     1. udplite:只计算部分数据的checksum,代替正常的UDP checksum(包含报文头和数据);
     2. checksum 被disabled:不需要计算checksum;
     3. 由硬件计算checksum;
     4. 正常的UDP checksum计算
     */
  1.     if (is_udplite)                  /* UDP-Lite */
  2.         csum = udplite_csum_outgoing(sk, skb);

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

  4.         skb->ip_summed = CHECKSUM_NONE;
  5.         goto send;

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

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

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

  11.     /* add protocol-dependent pseudo-header */
  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. }

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



目录
打赏
0
0
0
0
115
分享
相关文章
Python网络编程基础(Socket编程) UDP 发送和接收数据
【4月更文挑战第10天】对于UDP客户端而言,发送数据是一个相对简单的过程。首先,你需要构建一个要发送的数据报,这通常是一个字节串(bytes)。然后,你可以调用socket对象的`sendto`方法,将数据报发送到指定的服务器地址和端口。
Python网络编程基础(Socket编程)UDP客户端编程
【4月更文挑战第9天】在UDP通信中,客户端负责发送数据到服务器,并接收来自服务器的响应。与服务器不同,客户端通常不需要绑定到特定的地址和端口,因为它可以临时使用任何可用的端口来发送数据。下面,我们将详细讲解UDP客户端编程的基本步骤。
Python网络编程基础(Socket编程)创建UDP socket对象
【4月更文挑战第8天】在Python中创建UDP服务器涉及使用`socket`模块创建socket对象,如`udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)`,然后绑定到特定IP地址和端口,如`udp_socket.bind(('localhost', 12345))`。服务器通过`recvfrom`在无限循环中监听和接收数据报。这只是基础,实际应用还需处理接收、解析、响应及错误处理等。接下来可学习如何利用socket对象进行数据交互以构建完整服务器。
【网络】UDP回显服务器和客户端的构造,以及连接流程
【网络】UDP回显服务器和客户端的构造,以及连接流程
76 2
Linux基础-socket详解、TCP/UDP
综上所述,Linux下的Socket编程是网络通信的重要组成部分,通过灵活运用TCP和UDP协议,开发者能够构建出满足不同需求的网络应用程序。掌握这些基础知识,是进行更复杂网络编程任务的基石。
215 1
Java的Socket编程:TCP/IP与UDP深入探索
Java的Socket编程:TCP/IP与UDP深入探索
125 0
C语言 网络编程(七)UDP通信创建流程
本文档详细介绍了使用 UDP 协议进行通信的过程,包括创建套接字、发送与接收消息等关键步骤。首先,通过 `socket()` 函数创建套接字,并设置相应的参数。接着,使用 `sendto()` 函数向指定地址发送数据。为了绑定地址,需要调用 `bind()` 函数。接收端则通过 `recvfrom()` 函数接收数据并获取发送方的地址信息。文档还提供了完整的代码示例,展示了如何实现 UDP 的发送端和服务端功能。
【Socket】解决UDP丢包问题
UDP(用户数据报协议)是一种无连接的传输层协议,因其不保证数据包的顺序到达和不具备内置重传机制,导致在网络拥塞、接收缓冲区溢出或发送频率过快等情况下容易出现丢包现象。为应对这些问题,可以在应用层实现重传机制、使用前向纠错码等方法。这些方法在一定程度上可以缓解UDP通信中的丢包问题,提高数据传输的可靠性和效率。
解析TCP /UDP协议的 socket 调用的过程
【6月更文挑战第2天】该文介绍了传输层的两种主要协议TCP和UDP的区别。TCP是面向连接、可靠的,提供顺序无错的数据传输,而UDP则是无连接、不可靠的,不保证数据顺序或不丢失。
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等