【C语言】linux内核ipoib模块 - ipoib_ib_handle_rx_wc

一、中文注释

// 定义一个处理InfiniBand接收完成工作请求的函数
static void ipoib_ib_handle_rx_wc(struct net_device *dev, struct ib_wc *wc)
{// 通过网络设备获取私有数据结构struct ipoib_dev_priv *priv = ipoib_priv(dev);// 获取工作请求ID,并屏蔽掉接收操作的标志位unsigned int wr_id = wc->wr_id & ~IPOIB_OP_RECV;struct sk_buff *skb;u64 mapping[IPOIB_UD_RX_SG];union ib_gid *dgid;union ib_gid *sgid;// 调试输出接收完成信息ipoib_dbg_data(priv, "recv completion: id %d, status: %d\n",wr_id, wc->status);// 检查工作请求ID是否超出接收队列大小if (unlikely(wr_id >= priv->recvq_size)) {ipoib_warn(priv, "recv completion event with wrid %d (> %d)\n",wr_id, priv->recvq_size);return; // 超出则返回}// 获取与工作请求关联的socket缓冲区skb  = priv->rx_ring[wr_id].skb;// 检查工作请求的状态是否为成功if (unlikely(wc->status != IB_WC_SUCCESS)) {// 若失败且不是因为flush错误,打印警告信息if (wc->status != IB_WC_WR_FLUSH_ERR)ipoib_warn(priv,"failed recv event (status=%d, wrid=%d vend_err %#x)\n",wc->status, wr_id, wc->vendor_err);// 解除DMA映射并释放socket缓冲区ipoib_ud_dma_unmap_rx(priv, priv->rx_ring[wr_id].mapping);dev_kfree_skb_any(skb);// 将rx_ring中对应项的skb置为空priv->rx_ring[wr_id].skb = NULL;return; // 返回}// 复制DMA映射地址到本地变量memcpy(mapping, priv->rx_ring[wr_id].mapping,IPOIB_UD_RX_SG * sizeof(*mapping));/** 如果无法分配新的接收缓冲区,则丢弃此数据包* 并重用旧缓冲区。*/if (unlikely(!ipoib_alloc_rx_skb(dev, wr_id))) {// 增加丢弃的数据包计数++dev->stats.rx_dropped;// 跳转到重新提交接收请求的代码段goto repost;}// 调试输出接收到的数据长度和源LIDipoib_dbg_data(priv, "received %d bytes, SLID 0x%04x\n",wc->byte_len, wc->slid);// 解除DMA映射ipoib_ud_dma_unmap_rx(priv, mapping);// 设定skb数据长度skb_put(skb, wc->byte_len);/* 第一个dgid字节的值为0xff时代表多播 */dgid = &((struct ib_grh *)skb->data)->dgid;// 根据GRH判断消息类型(单播、多播或广播)if (!(wc->wc_flags & IB_WC_GRH) || dgid->raw[0] != 0xff)skb->pkt_type = PACKET_HOST;else if (memcmp(dgid, dev->broadcast + 4, sizeof(union ib_gid)) == 0)skb->pkt_type = PACKET_BROADCAST;elseskb->pkt_type = PACKET_MULTICAST;// 获取源GIDsgid = &((struct ib_grh *)skb->data)->sgid;/** 丢弃由此接口发送的数据包,即HCA已复制的多播数据包。*/if (wc->slid == priv->local_lid && wc->src_qp == priv->qp->qp_num) {int need_repost = 1;if ((wc->wc_flags & IB_WC_GRH) &&sgid->global.interface_id != priv->local_gid.global.interface_id)need_repost = 0;if (need_repost) {// 释放skb并跳转至重新提交接收请求dev_kfree_skb_any(skb);goto repost;}}// 移除GRH头skb_pull(skb, IB_GRH_BYTES);
#if (LINUX_VERSION_CODE < KERNEL_VERSION(3,14,0)) && ! defined(HAVE_SK_BUFF_CSUM_LEVEL)/* 仅适用于旧的内核版本,表示重新组装大小 */skb->truesize = SKB_TRUESIZE(skb->len);
#endif// 设置协议头skb->protocol = ((struct ipoib_header *) skb->data)->proto;// 添加伪头skb_add_pseudo_hdr(skb);// 更新接收统计信息++dev->stats.rx_packets;dev->stats.rx_bytes += skb->len;// 如果收到的是多播包,增加多播计数if (skb->pkt_type == PACKET_MULTICAST)dev->stats.multicast++;// 处理ARP协议包,用于路径发现if (unlikely(be16_to_cpu(skb->protocol) == ETH_P_ARP))ipoib_create_repath_ent(dev, skb, wc->slid);// 设置数据包关联的网络设备skb->dev = dev;// 如果设备支持接收校验和处理,且工作请求指示校验和ok,则跳过校验和处理if ((dev->features & NETIF_F_RXCSUM) &&likely(wc->wc_flags & IB_WC_IP_CSUM_OK))skb->ip_summed = CHECKSUM_UNNECESSARY;
#ifdef CONFIG_COMPAT_LRO_ENABLED_IPOIB// 如果设备支持大接收下偏移(LRO),则使用LRO处理skb,否则使用普通的接收处理if (dev->features & NETIF_F_LRO)lro_receive_skb(&priv->lro.lro_mgr, skb, NULL);elsenetif_receive_skb(skb);
#else// 使用NAPI通用接收处理接收到的数据包napi_gro_receive(&priv->recv_napi, skb);
#endif// 重新提交接收请求的代码段
repost:// 重用前面设置好的缓冲区,提交新的接收工作请求if (unlikely(ipoib_ib_post_receive(dev, wr_id)))// 如果提交失败,打印警告信息ipoib_warn(priv, "ipoib_ib_post_receive failed ""for buf %d\n", wr_id);
}

以上注释形式遵循C语言的单行注释模式,对函数中的每个主要步骤提供了简要的中文解释。此函数是针对IP over InfiniBand (IPoIB) 设备的InfiniBand接收完成处理函数。它处理从InfiniBand网络接收到的数据包,进行协议处理,并最终将收到的数据包发送到上层网络栈。此外,函数还负责根据当前的工作请求和状态更新设备的统计信息,并处理特殊的ARP数据包,进行资源回收以及重用缓冲区来提交新的接收请求。

二、中文讲解

这个函数`ipoib_ib_handle_rx_wc`是处理InfiniBand接口上的接收完成工作请求(Work Completion, WC)的函数,主要用于接收数据包并处理。下面将该函数的主要部分用中文解释:

1. 获取私有数据结构和工作请求ID(wr_id):

   struct ipoib_dev_priv *priv = ipoib_priv(dev);unsigned int wr_id = wc->wr_id & ~IPOIB_OP_RECV;

   提取出工作请求ID,这用于索引接收队列。

2. 日志记录:   

   ipoib_dbg_data(priv, "recv completion: id %d, status: %d\n", wr_id, wc->status);

   如果工作请求ID超出了预期范围,则记录一条警告信息。

3. 检查工作请求完成状态:

   if (unlikely(wc->status != IB_WC_SUCCESS)) { ... }

   如果状态不是成功的,清理相应的资源并返回。

4. 定位接收缓冲区并尝试分配新的RX缓冲区:

   skb  = priv->rx_ring[wr_id].skb;if (unlikely(!ipoib_alloc_rx_skb(dev, wr_id))) { goto repost; }

   如果分配失败,则丢弃这个数据包并重用旧的缓冲区。

5. 记录接收到的数据包大小和源本地ID(SLID):

   ipoib_dbg_data(priv, "received %d bytes, SLID 0x%04x\n", wc->byte_len, wc->slid);

6. 根据数据包第一个字节是否为0xff判断是否为多播,并设置skb的包类型:

   if (!(wc->wc_flags & IB_WC_GRH) || dgid->raw[0] != 0xff) { ... }

   根据比较目的全局ID(dgid),确认包的类型(单播、广播或者多播)。

7. 如果数据包是由本接口发送(例如多播包被IO控制器复制了),则丢弃该包:

   if (wc->slid == priv->local_lid && wc->src_qp == priv->qp->qp_num) { ... }

8. 从数据包中移除Global Routing Header (GRH):

   skb_pull(skb, IB_GRH_BYTES);

9. 设置数据包的协议类型,统计信息,并将包交付到网络层:

   skb->protocol = ((struct ipoib_header *) skb->data)->proto;netif_receive_skb(skb);

10. 在必要的情况下,重新将RX缓冲区提交给硬件:

    if (unlikely(ipoib_ib_post_receive(dev, wr_id))) { ... }

    如果重新提交RX缓冲区失败,则记录警告信息。
整体来说,这个函数负责管理InfiniBand接口接收到的数据包,包括分配和管理资源,以及将接收到的数据递交给更高层的网络协议处理。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/701591.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

探索未来:Web3如何改变我们的生活方式

在数字化的时代&#xff0c;技术的不断发展和创新已经成为了我们生活的常态。而在这个不断变革的过程中&#xff0c;区块链技术作为一种颠覆性的技术&#xff0c;正逐渐成为人们关注的焦点。作为区块链技术的下一代&#xff0c;Web3正日益崭露头角&#xff0c;成为了未来的发展…

橘子学es原理01之准备工作

es本身是具备很好的使用特性的&#xff0c;我指的是他的部署方面的&#xff0c;至于后期的使用和运维那还是很一眼难尽的。 我们从这一篇开始就着重于es的一些原理性的的一些探讨&#xff0c;当然我们也会有一些操作性的&#xff0c;业务性的会分为多个栏目来写。比如前面我写的…

Flutter开发进阶之Package

Flutter开发进阶之Package 通常我们在Flutter开发中需要将部分功能与整体项目隔离&#xff0c;一般有两种方案Plugin和Package&#xff0c;Application是作为主体项目&#xff0c;Module是作为原生项目接入Flutter模块。 当独立模块不需要与原生项目通讯只需要Plugin就可以&a…

【广度优先搜索】【网格】【割点】1263. 推箱子

作者推荐 视频算法专题 涉及知识点 广度优先搜索 网格 割点 并集查找 LeetCode:1263. 推箱子 「推箱子」是一款风靡全球的益智小游戏&#xff0c;玩家需要将箱子推到仓库中的目标位置。 游戏地图用大小为 m x n 的网格 grid 表示&#xff0c;其中每个元素可以是墙、地板或…

利用LaTex批量将eps转pdf、png转eps、eps转png、eps转svg、pdf转eps

1、eps转pdf 直接使用epstopdf命令&#xff08;texlive、mitex自带&#xff09;。 在cmd中进入到eps矢量图片的目录&#xff0c;使用下面的命令&#xff1a; for %f in (*.eps) do epstopdf "%f" 下面是plt保存eps代码&#xff1a; import matplotlib.pyplot as…

计算机网络面经-TCP的拥塞控制

写在前边 前边我们分享了网络分层协议、TCP 三次握手、TCP 四次分手。今天我们继续深入分享一下 TCP 中的拥塞控制。 对于 TCP 的拥塞控制,里边设计到很多细节,平平无奇的羊希望通过这一节能够将这部分内容串通起来,能够让你更深刻的记忆这部分内容。 思维导图 1、什么…

封装(encapsulation)

封装[encapsulation] 封装介绍封装好处封装的实现步骤&#xff08;三步&#xff09;入门案例封装与构造器 封装介绍 封装就是把抽象的数据[属性]和对数据的操作[方法]封装在一起&#xff0c;数据被保护在内部&#xff0c;程序的其它部分只有通过被授权的操作[方法]&#xff0c;…

vue项目的前端工程化思路webpack(持续更新中)

写在前面&#xff1a;现在的前端网页功能丰富&#xff0c;特别是SPA&#xff08;single page web application 单页应用&#xff09;技术流行后&#xff0c;JavaScript的复杂度增加和需要一大堆依赖包&#xff0c;还需要解决Scss&#xff0c;Less……新增样式的扩展写法的编译工…

DC与DCT DCG的区别

先进工艺不再wire load model进行静态时序分析&#xff0c;否则综合结果与后端物理电路差距很大&#xff0c;因此DC综合工具也进行了多次迭代&#xff0c;DC工具有两种模式&#xff0c;包括wire load mode和Topographical Mode&#xff0c;也就是对应的DC Expert和DC Ultra。 …

unity hub (第一部)初学配置

1、安装Unity Hub 2、设置中文 3、安装编辑器 4、新建项目 5、新建完成后进入编辑器 6、 编辑器设置中文 editPreferencesLanguages选择中文

机器学习基础(五)监督与非监督学习的结合

导语&#xff1a;上一节我们详细探索非监督学习的进阶应用&#xff0c;详情可见&#xff1a; 机器学习基础&#xff08;四&#xff09;非监督学习的进阶探索-CSDN博客文章浏览阅读613次&#xff0c;点赞15次&#xff0c;收藏13次。非监督学习像一位探险家&#xff0c;挖掘未标…

电路设计(25)——4位数字频率计的multisim仿真及PCB设计

1.设计要求 使用4位数码管&#xff0c;显示输入信号的频率。完成功能仿真后&#xff0c;用AD软件&#xff0c;画出原理图以及PCB。 2.电路设计 输入信号的参数为&#xff1a; 可见&#xff0c;输入为168HZ&#xff0c;测量值为170HZ&#xff0c;误差在可接受的范围内。 3.PCB设…

Bluesky数据采集框架-2

访问保存的数据 到此&#xff0c;自然想到了"我如何访问我保存的数据&#xff1f;"。从bluesky的视角&#xff0c;那真的不是bluesky的关注&#xff0c;但它是一个合理的问题&#xff0c;因此我们将强调一个特定的场景。 注意&#xff1a;本章假设你正在使用databr…

AI:134-基于深度学习的社交媒体图像内容分析

🚀点击这里跳转到本专栏,可查阅专栏顶置最新的指南宝典~ 🎉🎊🎉 你的技术旅程将在这里启航! 从基础到实践,深入学习。无论你是初学者还是经验丰富的老手,对于本专栏案例和项目实践都有参考学习意义。 ✨✨✨ 每一个案例都附带有在本地跑过的关键代码,详细讲解供…

C语言——实用调试技巧——第2篇——(第23篇)

坚持就是胜利 文章目录 一、实例二、如何写出好&#xff08;易于调试&#xff09;的代码1、优秀的代码2、示范&#xff08;1&#xff09;模拟 strcpy 函数方法一&#xff1a;方法二&#xff1a;方法三&#xff1a;有弊端方法四&#xff1a;对方法三进行优化assert 的使用 方法五…

Spring之AOP源码解析(下)

前言 在上一遍文章中,我们主要讲解了ProxyFactory在Spring完成AOP动态代理的过程中发挥的作用。这一篇我们主要讲解这些注解都是如何注入Advisors,然后分析这些Advisors生效的条件 注解都是如何注入Advisor并匹配的 EnableTransactionManagement注解 我们在之前提到EnableT…

STM32 TCP实现OTA

芯片&#xff1a;stm32f407 开发平台&#xff1a;stm32cubeide 上位机开发平台&#xff1a;visual studio 2017 1. FLASH分配 将flash划分为四个部分&#xff1a; bootloader: 0x8000000-0x800ffff app1: 0x8010000-0x805ffff app2: …

一流的财务:搞数据!!!(干货)

“三流财务给数据&#xff0c;二流财务给分析报告&#xff0c;一流财务给....&#xff08;解决方案&#xff09;“这些文章应该很多人都看到过&#xff0c;这个口号粗看好像很有道理&#xff0c;但笔者并不认同&#xff0c;因为大家都忽略了一个重要的概念&#xff1a;数据&…

什么是rouge metric

采用分类任务的指标评估生成任务的问题 举个例子&#xff0c;在一个seq2seq模型中&#xff0c;黄金标签是“police killed the gunman”&#xff0c;模型输出是"the gunman police killed"&#xff0c;两句话的意思是有差别的&#xff0c;但是从unigram的角度&#…

虚 拟 化原理

1 概念&#xff1a; ①通俗理解&#xff1a; 虚拟化是在硬件和操作系统之间的实践 ②通过对计算机的服务层级的理解&#xff0c;理解虚拟化概念 抽离层级之间的依赖关系&#xff08;服务器虚拟化&#xff09; 2 虚拟化分类 ①按架构分类 ◆寄居架构&#xff1a;装在操作系统上…