一、函数原型:

#include <poll.h>

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

 

二、函数说明:

        系统调用poll()执行的任务同select()很相似。两者间主要的区别在于我们要如何指定待检查的文件描述符。再select()中,我们提供三个集合,在每个集合中标明我们感兴趣的文件描述符。而在poll()中我们提供了一列文件描述符,并在每个文件描述符上标明我们感兴趣的事件。

 

三、参数说明:

fds:是一个struct pollfd结构类型的数组,列出了我们需要poll()检查的文件描述符,其定义如下:

typedef struct pollfd {
        int fd;           /* 需要被检测或选择的文件描述符*/
        short events;     /* 对文件描述符fd上感兴趣的事件 */
        short revents;    /* 文件描述符fd上当前实际发生的事件*/
} pollfd_t;

pollfd结构体中的events和revents字段都是掩码。调用者初始化events来指定需要为描述符fd做检查的事件。当poll()返回时,revents被设定以此来表示该文件描述符上实际发生的事件。

下表列出了events和revents字段中掩码:

 

位掩码events中的输入返回到revents 

POLLIN

POLLRDNORM

POLLRDBAND

POLLPRI

POLLRDHUB

可读取非高优先级数据

等同于POLLIN

可读取优先级数据(linux中不可用)

可读取高优先级数据

对端套接字关闭

POLLOUT

POLLWRNORM

POLLWRBAND

普通数据可写

等同于POLLOUT

优先级数据可写入

POLLERR

POLLHUP

POLLNVAL

 

有错误发生

出现挂断

文件描述符未打开

POLLMSG  linux中不可用

一般来说,poll()真正关心的标志位是:POLLIN、POLLOUT、POLLPRI、POLLRDHUB、POLLHUP、POLLERR

nfds:指定了fds中元素的个数,nfds_t为无符号整形

timeout:决定阻塞行为,一般如下:

-1:一直阻塞到fds数组中有一个达到就绪态或者捕获到一个信号

0:不会阻塞,立即返回

>0:阻塞时间

和select()一样,timeout的精度收软件时钟粒度的影响,如果不是时间粒度整数倍,向上取整。

返回值:

>0:数组fds中准备好读、写或出错状态的那些socket描述符的总数量;

==0:数组fds中没有任何socket描述符准备好读、写,或出错;此时poll超时

 

-1:  poll函数调用失败,同时会自动设置全局变量errno为下列值之一:

EBADF:一个或多个结构体中指定的文件描述符无效。
EFAULT:fds指针指向的地址超出进程的地址空间。
EINTR:请求的事件之前产生一个信号,调用可以重新发起。
EINVAL:nfds参数超出PLIMIT_NOFILE值。
ENOMEM:可用内存不足,无法完成请求。

 

 

四、代码举例:

/*********************************************
在/root/pro/fd1 /root/pro/fd2中分别有内容,
1234
5678
和
1122
3344
**********************************************/

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include <stropts.h>
#include <sys/poll.h>
#include <sys/stropts.h>
#include <string.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <poll.h>

#define BUFSIZE 1024

int main(int argc, char *argv[])
{
    char buf[BUFSIZE];
    int bytes;
    struct pollfd *pollfd;
    int i=0;
    int nummonitor=0;
    int numready;
    int errno;
    char *str;

    if(argc != 3)
    {
        fprintf(stderr,"Usage:the argc num error\n");
        exit(1);
    }


    if((pollfd = (struct pollfd*)calloc(2, sizeof(struct pollfd))) == NULL)
           exit(1);

    for(i; i<2; i++) //初始化化struct pollfd结构
    {
        str = (char*)malloc(14*sizeof(char));        
        memcpy(str,"/root/pro/",14);
        strcat(str,argv[i+1]);//注意,需要把路径信息放到str中

        printf("str=%s\n",str);

        (pollfd+i)->fd = open(str,O_RDONLY);
        if((pollfd+i)->fd >= 0)
            fprintf(stderr, "open (pollfd+%d)->fd:%s\n", i, argv[i+1]);

        nummonitor++;
        (pollfd+i)->events = POLLIN;
    }

    printf("nummonitor=%d\n",nummonitor);
      
    while(nummonitor > 0)
    {
        numready = poll(pollfd, 2, -1);
        if ((numready == -1) && (errno == EINTR))
            continue;       
        else if (numready == -1)
            break; //poll真正错误,退出

        printf("numready=%d\n",numready);

        for (i=0;nummonitor>0 && numready>0; i++)
        {
            if((pollfd+i)->revents & POLLIN)
            {
                
                bytes = read(pollfd[i].fd, buf, BUFSIZE);
                numready--;

                printf("pollfd[%d]->fd read buf:\n%s \n", i, buf);

                nummonitor--;
            }
        }
    }

    for(i=0; i<nummonitor; i++)
        close(pollfd[i].fd);

    free(pollfd);

    return 0;
}

结果为:

 

 

GitHub 加速计划 / li / linux-dash
6
1
下载
A beautiful web dashboard for Linux
最近提交(Master分支:3 个月前 )
186a802e added ecosystem file for PM2 4 年前
5def40a3 Add host customization support for the NodeJS version 4 年前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐