dpdk自己实现了一个中断机制，例如定时器中断，uio中断。这个中断是应用层中断，而不是像linux内核实现的硬件中断；且dpdk实现的中断机制属于控制中断，用来实现一些控制操作，例如uio中断用来设置一些网卡的状态之类。网卡收发包过程，还是使用轮询的方式从网卡接收报文。

一、中断事件管理

dpdk实现了uio, 定时器alarm, vfio三种中断，且用链表来管理这些中断源。当应用层需要设置中断时，设置好中断的触发回调后就可以调用rte_intr_callback_register接口注册一个中断源到中断链表中；当应用层想取消某个中断源时，调用rte_intr_callback_unregister接口从中断源链表中移除一个中断源。内部会将中断源链表中的所有中断源描述符都加入到epoll实现的红黑树中，当相应中断源有事件发生时，epoll会调用这些中断源注册的回调函数。

1、中断源的设置

应用层通过调用rte_intr_callback_register接口，就可以将一个中断源注册到中断源链表intr_sources中。中断源事件回调callback也是一个链表，意思是同一个中断源可以重复注册，且每次注册都可以指定不同的回调函数，因此这也是一个链表。在这个中断源有事件触发时，会调用这个中断源上注册的所有中断回调函数。

在中断源加入到中断源链表后，还会通过写管道的方式，往管道里面写入一个数值，此时读管道事件就会从epoll中触发，这个读管道事件的实现方式是退出epoll机制，重新将这个新加入的中断源注册到epoll事件机制中。

int rte_intr_callback_register(struct rte_intr_handle *intr_handle,rte_intr_callback_fn cb, void *cb_arg)
{//创建中断源链表节点，并设置好中断触发时的回调函数callback = rte_zmalloc("interrupt callback list", sizeof(*callback), 0);callback->cb_fn = cb;callback->cb_arg = cb_arg;//将中断回调插入到已经存在的中断回调链表。中断事件回调也是一个链表，同一个中断源//可以重复注册，且每次注册都可以指定不同的回调TAILQ_FOREACH(src, &intr_sources, next) {if (src->intr_handle.fd == intr_handle->fd) {TAILQ_INSERT_TAIL(&(src->callbacks), callback, next);break;}}//不存在，则重新创建一个中断源，并插入到链表if (src == NULL){src = rte_zmalloc("interrupt source list", sizeof(*src), 0))；src->intr_handle = *intr_handle;TAILQ_INIT(&src->callbacks);TAILQ_INSERT_TAIL(&(src->callbacks), callback, next);TAILQ_INSERT_TAIL(&intr_sources, src, next);}//写管道的方式，通知epoll事件机制退出事件循环， 重新将新加入事件加入到epoll.write(intr_pipe.writefd, "1", 1);
}

2、中断源的卸载

如果应用层不再需要中断了，则调用rte_intr_callback_unregister接口将中断源卸载。中断源卸载那就很简单了，将中断源链表上的节点移除就好了。需要注意的是，如果一个中断源注册了多个中断回调，则只有在中断回调链表都卸载后，才会将这个中断源节点也给移除。

int rte_intr_callback_unregister(struct rte_intr_handle *intr_handle,rte_intr_callback_fn cb_fn, void *cb_arg)
{//卸载中断回调链表中的节点TAILQ_REMOVE(&src->callbacks, cb, next);rte_free(cb);//在这个中断源上的中断回调链表没有元素时，也卸载中断源节点TAILQ_REMOVE(&intr_sources, src, next);rte_free(src);//通知epoll事件循环， 将已经删除的中断源也从epoll中移除write(intr_pipe.writefd, "1", 1);
}

二、中断源事件的实现

1、中断初始化

rte_eal_intr_init接口用于中断的初始化，内部会创建一个读写管道，用来控制是否退出epoll机制。当应用层添加了新的中断源或者卸载了中断源，在上面提到的两个注册与卸载函数里面，会往管道写入数据，此时epoll读管道事件将会被触发，读取这个管道的内容后，从epoll中退出后，将新加的中断源注册到epoll, 或者将卸载的中断源从epoll移除。这些操作都是在子线程中完成的，由子线程来处理中断事件，主线程则处理报文的高速转发。

int rte_eal_intr_init(void)
{//创建读写管道，用来控制器是否退出epoll机制。当应用层添加了新的源或者卸载了中断源，//用来通知epoll返回，将新加的中断源注册到epoll, 或者将卸载的中断源从epoll移除pipe(intr_pipe.pipefd);//创建子线程，子线程处理所有的中断事件，主线性继续执行其他业务逻辑pthread_create(&intr_thread, NULL, eal_intr_thread_main, NULL);
}

2、epoll事件机制创建

eal_intr_thread_main是中断子线程的入口函数，内部会创建一个epoll句柄，并将管道描述符，中断源链表中的所有描述符都加入到epoll事件机制中。需要注意的是这个子线程是一个死循环，永远都不会退出。如果有新的中断源加入或者移除，则会关闭epoll句柄，然后重新创建epoll对象，重新将管道以及中断源链表中的描述符加入到epoll中，这是一个循环的过程。一句话：这个死循环是为了在有新的中断源加入或者移除时，能够重复创建epoll句柄以及将中断源加入到epoll中

//中断子线程入口
static __attribute__((noreturn)) void * eal_intr_thread_main(__rte_unused void *arg)
{//子线程死循环，永远不会退出for (;;){//创建epoll句柄int pfd = epoll_create(1);//将管道加入到epoll事件中epoll_ctl(pfd, EPOLL_CTL_ADD, intr_pipe.readfd, &pipe_event);//将中断源链表中的中断元素加入到epoll事件中TAILQ_FOREACH(src, &intr_sources, next){ev.events = EPOLLIN | EPOLLPRI;ev.data.fd = src->intr_handle.fd;epoll_ctl(pfd, EPOLL_CTL_ADD, src->intr_handle.fd, &ev);}eal_intr_handle_interrupts(pfd, numfds);//执行到这里，说明异常了或者有新的中断事件加入或者中断源被移除。先关闭epoll后重新创建close(pfd);}
}

3、epoll_wait等待中断事件发生

在将管道描述符，中断源链表中的所有描述符注册到epoll红黑树后，eal_intr_handle_interrupts内部会调用epoll_wait等待中断事件，管道事件的触发，这是一个异步的过程。需要注意的是这也是一个死循环，什么时候会退出呢? 还是上面提到的，在有新的中断源加入或者移除，会退出这个这个死循环。想想如果没有这个for死循环会发生什么事件呢？相当于每次epol_wait返回后，都需要关闭epoll句柄，重新创建epoll句柄，然后重新将管道以及中断源链表中的所有描述符加入到epoll中，这些系统调用也是要消耗性能的，只有在新加入中断源或者移除中断源时才需要这么做。如果都没有新加或者移除的中断源就没有必要这么做了。一句话：这个死循环是为了等待中断以及管道事件触发。

static void eal_intr_handle_interrupts(int pfd, unsigned totalfds)
{//这又是一个死循环，循环等待已经加入到epoll的事件被触发for(;;){nfds = epoll_wait(pfd, events, totalfds, EAL_INTR_EPOLL_WAIT_FOREVER);/* epoll_wait has at least one fd ready to read *///处理所有已经发生的中断事件if (eal_intr_process_interrupts(events, nfds) < 0){return;}   }
}

4、中断事件的处理

当epoll_wait返回后，说明有中断事件发生或者管道事件的发生，此时调用eal_intr_process_interrupts开始处理已经发生的事件。如果是管道事件，则直接退出epoll事件循环，这是优先级最高的事件。如果是中断源事件，则查找到相应的中断源，然后调用这个中断源注册的所有中断回调。

static int eal_intr_process_interrupts(struct epoll_event *events, int nfds)
{//循环处理多个已经触发的中断事件for (n = 0; n < nfds; n++) {//有新的中断事件加入或者移除时，退出事件循环，之后会重新创建epoll， 将新事件加入到epoll中if (events[n].data.fd == intr_pipe.readfd){int r = read(intr_pipe.readfd, buf.charbuf,   sizeof(buf.charbuf));return -1;}//查找中断源TAILQ_FOREACH(src, &intr_sources, next)if (src->intr_handle.fd == events[n].data.fd){break;}//读取内容bytes_read = read(events[n].data.fd, &buf, bytes_read);//读取内容后，调用这个中断源注册的所有中断回调TAILQ_FOREACH(cb, &src->callbacks, next){active_cb.cb_fn(&src->intr_handle, active_cb.cb_arg);}}
}

三、中断的使用

以一个定时器中断的例子来说明中断的使用。

1、定时器初始化

rte_eal_alarm_init函数用来初始化定时器，里面会创建一个定时器中断源。这个中断源在后面会加入到中断源链表中

//定时器初始化
int rte_eal_alarm_init(void)
{//创建定时器中断源intr_handle.type = RTE_INTR_HANDLE_ALARM;intr_handle.fd = timerfd_create(CLOCK_MONOTONIC, TFD_NONBLOCK);
}

2、创建定时器

当需要创建定时器时，调用rte_eal_alarm_set创建定时器，可以多次调用这个接口来创建多个定时器。内部会调用rte_intr_callback_register接口将定时器中断源加入到中断源链表中，定时器中断源的定时时间为定时器链表中第一个元素的时间，因为定时器链表是按照时间从小到达排序的，因此第一个元素时间是最小的。

顺便说下这个接口的实现吧，每次调用rte_eal_alarm_set这个接口，都会创建一个定时器节点struct alarm_entry，并将这个定时器节点按照时间从小到大的顺序添加到定时器链表alarm_list中。定时器链表中有多个定时器节点，但只有一个中断源，这个中断源来管理所有的定时器。也就是说当中断源被触发时，会调用alarm_time定时器中断源回调，这个回调里面会遍历定时器链表中的所有定时器节点，进而调用每个定时器回调。

//创建一个定时器
int rte_eal_alarm_set(uint64_t us, rte_eal_alarm_callback cb_fn, void *cb_arg)
{//首次注册一个定时器中断源，中断回调为eal_alarm_callback。//当定时器中断被触发时，这个回调会调用定时器链表中的所有已经到期的定时器回调if (!handler_registered) {ret |= rte_intr_callback_register(&intr_handle, eal_alarm_callback, NULL);}//设置定时器链表中是按照时间从小到达排除的，因此第一个元素时间是最小的if (LIST_FIRST(&alarm_list) == new_alarm){ret |= timerfd_settime(intr_handle.fd, 0, &alarm_time, NULL);}
}

当定时器中断源定时时间到后，定时器中断源事件会被触发，进而调用定时器中断源回调eal_alarm_callback。这个函数里面会遍历已经注册到定时器链表中的各个定时器，然后调用每个定时器的处理函数。

static void eal_alarm_callback(struct rte_intr_handle *hdl __rte_unused,void *arg __rte_unused)
{//遍历定时器链表，调用各个定时器的回调函数while ((ap = LIST_FIRST(&alarm_list)) !=NULL &&gettimeofday(&now, NULL) == 0 &&(ap->time.tv_sec < now.tv_sec || (ap->time.tv_sec == now.tv_sec &&ap->time.tv_usec <= now.tv_usec))){ap->cb_fn(ap->cb_arg);}
}

3、定时器删除

调用rte_eal_alarm_cancel接口可以将定时器从定时器链表中删除，函数实现很简单，这里就不再贴代码了。

到此为止，dpdk中断机制的实现已经分析完成了。

原文链接：https://blog.csdn.net/ApeLife/article/details/100126728

DPDK 中断机制（二十六）相关推荐

2021年大数据Hadoop（二十六）：YARN三大组件介绍
全网最详细的Hadoop文章系列,强烈建议收藏加关注! 后面更新文章都会列出历史文章目录,帮助大家回顾知识重点. 目录本系列历史文章前言 Yarn三大组件介绍 ResourceManager No ...
模板方法模式 Template method 行为型设计模式（二十六）
模板方法模式 Template method 上图为网上百度的一份简历模板截图相信大家都有求职的经历,那么必然需要简历,写简历的时候,很可能你会网上检索一份简历模板,使用此模板的格式,然后替换为你的 ...
窗口消息——Windows核心编程学习手札之二十六
窗口消息 --Windows核心编程学习手札之二十六 Windows允许一个进程至多建立10000个不同类型的用户对象(user object):图符.光标.窗口类.菜单.加速键表等,当一个线程调用一 ...
OpenCV学习笔记（二十六）——小试SVM算法ml OpenCV学习笔记（二十七）——基于级联分类器的目标检测objdect OpenCV学习笔记（二十八）——光流法对运动目标跟踪Video Ope
OpenCV学习笔记(二十六)--小试SVM算法ml 总感觉自己停留在码农的初级阶段,要想更上一层,就得静下心来,好好研究一下算法的东西.OpenCV作为一个计算机视觉的开源库,肯定不会只停留在数字图 ...
2008R2Win7管理二十六ADRMS客户端使用及侦错
2008R2Win7管理二十六ADRMS客户端使用及侦错预计我以后都没太多时间专研新技术和写文啦,尽量挤时间吧,有一篇放一篇吧,呵呵本篇介绍在win7客户端使用adrms来进行权限管理和侦错,在使 ...
SAP UI5 初学者教程之二十六 - OData 服务配合 Mock 服务器的使用步骤详解试读版
一套适合 SAP UI5 初学者循序渐进的学习教程教程目录 SAP UI5 本地开发环境的搭建 SAP UI5 初学者教程之一:Hello World SAP UI5 初学者教程之二:SAP UI5 ...
微信小程序把玩（二十六）navigator组件
微信小程序把玩(二十六)navigator组件原文:微信小程序把玩(二十六)navigator组件 navigator跳转分为两个状态一种是关闭当前页面一种是不关闭当前页面.用redirect属性指 ...
第一百二十六节，JavaScript，XPath操作xml节点
第一百二十六节,JavaScript,XPath操作xml节点学习要点: 1.IE中的XPath 2.W3C中的XPath 3.XPath跨浏览器兼容 XPath是一种节点查找手段,对比之前使用标准 ...
FreeSql （二十六）贪婪加载 Include、IncludeMany、Dto、ToList
贪婪加载顾名思议就是把所有要加载的东西一次性读取. 本节内容为了配合[延时加载]而诞生,贪婪加载和他本该在一起介绍,开发项目的过程中应该双管齐下,才能写出高质量的程序. Dto 映射查询 Select ...
第三百二十六节，web爬虫，scrapy模块,解决重复ur——自动递归url
第三百二十六节,web爬虫,scrapy模块,解决重复url--自动递归url 一般抓取过的url不重复抓取,那么就需要记录url,判断当前URL如果在记录里说明已经抓取过了,如果不存在说明没抓取过 ...

DPDK 中断机制（二十六）