内核中的UDP socket流程(11)——ip_append_data

简介: 作者:gfree.wind@gmail.com博客:linuxfocus.blog.chinaunix.net继续ip_append_data,        if (copy > length)             copy = length;         if (!(rt->dst.
+关注继续查看
作者:gfree.wind@gmail.com
博客:linuxfocus.blog.chinaunix.net

继续ip_append_data,
  1.         if (copy > length)
  2.             copy = length;

  3.         if (!(rt->dst.dev->features&NETIF_F_SG)) {
  4.             /* 如果网卡不支持Scatter/gather特性,直接拷贝数据 */
  5.             unsigned int off;

  6.             off = skb->len;
  7.             if (getfrag(from, skb_put(skb, copy),
  8.                     offset, copy, off, skb) 0) {
  9.                 __skb_trim(skb, off);
  10.                 err = -EFAULT;
  11.                 goto error;
  12.             }
  13.         } else {
  14.             /* 如果支持Scatter/gather特性 */
      
             /* 得到已储存的buffer个数 */
  1.             int i = skb_shinfo(skb)->nr_frags;
  2.             skb_frag_t *frag = &skb_shinfo(skb)->frags[i-1];
  3.             /* 得到物理页面的地址 */
  4.             struct page *page = sk->sk_sndmsg_page;
  5.             int off = sk->sk_sndmsg_off;
  6.             unsigned int left;

  7.             if (page && (left = PAGE_SIZE - off) > 0) {
  8.                 /* 该页还有空余空间,可以填充一部分数据 */
                  
                 /* 如果要拷贝的长度大于剩余空间,调整拷贝的长度 */
  1.                 if (copy >= left)
  2.                     copy = left;
  1.                 if (page != frag->page) {
  2.     /* 此次数据与sock上次缓冲数据不是位于同一物理页面 */
  3.                     if (i == MAX_SKB_FRAGS) {
  4.                         /* 超过了缓存数据最大个数 */
  5.                         err = -EMSGSIZE;
  6.                         goto error;
  7.                     }
  8.                     get_page(page);
  9.     /* 将数据填充到物理页 */
  10.                     skb_fill_page_desc(skb, i, page, sk->sk_sndmsg_off, 0);
  11.                     frag = &skb_shinfo(skb)->frags[i];
  12.                 }
  13.             } else if (i MAX_SKB_FRAGS) {
  14.                 /* 将拷贝长度调整为物理页最大值 */
  15.                 if (copy > PAGE_SIZE)
  16.                     copy = PAGE_SIZE;
  17.                 /* 分配一个新的物理页 */
  18.                 page = alloc_pages(sk->sk_allocation, 0);
  19.                 if (page == NULL) {
  20.                     err = -ENOMEM;
  21.                     goto error;
  22.                 }
  23. /* 保存物理页地址 */
  24.                 sk->sk_sndmsg_page = page;
  25.                 sk->sk_sndmsg_off = 0;
                 /* 填充物理页 */
  1.                 skb_fill_page_desc(skb, i, page, 0, 0);
  2.                 frag = &skb_shinfo(skb)->frags[i];
  3.             } else {
  4.                 err = -EMSGSIZE;
  5.                 goto error;
  6.             }
             /* 调用getfrag填充数据 */
  1.             if (getfrag(from, page_address(frag->page)+frag->page_offset+frag->size, offset, copy, skb->len, skb) 0) {
  2.                 err = -EFAULT;
  3.                 goto error;
  4.             }
     /* 调整各个偏移以及长度 */
  1.             sk->sk_sndmsg_off += copy;
  2.             frag->size += copy;
  3.             skb->len += copy;
  4.             skb->data_len += copy;
  5.             skb->truesize += copy;
  6.             atomic_add(copy, &sk->sk_wmem_alloc);
  7.         }
  8.         /* 继续下一个 */
  9.         offset += copy;
  10.         length -= copy;
  11.     }

  12.     return 0;

  13. error:
  14.     inet->cork.length -= length;
  15.     IP_INC_STATS(sock_net(sk), IPSTATS_MIB_OUTDISCARDS);
  16.     return err;
看到这里,这个函数就已经结束了。在之前的学习过程中,有些不明白的问题,或者干脆理解错了的东西,在完全看完这个函数之后,已经有了新的认识。

明天,我会对这些问题进行整理,并总结一下这个函数。




目录
相关文章
|
2月前
|
域名解析 存储 移动开发
TCP socket && UDP && TCP协议 && IP协议 && 以太网等
TCP socket && UDP && TCP协议 && IP协议 && 以太网等
20 0
|
2月前
|
安全 网络协议 Java
Thread类的用法 && 线程安全 && 多线程代码案例 && 文件操作和 IO && 网络原理初识 &&UDP socket
Thread类的用法 && 线程安全 && 多线程代码案例 && 文件操作和 IO && 网络原理初识 &&UDP socket
17 0
|
10月前
|
监控 网络协议 安全
一文了解HTTP、HTTPS、TCP、UDP、Websocket(论点:概念、通信流程、异同点、应用领域)
一文了解HTTP、HTTPS、TCP、UDP、Websocket(论点:概念、通信流程、异同点、应用领域)
udp客户端收发数据流程
1、创建客户端socket开始进行通讯。2、这时服务端应该先启动,并在知道服务端的ip以及端口号的时候才能进行通讯。3、本地不需要绑定ip以及端口号,在用此套接字对象发送消息的时候会自动分配活动端口(1024-65535) 每次重启程序可能每次都不一样。
1252 0
|
缓存 网络协议
udp服务端收发数据流程
1、创建服务端的socket以便开始通讯。2、绑定ip以及端口号,这样客户端才能找到这个程序。3、因为本地网卡不止一个所以尽量不写死,一般用""空来表示所有本地网卡。4、接下来开始通过绑定的ip以及端口开始监听消息,设置最大接收1024字节消息,以防文件过大,占满网络缓存区。
1263 0
|
Linux
UDP socket流程(14)——ip_local_out及其调用的函数
作者:gfree.wind@gmail.com 博客:linuxfocus.blog.chinaunix.net ip_local_out的代码很短 int ip_local_out(struct sk_buff *skb) {     int err;     /*      调用netfilter的hook检查该包是否可以发送。
1037 0
UDP socket流程(13)——ip_push_pending_frames
作者:gfree.wind@gmail.com 博客:linuxfocus.blog.chinaunix.net 今天开始学习新的函数ip_push_pending_frames,这个函数会被icmp_push_reply,ip_send_reply,raw_sendmsg,和udp_push_pending_frames调用。
950 0
|
API
UDP socket流程(12)——udp_push_pending_frames
作者:gfree.wind@gmail.com博客:linuxfocus.blog.chinaunix.net 本来按照昨天的想法,是想把ip_append_data以及之前遇到的问题和不解整理思考一下的,但今天还是想把send的流程走完,再总结比较好,那么就开始下一个API——udp_push_pending_frames吧。
1205 0
|
网络安全 网络虚拟化
内核中的UDP socket流程(10)——ip_append_data
作者:gfree.wind@gmail.com 博客:linuxfocus.blog.chinaunix.net 现在换一种风格,把一些对代码的解读直接写到代码段。那样看起来可能更好 继续ip_append_data,     /* hh_len是hardware header...
1161 0
|
网络协议
内核中的UDP socket流程(9)——ip_append_data
作者:gfree.wind@gmail.com 原文:http://blog.chinaunix.net/space.php?uid=23629988&do=blog&id=96739 下面开始分析ip_append_data这个函数。
1641 0