生活随笔
收集整理的這篇文章主要介紹了
poll函数
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
#include <poll.h>
int poll(struct pollfd *fds, nfds_t nfds, int timeout);
參數：
struct pllfd {int fd; 待監聽的文件描述符short events; 待監聽的文件描述符對應的監聽事件short revents; 傳入時，給0; 如果滿足對應事件的話，返回非0
}
- nfds：監聽數組的，實際有效監聽個數
- 超時時長。單位：毫秒
//server.c
#include <unistd.h>#define SERV_PROT 8000
#define MAXLINE 80
#define OPEN_MAX 1024int main(int argc, char *argv[])
{int i, J, maxi, listenfd, connfd, sockfd;int nread;ssize_t n;char buf[MAXLINE], str[INET_ADDRSTRLEN]; //INE_ADDRSTRLEN 16socklen_t clilen;struct pollfd client[OPEN_MAX];struct sockaddr_in cliaddr, seraddr;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_PROT);Bind(listen, (struct sockaddr*)&serv_addr, sizeof(serv_addr));Listen(listenfd, 128);client[0].fd = listenfd; //要監聽的第一個文件描述符存入client[0]client[0].events = POLLIN; //listen監聽普通讀事件for (i = 1; i < OPEN_NAX; ++i)client[i].fd = -1; //用-1初始化client[]里剩下, 0也是文件描述符，不能用mxi = 0; //client[]數組有效元素中最大元素的下標for ( ; ; ){nread = poll(client, maxi + 1, -1); //阻塞監聽是否有客戶端連接請求if (client[0].revents & POLLIN) //listen有讀事件就緒{clilen = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &clilen); //接受客戶端請求Accept不會阻塞printf("receive from %s at PORT %d\n",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返回的connfdbreak;}if (i == OPEN_MAX) //達到最大客戶端perr_exit("too many client");client[i].events = POLLIN; //設置剛返回的connfd監控讀事件if (i > maxi)maxi = i; //更新client[]中最大元素下標if (--nread <= 0)continue; //沒有更多就緒事件時， 繼續回到poll阻塞}for (i = 1; i < maxi; i++){if ((sockfd = client[i].fd) < 0)continue;if (client[i].revents & POLLIN){if (n = Read(sockfd, buf, MAXLINE)) < 0){if (errno == ECONNRESET) //收到RST標志{printf("client[%d] aborted connection\n", i);Close(sockfd);client[i].fd = -1; //poll中不監控該文件描述符，直接置為-1即可，不用像select中那樣移除}elseperr_exit("read error");}else if (n == 0) //說明客戶端先關閉鏈接{printf("client[%d] closed connection\n", i);Close(sockfd);clent[i].fd = -1;}else{for (j = 0; j < n; ++j)buf[j] = toupper(buf[j]);Write(sockfd, buf, n);if (--nread <= 0)break;}}}}return 0;
}
?
總結
以上是生活随笔為你收集整理的poll函数的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
