selectとpollの基本的な使い方

16665 ワード

select関数
関数プロトタイプ
int select(int nfds, fd_set *readfds, fd_set *writefds,
              fd_set *exceptfds, struct timeval *timeout);

(1)timeout==NULL、いつまでも待っていて、もし1つの信号selectが-1を返すことを捉えたら、errnoはEINTRに設定します.(2)timeout->tv_sec == 0 && timeout->tv_usec==0,まったく待たず,ポーリングシステムがselect関数をブロックしない方法(3)timeout->tv_sec != 0 || timeout->tv_usec != 0、指定された秒数と微妙数を待機します.タイムアウトの期限が切れたときに記述子の準備ができていない場合は、0を返します.
アクション関数
   void FD_SET(int fd, fd_set *set);
   void FD_CLR(int fd, fd_set *set);
   int  FD_ISSET(int fd, fd_set *set);
   void FD_ZERO(fd_set *set);

戻り値
(1)戻り値-1はエラーを示す.これは、例えば、指定された記述子が1つも準備されていないときに信号をキャプチャすることができる.この場合、1つの記述子セットも変更されない(2)戻り値0は、記述子が準備されていないことを示す.指定した記述子が1つも準備されていない場合、指定した時間が過ぎてしまうと、このような状況が発生します.このとき、すべての記述子セットが0(3)の正の戻り値に設定され、準備された記述子数が説明される.変更は、3つのディスクリプタセットで用意されているディスクリプタの数の和であり、同じディスクリプタが読み取りと書き込みの準備ができている場合、戻り値で2回記数されます.
何時に説明しますか.
(1)1つの記述子がブロックされているかどうかはselectがブロックされているかどうかには影響しない(2)1つのファイル記述子にファイルの末端が接触した場合、selectは記述子が読めると判断し、readを呼び出すと0を返す.これはUNIXシステムがファイルの末端に到達することを示す方法である.
pselect関数
 int pselect(int nfds, fd_set *readfds, fd_set *writefds,
               fd_set *exceptfds, const struct timespec *timeout,
               const sigset_t *sigmask);

以下の点を除いて、pselectはselectと同じ-selectのタイムアウト値はtimeval構造で指定され、pselectはtimespecで受信され、timespec構造は秒とナノ秒でタイムアウト値を表し、秒とマイクロ秒ではなく、より正確なタイムアウト時間を提供することができる-pselectのタイムアウト値はconstとして宣言され、これにより、pselectを呼び出してこの値-pselectが変更されないことを保証します.sigmaskがNULLである場合、pselectおよびselectは、信号に関連する点で同じである.sigmaskが信号シールドワードを指すと、pselectが呼び出されると、その信号シールドワードが原子操作でインストールされる.戻り時に、以前の信号マスクを返信
テストプログラム
/*server.c*/
#include 
#include 
#include 
#include 
#include 
#include 

#include "wrap.h"

#define SERV_PORT 6666

int main(int argc, char *argv[])
{
    int i, j, n, maxi;

    int nready, client[FD_SETSIZE];                 /*      client,     1024        FD_SETSIZE   1024 */
    int maxfd, listenfd, connfd, sockfd;
    char buf[BUFSIZ], str[INET_ADDRSTRLEN];         /* #define INET_ADDRSTRLEN 16 */

    struct sockaddr_in clie_addr, serv_addr;
    socklen_t clie_addr_len;
    fd_set rset, allset;                            /* rset            allset     */

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);

    int opt = 1;
    setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

    bzero(&serv_addr, sizeof(serv_addr));
    serv_addr.sin_family= AF_INET;
    serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_addr.sin_port= htons(SERV_PORT);

    Bind(listenfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr));
    Listen(listenfd, 128);

    maxfd = listenfd;                           /*    listenfd           */

    maxi = -1;                                  /*     client[]   ,      0          */
    for (i = 0; i < FD_SETSIZE; i++)
        client[i] = -1;                         /*  -1   client[] */

    FD_ZERO(&allset);
    FD_SET(listenfd, &allset);                  /*   select         */

    while (1) {   
        rset = allset;                          /*           select      */
        nready = select(maxfd+1, &rset, NULL, NULL, NULL);
        if (nready < 0)
            perr_exit("select error");

        if (FD_ISSET(listenfd, &rset)) {        /*              */

            clie_addr_len = sizeof(clie_addr);
            connfd = Accept(listenfd, (struct sockaddr *)&clie_addr, &clie_addr_len);                    /* Accept      */
            printf("received from %s at PORT %d
"
, inet_ntop(AF_INET, &clie_addr.sin_addr, str, sizeof(str)), ntohs(clie_addr.sin_port)); for (i = 0; i < FD_SETSIZE; i++) if (client[i] < 0) { /* client[] */ client[i] = connfd; /* accept client[] */ break; } if (i == FD_SETSIZE) { /* select 1024 */ fputs("too many clients
"
, stderr); exit(1); } FD_SET(connfd, &allset); /* allset connfd */ if (connfd > maxfd) maxfd = connfd; /* select */ if (i > maxi) maxi = i; /* maxi client[] */ if (--nready == 0) continue; } for (i = 0; i <= maxi; i++) { /* clients */ if ((sockfd = client[i]) < 0) continue; if (FD_ISSET(sockfd, &rset)) { if ((n = Read(sockfd, buf, sizeof(buf))) == 0) { /* client , */ Close(sockfd); FD_CLR(sockfd, &allset); /* select */ client[i] = -1; } else if (n > 0) { for (j = 0; j < n; j++) buf[j] = toupper(buf[j]); Write(sockfd, buf, n); Write(STDOUT_FILENO, buf, n); } if (--nready == 0) break; /* for, while */ } } } Close(listenfd); return 0; }

poll関数
int poll(struct pollfd *fds, nfds_t nfds, int timeout);
struct pollfd { int fd;/* file descriptor */ short events;/* requested events */ short revents;/* returned events */ }; 常用eventsマクロ:POLLIN(リードイベント)、POLLOUT(ライトイベント)、POLLERR(異常イベント)
テストプログラム
#include 
#include 
#include 
#include 
#include 
#include 
#include 
#include 

#include "wrap.h"

#define MAXLINE 80
#define SERV_PORT 8000
#define OPEN_MAX 1024

int main(int argc, char *argv[])
{
    int i, j, maxi, listenfd, connfd, sockfd;
    int nready;                                 /*  poll   ,          fd  */
    ssize_t n;

    char buf[MAXLINE], str[INET_ADDRSTRLEN];
    socklen_t clilen;
    struct pollfd client[OPEN_MAX];
    struct sockaddr_in cliaddr, servaddr;

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);

    int opt = 1;
    setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(SERV_PORT);

    Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
    Listen(listenfd, 128);

    client[0].fd = listenfd;                    /*                client[0]*/
    client[0].events = POLLIN;                  /* listenfd        */

    for (i = 1; i < OPEN_MAX; i++)
        client[i].fd = -1;                      /*  -1   client[]      0       ,    */

    maxi = 0;                                   /* client[]              */

    for ( ; ; ) {
        nready = poll(client, maxi+1, -1);      /*                */

        if (client[0].revents & POLLIN) {       /* listenfd       */

            clilen = sizeof(cliaddr);
            connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &clilen);
               /*         Accept      */
            printf("received from %s at PORT %d
"
, inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)), ntohs(cliaddr.sin_port)); for (i = 1; i < OPEN_MAX; i++) if (client[i].fd < 0) { client[i].fd = connfd; /* client[] , accept connfd */ break; } if (i == OPEN_MAX) /* */ perr_exit("too many clients"); client[i].events = POLLIN; /* connfd, */ if (i > maxi) maxi = i; /* client[] */ if (--nready <= 0) continue; /* , poll */ } for (i = 1; i <= maxi; i++) { /* if , listenfd . client[] connfd */ if ((sockfd = client[i].fd) < 0) continue; if (client[i].revents & POLLIN) { if ((n = Read(sockfd, buf, MAXLINE)) < 0) { /* connection reset by client */ if (errno == ECONNRESET) { /* RST */ printf("client[%d] aborted connection
"
, i); Close(sockfd); client[i].fd = -1; /* poll , -1 , select */ } else perr_exit("read error"); else if (n == 0) { /* */ printf("client[%d] closed connection
"
, i); Close(sockfd); client[i].fd = -1; } else { for (j = 0; j < n; j++) buf[j] = toupper(buf[j]); Writen(sockfd, buf, n); } if (--nready <= 0) break; } } } return 0; }

区別する
1 poll関数は1024の制限を突破し、プロファイルを変更することで実現できます.
2リスニングと返される集合は分離されるので、poll関数はselect関数のように返される結果に対してイベントが発生したファイル記述子を順次探す必要はありません.