曾经的足迹——对CAN驱动中的NAPI机制的理解

2023-10-07 05:58

本文主要是介绍曾经的足迹——对CAN驱动中的NAPI机制的理解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

NAPI 是 Linux 上采用的一种提高网络处理效率的技术,它的核心概念就是不采用中断的方式读取数据,而代之以首先采用中断唤醒数据接收的服务程序,然后 通过poll的方法来轮询数据。采用NAPI技术可以大大改善短长度数据包接收的效率,减少中断触发的时间。

可以这样理解,在NAPI机制没有出现时,由于网络设备接收数据是采用中断方式的,假设每次数据包很小,小到只有几个字节。而刚好在1秒内有5000个这样的数据包。那么系统就是在1秒内产生5000个中断,这无疑给会占据CPU的大部分资源。NAPI的出现就是要解决这样的问题。

概念的东西就不多提了。下面开始源码之旅啦!

首先在分配CAN设备时,采用netif_napi_add函数注册轮询函数d_can_poll()

struct net_device *alloc_d_can_dev(int num_objs)

{

struct net_device *dev;

struct d_can_priv *priv;

 

dev = alloc_candev(sizeof(struct d_can_priv), num_objs/2);

if (!dev)

return NULL;

 

priv = netdev_priv(dev);

netif_napi_add(dev, &priv->napi, d_can_poll, num_objs/2);

 

priv->dev = dev;

priv->can.bittiming_const = &d_can_bittiming_const;

priv->can.do_set_mode = d_can_set_mode;

priv->can.do_get_berr_counter = d_can_get_berr_counter;

priv->can.ctrlmode_supported = (CAN_CTRLMODE_LOOPBACK |

CAN_CTRLMODE_LISTENONLY |

CAN_CTRLMODE_BERR_REPORTING |

CAN_CTRLMODE_3_SAMPLES);

 

return dev;

}

netif_napi_add()函数原型如下:

void netif_napi_add(struct net_device *dev, struct napi_struct *napi,

    int (*poll)(struct napi_struct *, int), int weight)

{

INIT_LIST_HEAD(&napi->poll_list);

napi->gro_count = 0;

napi->gro_list = NULL;

napi->skb = NULL;

napi->poll = poll;

napi->weight = weight;

list_add(&napi->dev_list, &dev->napi_list);

napi->dev = dev;

#ifdef CONFIG_NETPOLL

spin_lock_init(&napi->poll_lock);

napi->poll_owner = -1;

#endif

set_bit(NAPI_STATE_SCHED, &napi->state);

}

 

轮询函数d_can_poll()如下:

static int d_can_poll(struct napi_struct *napi, int quota)

{

int lec_type = 0;

int work_done = 0;

struct net_device *dev = napi->dev;

struct d_can_priv *priv = netdev_priv(dev);

 

if (!priv->irqstatus)

goto end;

 

/* status events have the highest priority */

if (priv->irqstatus == STATUS_INTERRUPT) {

priv->current_status = d_can_read(priv, D_CAN_ES);

 

/* handle Tx/Rx events */

if (priv->current_status & D_CAN_ES_TXOK)

d_can_write(priv, D_CAN_ES,

priv->current_status & ~D_CAN_ES_TXOK);

 

if (priv->current_status & D_CAN_ES_RXOK)

d_can_write(priv, D_CAN_ES,

priv->current_status & ~D_CAN_ES_RXOK);

 

/* handle state changes */

if ((priv->current_status & D_CAN_ES_EWARN) &&

(!(priv->last_status & D_CAN_ES_EWARN))) {

netdev_dbg(dev, "entered error warning state\n");

work_done += d_can_handle_state_change(dev,

D_CAN_ERROR_WARNING);

}

if ((priv->current_status & D_CAN_ES_EPASS) &&

(!(priv->last_status & D_CAN_ES_EPASS))) {

netdev_dbg(dev, "entered error passive state\n");

work_done += d_can_handle_state_change(dev,

D_CAN_ERROR_PASSIVE);

}

if ((priv->current_status & D_CAN_ES_BOFF) &&

(!(priv->last_status & D_CAN_ES_BOFF))) {

netdev_dbg(dev, "entered bus off state\n");

work_done += d_can_handle_state_change(dev,

D_CAN_BUS_OFF);

}

 

/* handle bus recovery events */

if ((!(priv->current_status & D_CAN_ES_BOFF)) &&

(priv->last_status & D_CAN_ES_BOFF)) {

netdev_dbg(dev, "left bus off state\n");

priv->can.state = CAN_STATE_ERROR_ACTIVE;

}

if ((!(priv->current_status & D_CAN_ES_EPASS)) &&

(priv->last_status & D_CAN_ES_EPASS)) {

netdev_dbg(dev, "left error passive state\n");

priv->can.state = CAN_STATE_ERROR_ACTIVE;

}

 

priv->last_status = priv->current_status;

 

/* handle lec errors on the bus */

lec_type = d_can_has_handle_berr(priv);

if (lec_type)

work_done += d_can_handle_bus_err(dev, lec_type);

} else if ((priv->irqstatus >= D_CAN_MSG_OBJ_RX_FIRST) &&

(priv->irqstatus <= D_CAN_MSG_OBJ_RX_LAST)) {

/* handle events corresponding to receive message objects */

work_done += d_can_do_rx_poll(dev, (quota - work_done));

} else if ((priv->irqstatus >= D_CAN_MSG_OBJ_TX_FIRST) &&

(priv->irqstatus <= D_CAN_MSG_OBJ_TX_LAST)) {

/* handle events corresponding to transmit message objects */

d_can_do_tx(dev);

}

 

end:

if (work_done < quota) {

napi_complete(napi);

/* enable all IRQs */

d_can_interrupts(priv, ENABLE_ALL_INTERRUPTS);

}

 

return work_done;

}

 

在中断处理函数中,先禁止接收中断,且告诉网络子系统,将以轮询方式快速收包,其中禁止接收中断完全由硬件功能决定,而告诉内核将以轮询方式处理包则是使用函数napi_schedule()。

static irqreturn_t d_can_isr(int irq, void *dev_id)

{

struct net_device *dev = (struct net_device *)dev_id;

struct d_can_priv *priv = netdev_priv(dev);

priv->irqstatus = d_can_read(priv, D_CAN_INT);

if (!priv->irqstatus)

return IRQ_NONE;

 

/* disable all interrupts and schedule the NAPI */

d_can_interrupts(priv, DISABLE_ALL_INTERRUPTS);

napi_schedule(&priv->napi);

 

return IRQ_HANDLED;

}

 

其中的napi_schedule_prep()函数是为了判定现在是否已经进入了轮询模式。

static inline void napi_schedule(struct napi_struct *n)

{

if (napi_schedule_prep(n))

__napi_schedule(n);

}

 

轮询功能的关闭则需要使用:

if (work_done < quota) {

napi_complete(napi);

/* enable all IRQs */

d_can_interrupts(priv, ENABLE_ALL_INTERRUPTS);

}

 

因为可能存在多个napi_struct的实例,要求每个实例能够独立的使能或者禁止。因此,需要驱动开发人员保证在网卡接口关闭时,禁止所有的napi_struct的实例。在d_can_open()函数中使用napi_enable(),在d_can_close()函数中使用napi_disable()

napi_enable(&priv->napi);

napi_disable(&priv->napi);

 

这篇关于曾经的足迹——对CAN驱动中的NAPI机制的理解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/156478

相关文章

深入理解C++ 空类大小

《深入理解C++空类大小》本文主要介绍了C++空类大小,规定空类大小为1字节,主要是为了保证对象的唯一性和可区分性,满足数组元素地址连续的要求,下面就来了解一下... 目录1. 保证对象的唯一性和可区分性2. 满足数组元素地址连续的要求3. 与C++的对象模型和内存管理机制相适配查看类对象内存在C++中,规

Spring使用@Retryable实现自动重试机制

《Spring使用@Retryable实现自动重试机制》在微服务架构中,服务之间的调用可能会因为一些暂时性的错误而失败,例如网络波动、数据库连接超时或第三方服务不可用等,在本文中,我们将介绍如何在Sp... 目录引言1. 什么是 @Retryable?2. 如何在 Spring 中使用 @Retryable

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

认识、理解、分类——acm之搜索

普通搜索方法有两种:1、广度优先搜索;2、深度优先搜索; 更多搜索方法: 3、双向广度优先搜索; 4、启发式搜索(包括A*算法等); 搜索通常会用到的知识点:状态压缩(位压缩,利用hash思想压缩)。

【生成模型系列(初级)】嵌入(Embedding)方程——自然语言处理的数学灵魂【通俗理解】

【通俗理解】嵌入(Embedding)方程——自然语言处理的数学灵魂 关键词提炼 #嵌入方程 #自然语言处理 #词向量 #机器学习 #神经网络 #向量空间模型 #Siri #Google翻译 #AlexNet 第一节:嵌入方程的类比与核心概念【尽可能通俗】 嵌入方程可以被看作是自然语言处理中的“翻译机”,它将文本中的单词或短语转换成计算机能够理解的数学形式,即向量。 正如翻译机将一种语言

Java ArrayList扩容机制 (源码解读)

结论:初始长度为10,若所需长度小于1.5倍原长度,则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1:数组默认长度         2:这是一个共享的空数组实例,用于明确创建长度为0时的ArrayList ,比如通过 new ArrayList<>(0),ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL

Linux_kernel驱动开发11

一、改回nfs方式挂载根文件系统         在产品将要上线之前,需要制作不同类型格式的根文件系统         在产品研发阶段,我们还是需要使用nfs的方式挂载根文件系统         优点:可以直接在上位机中修改文件系统内容,延长EMMC的寿命         【1】重启上位机nfs服务         sudo service nfs-kernel-server resta

【C++高阶】C++类型转换全攻略:深入理解并高效应用

📝个人主页🌹:Eternity._ ⏩收录专栏⏪:C++ “ 登神长阶 ” 🤡往期回顾🤡:C++ 智能指针 🌹🌹期待您的关注 🌹🌹 ❀C++的类型转换 📒1. C语言中的类型转换📚2. C++强制类型转换⛰️static_cast🌞reinterpret_cast⭐const_cast🍁dynamic_cast 📜3. C++强制类型转换的原因📝

【编程底层思考】垃圾收集机制,GC算法,垃圾收集器类型概述

Java的垃圾收集(Garbage Collection,GC)机制是Java语言的一大特色,它负责自动管理内存的回收,释放不再使用的对象所占用的内存。以下是对Java垃圾收集机制的详细介绍: 一、垃圾收集机制概述: 对象存活判断:垃圾收集器定期检查堆内存中的对象,判断哪些对象是“垃圾”,即不再被任何引用链直接或间接引用的对象。内存回收:将判断为垃圾的对象占用的内存进行回收,以便重新使用。

【Tools】大模型中的自注意力机制

摇来摇去摇碎点点的金黄 伸手牵来一片梦的霞光 南方的小巷推开多情的门窗 年轻和我们歌唱 摇来摇去摇着温柔的阳光 轻轻托起一件梦的衣裳 古老的都市每天都改变模样                      🎵 方芳《摇太阳》 自注意力机制(Self-Attention)是一种在Transformer等大模型中经常使用的注意力机制。该机制通过对输入序列中的每个元素计算与其他元素之间的相似性,