码迷，mamicode.com
首页 > 系统相关 > 详细

linux中断处理下文：软中断tasklet机制分析

时间：2014-10-21 21:38:24      阅读：352      评论：0      收藏：0      [点我收藏+]

标签：linux中断处理   软中断   tasklet   

参考：

《Linux内核设计与实现》

http://blog.csdn.net/fontlose/article/details/8279113

http://blog.chinaunix.net/uid-27212029-id-3386692.html


tasklet是中断处理下半部分最常用的一种方法，驱动程序一般先申请中断，在中断处理函数内完成中断上半部分的工作后调用tasklet。tasklet有如下特点：


1.tasklet只可以在一个CPU上同步地执行，不同的tasklet可以在不同地CPU上同步地执行。
2.tasklet的实现是建立在两个软件中断的基础之上的，即HI_SOFTIRQ和TASKLET_SOFTIRQ，本质上没有什么区别，只不过HI_SOFTIRQ的优先级更高一些
3.由于tasklet是在软中断上实现的，所以像软中断一样不能睡眠、不能阻塞，处理函数内不能含有导致睡眠的动作，如减少信号量、从用户空间拷贝数据或手工分配内存等。
4.一个 tasklet 能够被禁止并且之后被重新使能; 它不会执行直到它被使能的次数与被禁止的次数相同.
5.tasklet的串行化使tasklet函数不必是可重入的，因此简化了设备驱动程序开发者的工作。

6.每个cpu拥有一个tasklet_vec链表，具体是哪个cpu的tasklet_vec链表，是根据当前线程是运行在哪个cpu来决定的。


tasklet是驱动程序实现可延迟函数的首选方法，tasklet建立在HI_SOFTIRT和TASKLET_SOFTIRQ两个软中断上。
原理
tasklet和高优先级的tasklet分别存放在tasklet_vec和tasklet_hi_vec数组中，二者都包含类型为tasklet_head的
NR_CPUS个元素，每个元素都是指向tasklet描述符链表的指针。
执行过程
HI_SOFTIRQ软中断相关的软中断函数是tasklet_hi_action(),而与TASKLET_SOFTIRQ相关的函数是tasklet_action()
     1.禁止本地中断
     2.获得本地CPU的逻辑号n
     3.把tasklet_vec[n]或tasklet_hi_vec[n]所指向的链表的地址存入局部变量list
     4.把tasklet_vec[n]或tasklet_hi_vec[n]的值赋为NULL，因此已调度的tasklet描述符链表被清空
     5.打开本地中断
     6.对于list所指向的每个tasklet描述符
            a.在多处理器系统上，检查tasklet的TASKLET_STATE_RUN标志。
                    if标志被设置，list重新插入结构数组，并激活TASKLET_SOFTIRQ或HI_SOFTIRQ软中断，这个tasklet
    被延迟
                    else 设置TASKLET_STATE_RUN标志，以便tasklet不能在其他CPU上运行            
            b.通过查看tasklet描述符的count字段，看tasklet是否被禁止。如果是清TASKLET_STATE_RUN标志，把
    list重新插入结构数组，并激活相应的软中断。
            c.如果tasklet被激活，清TASKLET_STATE_SCHED标志，并执行tasklet函数
编写一个设备驱动程序的步骤
1.分配一个新的tasklet_struct数据结构，并用tasklet_init()初始化它；
2.实现tasklet函数
3.禁止或使能tasklet

tasklet结构体

[cpp] view plaincopyprint?
  1. struct tasklet_struct  
  2. {  
  3.     struct tasklet_struct *next;  
  4.     unsigned long state;  
  5.     atomic_t count;  
  6.     void (*func)(unsigned long);  
  7.     unsigned long data;  
  8. };  
  9.   
  10. tasklet结构变量是tasklet_vec链表的一个节点，next是链表的下一节点，state使用了两个位如下  
  11. enum  
  12. {  
  13.     TASKLET_STATE_SCHED,    /* 1已经被调度，0表示还没调度*/  
  14.     TASKLET_STATE_RUN   /* 1tasklet正在执行，0表示尚未执行，只针对SMP有效,单处理器无意义 */  
  15. };  
  16.   
  17. count用于禁止使能，每禁止一次计数加一，没使能一次计数减一，只有禁止次数和使能次数一样（count等于0）时tasklet才会执行调用函数。  
  18. func 执行函数不能有导致睡眠、不能阻塞的代码。  
  19. data 执行函数的参数  


tasklet的定义

[cpp] view plaincopyprint?
  1. 定义时初始化     
  2.     定义变量名为name的tasklets_struct变量，并初始化调用函数为func，参数为data，使能tasklet  
  3.     DECLARE_TASKLET(name, func, data);     #define DECLARE_TASKLET(name, func, data) \  
  4.     struct tasklet_struct name = { NULL, 0, ATOMIC_INIT(0), func, data }  
  5.   
  6.     定义变量名为name的tasklets_struct变量，并初始化调用函数为func，参数为data，禁止tasklet  
  7.     DECLARE_TASKLET_DISABLED(name, func, data)；  
  8.     #define DECLARE_TASKLET_DISABLED(name, func, data) \  
  9.     struct tasklet_struct name = { NULL, 0, ATOMIC_INIT(1), func, data }  
  10.   
  11. 运行中初始化    先定义    struct tasklet_struct name ；  
  12.     后初始化    
  13.   
  14. void tasklet_init(struct tasklet_struct *t,void (*func)(unsigned long), unsigned long data)  
  15. {  
  16.     t->next = NULL;              //  
  17.     t->state = 0;                //设置为未调度 未运行    
  18.     atomic_set(&t->count, 0);    //默认使能  
  19.     t->func = func;              //调用函数  
  20.     t->data = data;              //调用函数参数  
  21. }  

tasklet的调用过程

[cpp] view plaincopyprint?
  1. static inline void tasklet_schedule(struct tasklet_struct *t)；使用此函数即可完成调用  
  2. static inline void tasklet_schedule(struct tasklet_struct *t)  
  3. {  
  4.     /*test_and_set_bit设置调度位TASKLET_STATE_SCHED，test_and_set_bit返回t->state设置前状态，如果设置前状态为1（已被调用）那么直接退出否则进入__tasklet_schedule函数*/  
  5.     if (!test_and_set_bit(TASKLET_STATE_SCHED, &t->state))  
  6.         __tasklet_schedule(t);  
  7. }  
  8.   
  9.   
  10. void fastcall __tasklet_schedule(struct tasklet_struct *t)  
  11. {  
  12.     unsigned long flags;  
  13.     local_irq_save(flags);                      //关中断保存中断状态  
  14.     t->next = __get_cpu_var(tasklet_vec).list;  //这两行用于将新插入的节点 放置在tasklet_vec链表的头部  
  15.     __get_cpu_var(tasklet_vec).list = t;        //   
  16.     raise_softirq_irqoff(TASKLET_SOFTIRQ);      //触发一个软终端  
  17.     local_irq_restore(flags);                   //使能中断的同时还恢复了由 local_irq_save() 所保存的中断状态  
  18. }  
  19. 至此调度函数已经触发了一个软中断，具体中断函数看tasklet的初始化  
  20. void __init softirq_init(void)  
  21. {  
  22.         open_softirq(TASKLET_SOFTIRQ, tasklet_action, NULL);//可以看到软中断触发后会执行tasklet_action这个函数  
  23.         open_softirq(HI_SOFTIRQ, tasklet_hi_action, NULL);  
  24. }  
  25.   
  26.   
  27. static void tasklet_action(struct softirq_action *a)  
  28. {  
  29.     struct tasklet_struct *list;  
  30.   
  31.     local_irq_disable();                       //这里先关中断 保证原子操作  
  32.     list = __get_cpu_var(tasklet_vec).list;    //取出tasklet_vec链表表头  
  33.     __get_cpu_var(tasklet_vec).list = NULL;    //因为下面将会一次处理完，这里可以预先清空tasklet_vec链表，对于为处理完的会重新加入链表  
  34.                                                //也可以实现在tasklet的处理函数中重新加入自己。  
  35.     local_irq_enable();  
  36.   
  37.   
  38.   
  39.     while (list) {  
  40.         struct tasklet_struct *t = list;       //取一节点  
  41.   
  42.         list = list->next;                     //循环遍历全部节点   
  43.   
  44.         if (tasklet_trylock(t)) {              //这里只是测试TASKLET_STATE_RUN标记，防止tasklet重复调用    
  45.                                                //疑问：这里如果判断tasklet已经在上运行了，trylock失败，那么为什么后面会被重新加入链表呢，那不是下次又执行了？  
  46.             if (!atomic_read(&t->count)) {     //疑问: 如果tasklet被禁止了那么后面有把它加回链表中重新触发一次软中断，这样不是一直有软中断了吗？为什么不在禁止的时候移出链表，使能时候在加入呢？    
  47.                 if (!test_and_clear_bit(TASKLET_STATE_SCHED, &t->state)) //检查可调度位是否设置了，正常应该设置了的  
  48.                      BUG();                     
  49.                 t->func(t->data);              //处理调用函数  
  50.                 tasklet_unlock(t);             //清TASKLET_STATE_RUN标记  
  51.                 continue;  
  52.             }  
  53.             tasklet_unlock(t);  
  54.         }  
  55.   
  56.         local_irq_disable();  
  57.         t->next = __get_cpu_var(tasklet_vec).list; //对于trylock失败和tasklet禁止的节点会被重新加入链表  
  58.         __get_cpu_var(tasklet_vec).list = t;  
  59.         __raise_softirq_irqoff(TASKLET_SOFTIRQ);   //发起新的软中断，这里有两条链表一条是处理中的链表list，一个是当前tasklet_vec中的链表，当出现不能处理的节点时将节点重新加入tasklet_vec中后发起新的软中断，那么未处理的节点也会在下次中断中处理。  
  60.         local_irq_enable();  
  61.     }  
  62. }  

相关函数

[cpp] view plaincopyprint?
  1. /*和tasklet_disable类似，但是tasklet可能仍然运行在另一个 CPU */  
  2. static inline void tasklet_disable_nosync(struct tasklet_struct *t)  
  3. {  
  4.     atomic_inc(&t->count);      //减少计数后，t可能正在运行  
  5.     smp_mb__after_atomic_inc(); //保证在多处理器时同步  
  6. }  
  7. /*函数暂时禁止给定的tasklet被tasklet_schedule调度，直到这个tasklet被再次被enable；若这个tasklet当前在运行, 这个函数忙等待直到这个tasklet退出*/  
  8.   
  9. static inline void tasklet_disable(struct tasklet_struct *t){  
  10.    tasklet_disable_nosync(t);   
  11.    tasklet_unlock_wait(t);  //等待TASKLET——STATE_RUN标记清零     
  12.    smp_mb();  
  13. }  
  14.   
  15. static inline int tasklet_trylock(struct tasklet_struct *t){  
  16.    return !test_and_set_bit(TASKLET_STATE_RUN, &(t)->state);  
  17. }  
  18.   
  19. static inline void tasklet_unlock(struct tasklet_struct *t){     
  20.         smp_mb__before_clear_bit();       
  21.         clear_bit(TASKLET_STATE_RUN, &(t)->state);  
  22. }  
  23.   
  24. static inline void tasklet_unlock_wait(struct tasklet_struct *t){  
  25.     while (test_bit(TASKLET_STATE_RUN, &(t)->state)) {  
  26.           barrier();   
  27.      }  
  28. }  
  29.   
  30. /*使能一个之前被disable的tasklet；若这个tasklet已经被调度, 它会很快运行。tasklet_enable和tasklet_disable必须匹配调用, 因为内核跟踪每个tasklet的"禁止次数"*/   
  31. static inline void tasklet_enable(struct tasklet_struct *t)  
  32. {  
  33.     smp_mb__before_atomic_dec();  
  34.     atomic_dec(&t->count);  
  35. }  
  36.   
  37. /*和tasklet_schedule类似，只是在更高优先级执行。当软中断处理运行时, 它处理高优先级 tasklet 在其他软中断之前，只有具有低响应周期要求的驱动才应使用这个函数, 可避免其他软件中断处理引入的附加周期*/  
  38. void tasklet_hi_schedule(struct tasklet_struct *t);  
  39.   
  40. /*确保了 tasklet 不会被再次调度来运行，通常当一个设备正被关闭或者模块卸载时被调用。如果 tasklet 正在运行, 这个函数等待直到它执行完毕。若 tasklet 重新调度它自己，则必须阻止在调用 tasklet_kill 前它重新调度它自己，如同使用 del_timer_sync*/  
  41. void tasklet_kill(struct tasklet_struct *t)  
  42. {  
  43.     if (in_interrupt())  
  44.         printk("Attempt to kill tasklet from interrupt\n");  
  45.   
  46.         while (test_and_set_bit(TASKLET_STATE_SCHED, &t->state)) { //检测t是否被调度  
  47.         do  
  48.             yield();  
  49.         while (test_bit(TASKLET_STATE_SCHED, &t->state));          //等待t调度位清零，还未执行调用函数  
  50.     }  
  51.     tasklet_unlock_wait(t);                                        //等待t调用函数执行完  
  52.     clear_bit(TASKLET_STATE_SCHED, &t->state);                     //函数调用完可能t被重新加入链表，所以再清一次保证不再调用  
  53. }  
  54. 这个函数不是真的去杀掉被调度的tasklet，而是保证tasklet不再调用  

linux中断处理下文：软中断tasklet机制分析

标签：linux中断处理   软中断   tasklet   

原文地址：http://blog.csdn.net/hustyangju/article/details/40350145
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！