Chinaunix首页 | 论坛 | 博客
  • 博客访问: 313463
  • 博文数量: 72
  • 博客积分: 1851
  • 博客等级: 上尉
  • 技术积分: 1464
  • 用 户 组: 普通用户
  • 注册时间: 2010-09-16 17:50
文章分类

全部博文(72)

文章存档

2013年(1)

2012年(17)

2011年(51)

2010年(3)

分类: C/C++

2012-06-02 23:56:35

select中的timeout机制

do_select函数内部有一个遍历fd的轮询,对其中的每一个调用对应的poll驱动,调用完成之后就会立刻返回,部分代码如下:

  1. for(j = 0;j < __NFDBITS;++j,++i,bit <<=1) {
  2.     ….
  3.     file = fget_light(i,&fput_needed);
  4.     …
  5.     //调用之后就会立刻返回
  6.     (*f_op->poll)(file,wait);
  7.     //判断之后,开始下一个轮询
  8.     ….
  9. }
  10. //当轮询完成后,开始进行,检查是否有抢占进程
  11. ...
  12. cond_resched();
  13. //接着开始判断获取的可读写事件情况,超时等情况,决定是否进行超时睡眠等待
  14. ..
  15. if(retval || time_out || signal_pending(current))
  16.     break;
  17. ..
  18. if(!poll_schedule_timeout(&table,TASK_INTERRUPTIBLE,to,slack))
  19.     time_out = 1;
  20. }
  21. .....

这样就完成了超时机制的实现,实际上也就是询一遍,发现是否有就绪事件来决定是否睡眠或返回.

2.poll驱动中的wait参数作用

在编写设备驱动实现poll时,基本原型如下:

点击(此处)折叠或打开

  1. static unsigned int dev_poll(struct file *filp,poll_table *wait)
  2. {
  3. ...
  4. poll_wait(filp,&dev->inq,wait);
  5. poll_wait(filp,&dev->outq,wait);
  6. //判断是否有就绪事件
  7. if(condition)
  8.     mask |= POLLIN | POLLRDNORM;
  9. if(condition)
  10.     mask |= POLLOUT | POLLWRNORM;
  11. ..
  12. }

这里就会让对应的进程在驱动定义的wait_queue_head_t 的等待队列中睡眠,这其中最关键的函数之一就是poll_wait,原型如下:

void poll_wait(struct file *filp,wait_queue_head_t *wait_address,poll_table *p)

poll_table定义如下:

  1. typedef struct poll_table_struct {
  2.     poll_queue_proc qproc;
  3.     unsigned long key;
  4. }poll_table;

而具体poll_wait函数原型如下:


  1. static void __pollwait(struct file *filp,wait_queue_head_t *wait_address,poll_table *p)
  2. {
  3.     struct poll_wqueues *pwq = container_of(p,struct poll_wqueues,pt);
  4.     //在对应调用select 实现中添加一项等待该filp的数据结构
  5.     struct poll_table_entry *entry = poll_get_entry(pwq);
  6.     if(!entry)
  7.         return;
  8.     get_file(filp);
  9.     entry->filp = filp;
  10.     entry->wait_address = wait_address;
  11.     entry->key = p->key;
  12.     //当事件到来时,就会调用pollwake唤醒进程,也就是读写驱动中可读写事件到来时的唤醒
  13.     init_waitqueue_func_entry(&entry->wait,pollwake);
  14.     entry->wait.private = pwq;
  15.     //放到等待队列上,还是没有被抢占,通过调用schedule函数显示让出CPU
  16.     add_wait_queue(wait_address,&entry->wait);
  17. }

加入到等待队列的主要目的是让驱动中的读写函数在处理阻塞式操作时,解决阻塞等待的问题.

这里的poll_wqueue定义如下:


  1. struct poll_wqueue {
  2. poll_table pt;
  3. struct poll_table_page *table;
  4. struct task_struct *polling_task;
  5. int triggered;
  6. int error;
  7. int inline_index;
  8. //N_INLINE_POLL_ENTRIES 18(32位系统)
  9. struct poll_table_entry inline_entries[N_INLINE_POLL_ENTRIES];
  10. }

在调用poll_get_entry函数时,获取一项时,方法有些巧妙,具体实现如下:


  1. struct poll_table_page {
  2.     struct poll_table_page *next;
  3.     struct poll_table_entry *entry;
  4.     struct poll_table_entry entries[0];//此为gcc扩展
  5. }
  6. static struct poll_table_entry *poll_get_entry(struct poll_wqueues *p)
  7. {
  8.     struct poll_table_page *table = p->table;
  9.     if(p->inline_index < N_INLINE_POLL_ENTRIES)
  10.             return p->inline_entries + p->inline_index ++;
  11.     if(!table || POLL_TABLE_FULL(table)) {
  12.         struct poll_table_page *new_table;
  13.         new_table = (struct poll_table_page *) __get_free_page(GFP_KERNEL);
  14.         if (!new_table) {
  15.             p->error = -ENOMEM;
  16.             return NULL;
  17.         }
  18.         //关键是这里两者指针地址相同,entry,entries都是用来标示new_table的数据起始地址
  19.         new_table->entry = new_table->entries;
  20.         new_table->next = table;
  21.         p->table = new_table;
  22.         table = new_table;
  23.     }
  24.  return table->entry++;

    }

释放poll_table数据结构时:


  1. void poll_freewait(struct poll_wqueues *pwq)
  2. {
  3.     struct poll_table_page * p = pwq->table;
  4.     int i;
  5.     for (i = 0; i < pwq->inline_index; i++)
  6.         free_poll_entry(pwq->inline_entries + i);
  7.     while (p) {
  8.         struct poll_table_entry * entry;
  9.         struct poll_table_page *old;

  10.         entry = p->entry;
  11.         do {
  12.             entry--;
  13.             free_poll_entry(entry);
  14.         } while (entry > p->entries);//这里的起始地址就起到判断的作用了!!
  15.         old = p;
  16.         p = p->next;
  17.         free_page((unsigned long) old);
  18.     }
  19. }

select echo和设备驱动示例见这里:https://github.com/ytaoWang/test

参考资料:

linux设备驱动

深入理解linux内核

阅读(1689) | 评论(0) | 转发(1) |
给主人留下些什么吧!~~
评论热议
请登录后评论。

登录 注册