Chinaunix首页 | 论坛 | 博客
  • 博客访问: 403136
  • 博文数量: 96
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 415
  • 用 户 组: 普通用户
  • 注册时间: 2015-05-22 09:08
个人简介

最近的研究方向:Nginx

文章分类
文章存档

2017年(2)

2016年(59)

2015年(35)

我的朋友

分类: LINUX

2016-08-24 21:09:45

原文:

完成量(completion)机制基于等待队列,内核利用这个机制等待某一个操作结束,这两种机制使用得都比较频繁,主要用于设备的驱动程序。完成量与信号量有些相似,但完成量是基于等待队列实现的。

我们只感兴趣完成量的接口。在场景中有两个参与者,一个在等待某操作的完成,而另一个在操作完成时发出声明,实际上,这已经被简化过了。实际上,可以有任意数目的进程等待操作完成,为表示进程等待的即将完成的『某操作』,内核使用了complietion数据结构,代码如下:

点击(此处)折叠或打开

  1. <kernel/completion.h>

  2. struct completion
  3. {
  4.     unsigned int done;
  5.     wait_queue_head_t wait;
  6. };
我们可以看到wait变量是一个wait_queue_head_t结构体,是等待队列链表的头,done是一个计数器。每次调用completion时,该计数器就加1,仅当done等于0时,wait_for系列函数才会使调用进程进入睡眠。实际上,这意味着进程无需等待已经完成的事件。
其中wait_queue_head_t已经在等待队列中记录过了,代码如下:

击(此处)折叠或打开

  1. <linux/wait.h>

  2. struct __wait_queue_head
  3. {
  4.     spinlock_t lock; 
  5.     struct list_head task_list; 
  6. }; 

  7. typedef struct __wait_queue_head wait_queue_head_t;
init_completion()函数用于初始化一个动态分配的completion实例,而DECLARE_COMPLETION宏用来建立该数据结构的静态实例。init_completion()函数代码如下:

点击(此处)折叠或打开

  1. <kernel/completion.h>

  2. static inline void init_completion(struct completion *x) 
  3. { 
  4.     x->done = 0; 
  5.     init_waitqueue_head(&x->wait); 
  6. }
从上面代码中可以看到,初始化完成量会将done字段初始化为0,并且初始化wait链表。进程可以用wait_for_completion添加到等待队列,进程在其中等待,并以独占睡眠状态直到请求被内核的某些部分处理,这些函数都需要一个completion实例:

点击(此处)折叠或打开

  1. <kernel/completion.h>

  2. extern void wait_for_completion( struct completion *); 
  3. extern int wait_for_completion_interruptible( struct completion *x); 
  4. extern int wait_for_completion_killable( struct completion *x); 
  5. extern unsigned long wait_for_completion_timeout( struct completion *x, unsigned long timeout); 
  6. extern unsigned long wait_for_completion_interruptible_timeout( struct completion *x, unsigned long timeout); 
  7. extern bool try_wait_for_completion( struct completion *x); 
  8. extern bool completion_done( struct completion *x); 
  9. extern void complete( struct completion *); 
  10. extern void complete_all( struct completion *);
通常进程在等待事件的完成时处于不可中断状态,但如果使用wait_for_completion_interruptible可以改变这一设置,如果进程被中断,则函数返回-ERESTARTSYS,否则返回0.

wait_for_completion_timeout等待一个完成事件发送,但提供了超时的设置,如果等待时间超过了这一设置,则取消等待。这有助于防止无限等待某一时间,如果在超时之间就已经完成,函数就返回剩余时间,否则就返回0。

wait_for_completion_interruptible_timeout是前两种的结合体。

在请求由内核的另一部分处理之后,必须调用complete或者complete_all来唤醒等待的进程。因为每次调用只能从完成量的等待队列移除一个进程,对n个等待进程来说,必须调用函数n次。另一方面,complete_all会唤醒所有等待该完成的进程。

除此之外,还有complete_and_exit方法,该方法是一个小的包装起,首先调用complete,然后调用do_exit结束内核线程。

点击(此处)折叠或打开

  1. <kernel/exit.c>

  2. NORET_TYPE void complete_and_exit( struct completion *comp, long code) 
  3. { 
  4.     if (comp) complete(comp); 
  5.     do_exit(code); 
  6. }

completion结构体中,done是一个计数器。complete_all的工作方式与之类似,但它会将计数器设置为最大的可能值,这样,在事件完成后调用wait_for系列函数的进程将永远不会睡眠。



EOF
阅读(4066) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~