poll

一、poll()函式：

這個函式是某些Unix系統提供的用於執行與select()函式同等功能的函式，自認為poll和select大同小異，下面是這個函式的宣告：

#include <poll.h>

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

引數：

1.第一個引數:一個結構陣列,struct pollfd：

        fds：是一個struct pollfd結構型別的陣列，每個陣列元素都是一個pollfd結構，用於指定測試某個給定描述字fd的條件。存放需要檢測其狀態的Socket描述符；每當呼叫這個函式之後，系統不會清空這個陣列，操作起來比較方便；

結構如下：

　struct pollfd{
　　int fd;          //檔案描述符
　　short events;    //請求的事件
　　short revents;   //返回的事件
　　};
 

　　events和revents是通過對代表各種事件的標誌進行邏輯或運算構建而成的。events包括要監視的事件（就是我需要關注的時間，是讀？是寫？還是出錯？），poll用已經發生的事件填充revents。poll函式通過在revents中設定標誌肌膚POLLHUP、POLLERR和POLLNVAL來反映相關條件的存在。不需要在events中對於這些標誌符相關的位元位進行設定。如果fd小於0， 則events欄位被忽略，而revents被置為0.標準中沒有說明如何處理檔案結束。檔案結束可以通過revents的識別符號POLLHUN或返回0位元組的常規讀操作來傳達。即使POLLIN或POLLRDNORM指出還有資料要讀，POLLHUP也可能會被設定。因此，應該在錯誤檢驗之前處理正常的讀操作。

poll函式的事件標誌符值：

　注意：

        1）後三個只能作為描述字的返回結果儲存在revents中，而不能作為測試條件用於events中。

　　2）第二個引數nfds：要監視的描述符的數目。

　　3）最後一個引數timeout：是一個用毫秒表示的時間，是指定poll在返回前沒有接收事件時應該等待的時間。如果  它的值為-1，poll就永遠都不會超時。如果整數值為32個位元，那麼最大的超時週期大約是30分鐘。

對socket描述符fd上的讀、寫、異常事件感興趣，就可以這樣做：

struct pollfd  fds;

fds[index].events=POLLIN | POLLOUT | POLLERR；

struct pollfd  fds;

//檢測可讀TCP連線請求：
if((fds[nIndex].revents & POLLIN) == POLLIN)
{
<span style="white-space:pre">	</span>//接收資料，呼叫accept()接收連線請求
}

//檢測可寫：
if((fds[nIndex].revents & POLLOUT) == POLLOUT)
{
<span style="white-space:pre">	</span>//傳送資料
}

//檢測異常：
if((fds[nIndex].revents & POLLERR) == POLLERR)
{
<span style="white-space:pre">	</span>//異常處理
}

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>　
#include <string.h>
#include <errno.h>
#include <poll.h>   //for poll

#define LISTENQ 1024
#define MAXLINE 1024
#define OPEN_MAX 50000

#ifndef INFTIM 
#define INFTIM -1 
#endif             

int start_up(char* ip,int port)  //建立一個套接字，繫結，檢測伺服器
{
  //sock
  //1.建立套接字
  int sock=socket(AF_INET,SOCK_STREAM,0);   
  if(sock<0)
  {
      perror("sock");
      exit(0);
  }
  
  //2.填充本地 sockaddr_in 結構體（設定本地的IP地址和埠）
  struct sockaddr_in local;       
  local.sin_port=htons(port);
  local.sin_family=AF_INET;
  local.sin_addr.s_addr=inet_addr(ip);

  //3.bind（）繫結
  if(bind(sock,(struct sockaddr*)&local,sizeof(local))<0) 
  {
      perror("bind");
      exit(1);
  }
  //4.listen（）監聽 檢測伺服器
  if(listen(sock,back_log)<0)
  {
      perror("sock");
      exit(1);
  }
  return sock;    //這樣的套接字返回
}
	
int main(int argc, char *argv[])
{
　　int i, maxi, connfd, sockfd;
　　int nready;
　　ssize_t n;
　　socklen_t clilen;

　　struct sockaddr_in servaddr;
    socklen_t len=sizeof(servaddr); 

　  char buf[BUFSIZ];
    struct pollfd client[OPEN_MAX]; // 用於poll函式第一個引數的陣列,存放每次的檔案描述符個數
　　if( argc != 3 )
    {
　　     printf("Please input %s <hostname>\n", argv[0]);
	 exit(2);
    }

        int listenfd=start_up(argv[1],argv[2]);      //建立一個綁定了本地 ip 和埠號的套接字描述符
		
　　    client[0].fd = listenfd;         //將陣列中的第一個元素設定成監聽描述字
　　    client[0].events = POLLIN;       //將測試條件設定成普通或優先順序帶資料可讀(感興趣的事件讀、寫、出錯)，此處書中為POLLRDNORM，*/
		client[0].revents = 0;           //真正發生的事件

　　    for(i = 1;i < OPEN_MAX; ++i)     //陣列中的其它元素將暫時設定成不可用
		{
			client[i].fd = -1;
		}
        
　　    maxi = 0;
　      while(1)
　　    {
　　       nready = poll(client, maxi+1,INFTIM);          //將程序阻塞在poll上
　　       if( client[0].revents & POLLIN)                //先測試監聽描述字
　　       {
				connfd = accept(listenfd,(struct sockaddr*)&servaddr, &clilen);

　　            for(i = 1; i < OPEN_MAX; ++i)
				{
					if( client[i].fd < 0 )
　　                {
　                     client[i].fd = connfd;      //將新連線加入到測試陣列中
　　                   client[i].events = POLLIN;  //POLLRDNORM; 測試條件普通資料可讀
　                     break;
　　                }
　　            	if( i == OPEN_MAX )
　              	{
　　               	 	printf("too many clients"); //連線的客戶端太多了，都達到最大值了
　                  	exit(1);
　　            	}

　　            	if( i > maxi )
　　                	maxi = i;        //maxi記錄的是陣列元素的個數

　　            	if( --nready <= 0 )
　　               	continue;            //如果沒有可讀的描述符了，就重新監聽連線
				}
　　        }

　　        for(i = 1; i <= maxi; i++)  //測試除監聽描述字以後的其它連線描述字
　　        {
				if( (sockfd = client[i].fd) < 0) //如果當前描述字不可用，就測試下一個
　　                continue;

　　            if(client[i].revents & (POLLIN | POLLERR))//如果當前描述字返回的是普通資料可讀或出錯條件
　　            {
　                if( (n = read(sockfd, buf, MAXLINE)) < 0) //從套介面中讀資料
　　               {
　　                    if( errno == ECONNRESET) //如果連線斷開，就關閉連線，並設當前描述符不可用
　　                    {
　　                       close(sockfd);
　　                       client[i].fd = -1;
　　                    }
　　                    else
　　                        perror("read error");
　　                }
　               else if(n == 0) //如果資料讀取完畢，關閉連線，設定當前描述符不可用
　　                {
　　                    close(sockfd);
　　                    client[i].fd = -1;
　　                }
　　                else
　　                    write(sockfd, buf, n); //列印資料
　　             if(--nready <= 0)
　　                 break;
　　            }
　　        }
　　   }
　　   exit(0);
　}