poll function


poll

目录

函数
poll实现功能
poll操作举例

函数

  Linux中的字符设备驱动中有一个函数   

unsigned int (*poll)(struct file * fp, struct poll_table_struct * table)  

 此函数在系统调用select内部被使用,作用是把当前的文件指针挂到设备内部定义的等待队列中。这里的参数table可以不考虑,是在select函数实现过程中的一个内部变量。

  函数具体实现时:  

 wait_queue_head_t t = ((struct mydev *)filp->private_data)->wait_queue;  

 poll_wait(filp, t, table);  

 return mask;  

 这里mask可以是:   POLLIN | POLLRDNORM   POLLOUT | POLLWRNORM   等等。  

 poll()函数:这个函数是某些Unix系统提供的用于执行与select()函数同等功能的函数,下面是这个函数的声明:  

 #include <poll.h>  

 int poll(struct pollfd fds[], nfds_t nfds, int timeout);  

 参数说明:   fds:是一个struct pollfd结构类型的数组, 用于存放需要检测其状态的Socket描述符;每当调用这个函数之后,系统不会清空这个数组,操作起来比较方便;特别是对于socket连接比较多的情况 下,在一定程度上可以提高处理的效率;这一点与select()函数不同,调用select()函数之后,select()函数会清空它所检测的 socket描述符集合,导致每次调用select()之前都必须把socket描述符重新加入到待检测的集合中;因此,select()函数适合于只检 测一个socket描述符的情况,而poll()函数适合于大量socket描述符的情况;   nfds:nfds_t类型的参数,用于标记数组fds中的结构体元素的总数量;   timeout:是poll函数调用阻塞的时间,单位:毫秒;   返回值:   >0:数组fds中准备好读、写或出错状态的那些socket描述符的总数量;   ==0:数组fds中没有任何socket描述符准备好读、写,或出错;此时poll超时,超 时时间是timeout毫秒;换句话说,如果所检测的socket描述符上没有任何事件发生的话,那么poll()函数会阻塞timeout所指定的毫秒 时间长度之后返回,如果timeout==0,那么poll() 函数立即返回而不阻塞,如果timeout==INFTIM,那么poll() 函数会一直阻塞下去,直到所检测的socket描述符上的感兴趣的事件发生是才返回,如果感兴趣的事件永远不发生,那么poll()就会永远阻塞下去;   -1: poll函数调用失败,同时会自动设置全局变量errno;

编辑本段poll实现功能

  poll和select实现功能差不多,但poll效率高,以后要多用poll

  poll()接受一个指向结构'struct pollfd'列表的指针,其中包括了你想测试的文件描述符和 事件。事件由一个在结构中事件域的比特掩码确定。当前的结构在调用后将被填写并在事件发生后返回。在SVR4(可能更早的一些版本)中的 "poll.h"文件中包含了用于确定事件的一些宏定义。事件的等待时间精确到毫秒 (但令人困惑的是等待时间的类型却是int),当等待时间为0时,poll()函数立即返回,-1则使poll()一直挂起直到一个指定事件发生。下面是 pollfd的结构。  

 struct pollfd {   int fd; /* 文件描述符 */   short events; /* 等待的事件 */   short revents; /* 实际发生了的事件 */   };  

 于select()十分相似,当返回正值时,代表满足响应事件的文件描述符的个数,如果返回0则代表在规定事件内没有事件发生。如发现返回为负则应该立即查看 errno,因为这代表有错误发生。  

 如果没有事件发生,revents会被清空,所以你不必多此一举。

poll操作举例

  #include <fcntl.h>   

#include <stdio.h>

  #include <unistd.h>  

 #include <stdlib.h>  

 #include <string.h>  

 #include <time.h>   

#include <errno.h>  

 #include <poll.h>   

#define MAX_BUFFER_SIZE 1024  

 #define IN_FILES 3   

#define TIME_DELAY 60*5   

#define MAX(a,b) ((a>b)?(a):(b))  

 int main(int argc ,char **argv)  

 {   

struct pollfd fds[IN_FILES];  

 char buf[MAX_BUFFER_SIZE];  

 int i,res,real_read, maxfd;  

 fds[0].fd = 0;  

 if((fds[1].fd=open("data1",O_RDONLY|O_NONBLOCK)) < 0)  

 {

  fprintf(stderr,"open data1 error:%s",strerror(errno));  

 return 1;  

 }  

 if((fds[2].fd=open("data2",O_RDONLY|O_NONBLOCK)) < 0)  

 {  

 fprintf(stderr,"open data2 error:%s",strerror(errno));

  return 1;  

 }  

 for (i = 0; i < IN_FILES; i++)  

 {   fds[i].events = POLLIN;   }  

 while(fds[0].events || fds[1].events || fds[2].events)  

 {  

 if (poll(fds, IN_FILES, TIME_DELAY) <= 0)  

 {  

 printf("Poll error\n");  

 return 1;   }  

 for (i = 0; i< IN_FILES; i++)  

 {  

 if (fds[i].revents)   

{  

 memset(buf, 0, MAX_BUFFER_SIZE);  

 real_read = read(fds[i].fd, buf, MAX_BUFFER_SIZE);  

 if (real_read < 0)  

 {

  if (errno != EAGAIN)  

 {  

 return 1;

  }  

 }  

 else if (!real_read)  

 {   

close(fds[i].fd);  

 fds[i].events = 0;  

 }  

 else

  {  

 if (i == 0)

  {  

 if ((buf[0] == 'q') || (buf[0] == 'Q'))

  {  

 return 1;

  }   

}  

 else

  {  

 buf[real_read] = '\0';  

 printf("%s", buf);

  }  

 }  

 }  

 }

  }

  exit(0);  

 }


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM