- 浏览: 271829 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
AndMacLinuXp:
试了下,不错!
printk内核调试 -
klose:
我引用你的文章,并做了简单的分析:这里贴出url:http:/ ...
linux系统调用fork, vfork, clone -
klose:
你上面提到的问题:free的问题。首先你可能疏忽了,stack ...
linux系统调用fork, vfork, clone -
qwe_rt:
HI ,非常nice的文章,在阅读过程中,我发现我的ubunt ...
linux手动添加开机启动的服务 -
suifeng:
谢谢分享, 受用中.
shell编程分支,循环
poll函数和select一样都是用于I/O复用,他们提供的功能也一样,只不过是poll想对于流设备,提供一些额外的功能。在SVR3时候只局限于使用流设备,但这个SVR4以后,poll可以用于各种设备。
#include "poll.h"
int poll(struct polifd * fdarray, unsigned long nfds, int timeout);
和之前的select一样的功能,这里简单介绍下它的API,然后修改下之前曾经出现过的聊天程序,用poll替换掉之前的select函数。
参数timeout很好理解,用于限时作用,单位为毫秒,如果设定为负值,则永远等待,为0则立即返回不等待,大于0则就是等待指定时间(当然如果系统不提供如此精确的等待时间,则向上取最近值)。
参数struct polifd * fdarray则是用来确定阻塞的设备(也就是描述字)。结构定义如下:
struct polifd {
int fd;
short events;
short revents;
};
fd为等待的描述字,当fd为-1时候表示该组项被忽略。events为等待的事件,他可以取一下几种值:POLLIN(普通或优先级带的数据可读),POLLRDNORM(普通数据可读),POLLRDBAND(优先级带数据可读), POLLPRI(高优先级数据可读).所谓的优先级数据是流设备中概念,在网络套接口优先级数据指的是TCP的带外数据(这个就不展开讨论)。POLLOUT(普通数据可写),POLLWRNORM(普通数据可写),POLLWRBAND(优先级带数据可写).这些就是events设置的值。而revents则是用来返回结果,所以以上的参数都可以是revents返回的结果,除以上以外,它还有可能是下面几种返回结果:POLLERR(返回结果), POLLHUP(发生挂起),POLLNVAL(描述字不是一个打开的文件)。
nfds则指示的是fdarray数组的长度,fdarray是由进程打开文件的描述字决定,但平常我们并不关心所有打开的描述字,比如下面的程序,我们只关心标准输入文件0号(键盘)和我们连接的套接口是否有数据到来。所以用nfds标识我们关心的描述字个数。
关于返回值,返回负值则表示出错(和之前select一样,会被信号中断阻塞过程,而导致函数错误返回),0则表示超时。如果是大于0,则表示准备好的描述字个数。
说起来很抽象,不过结合下面的代码和解释我相信很容易理解。
1 #include "/programe/net/head.h"
2 #include "stdio.h"
3 #include "stdlib.h"
4 #include "string.h"
5 #include "unistd.h"
6 #include "sys/wait.h"
7 #include "sys/select.h"
8 #include "sys/poll.h"
9
10 #define MAXSIZE 100
11
12 int main(int argc, char ** argv) {
13 int sockfd;
14 struct sockaddr_in serv_socket;
15 char end_flag[] = "EOF";
16 char end_word[] = "no words\n";
17 int send_flag = 1;
18 int recv_flag = 1;
19
20 sockfd = socket(AF_INET, SOCK_STREAM, 0);
21 bzero(&serv_socket, sizeof(struct sockaddr_in));
22 serv_socket.sin_family = AF_INET;
23 serv_socket.sin_port = htons(atoi(argv[1]));
24 serv_socket.sin_addr.s_addr = htonl(INADDR_ANY);
25
26 bind(sockfd, (struct sockaddr *)&serv_socket, sizeof(serv_socket));
27 listen(sockfd, 10);
28 int connfd = accept(sockfd, (struct sockaddr *)NULL, NULL);
29 for(;;) {
30 struct pollfd fdarray[10];
31 char send[MAXSIZE + 1], recv[MAXSIZE + 1];
32
33 int i;
34 for(i = 0; i < 10; i++)
35 fdarray[i].fd = -1;
36
37 fdarray[0].fd = 0;
38 fdarray[0].events = POLLIN;
39
40 fdarray[1].fd = connfd;
41 fdarray[1].events = POLLIN;
42
43 if(!send_flag && !recv_flag)
44 break;
45 int flag = poll(fdarray, 2, -1);
46
47 if(flag < 0) {
48 printf("system message:some error happen when waiting for input\n");
49 continue;
50 }
51
52 if(send_flag) {
53 if(fdarray[0].revents & POLLIN) {
54 int n = read(0, send, MAXSIZE);
55 if(!strncmp(end_flag, send, 3)) {
56 write(connfd, end_word, strlen(end_word));
57 shutdown(connfd, SHUT_WR);
58 send_flag = 0;
59 } else {
60 write(connfd, send, n);
61 }
62 }
63 }
64
65 if(recv_flag) {
66 if(fdarray[1].revents & POLLIN) {
67 int n = read(connfd, recv, MAXSIZE);
68 if(!n) {
69 printf("client closed\n");
70 break;
71 }
72 if(!strncmp(end_word, recv, 8)) {
73 printf("client message:%s", recv);
74 shutdown(connfd, SHUT_RD);
75 recv_flag = 0;
76 } else {
77 recv[n] = '\0';
78 printf("client message:%s", recv);
79 }
80 }
81 }
82
83 }
84 shutdown(connfd, SHUT_RDWR);
85 }
代码有点长了,不过我们只关心部分代码,之前那些链接的代码看的很多了。
从第30行开始,我们创建了描述字数组,这里用10,其实我们并不知道此时进程打开了多少文件,10只是个人随便选的。然后用for循环将整个数组的描述设置成-1,也就是不关心。然后将0组项设置成标准输入文件0号,然后关心的事件为POLLIN(这个值的意思之前有介绍)。然后将网络套接口描述字放入2号组项,并同样设置关心事件。伺候当从poll返回就开始检测是什么事件发生。代码很简单,结合说明很容易看懂,至于client代码和server差不多,就不贴出了。
发表评论
-
hdfs集群搭建
2014-05-11 17:19 1054网上很多hadoop集群搭建的文章,我这里只写下hdfs,不 ... -
网站性能优化
2013-10-25 10:43 0好久没写了,最近一直在做些互联网的一些东西。下面介绍些性能优 ... -
html5学习网站
2011-07-29 14:55 983htm5:http://www.w3school.com.cn ... -
HTTP下载
2011-02-09 15:24 1138HTTP下载的关键是修改Content-Type。 C ... -
28.sniffer程序2
2010-07-01 17:51 1808对前面27中sniffer中的一 ... -
27. sniffer程序
2010-06-30 11:51 5970网络抓包,必需从数据链路层开始抓取,至于原因之前在原始套接口中 ... -
java 和 linux c udp通信的样例
2010-05-28 11:58 2510一个简单的例子 java段(客户端) package ... -
26.原始套接字
2010-05-12 16:45 1849一个小程序: //发送方 #include <sys ... -
25.cookies和session
2010-05-10 15:21 992原文出自:http://blog.csdn ... -
24.SOCKET模拟HTTP请求
2010-05-07 14:11 5392HTTP请求头部样例: GET http://www.bai ... -
23.广播
2010-04-29 16:34 978如果想发送广播到目前为止只能使用AF_INET, SOCK_D ... -
22.非阻塞connect
2010-04-28 11:36 2806connect非阻塞套接口时候,一般使用在以下几种情况: ... -
21.非阻塞I/O
2010-04-27 16:54 2104设置一个I/O成为非阻塞很简单,只需要: int val = ... -
20.辅助数据 和 传输描述字
2010-04-26 15:53 2128打开一个文件或者一个 ... -
19.unix域协议与TCP UDP不同之处
2010-04-22 13:46 2680之前说过一些区别,但基本对我们编程来说没有太多影响,但以下几个 ... -
18.unix域协议
2010-04-21 16:47 2667UNIX域协议并不是一个真正的协议族,它是用在同一台主机上进行 ... -
17.I/O函数recvmsg与sendmsg
2010-04-20 15:58 12511想对于之前的几个IO函 ... -
16.I/O函数
2010-04-20 13:51 1291最早使用的read与write函 ... -
15.服务器守护进程
2010-04-16 17:44 1432前面提到过的服务器都占有控制终端。而有些进程并不需要控制终端。 ... -
14.udp与connect
2010-04-13 16:41 3262UDP在调用sendto发送数据 ...
相关推荐
poll函数的使用 客户端 基本流程编写运行正常
本篇将详细讲解TCP服务器中的多路复用模型,特别是如何使用POLL函数来实现这一机制。 首先,TCP(Transmission Control Protocol)是一种面向连接的、可靠的、基于字节流的传输层通信协议,常用于互联网上的数据...
线程`poll`函数在IT领域,特别是在网络编程和多线程编程中是一个重要的概念。本文将深入探讨`poll`函数的工作原理、使用场景以及它如何与线程协同工作,帮助提升程序的效率。 `poll`是Linux系统提供的一种I/O多路...
基于Linux开发板的GPIO子系统,使用poll()函数监听io口的实时电平变化,使用示例: GpioApi ioTest = new GpioApi(this); ioTest->addOutIO(GpioApi::IO_C_0);//添加输出口 ioTest->addInIO(GpioApi::IO_G_11);//...
### Linux C 中 `poll()` 函数的使用详解 在Linux C编程中,`poll()` 函数是一个非常重要的I/O多路复用技术之一,它能够有效地监控多个文件描述符的状态变化,一旦某个文件描述符就绪(即可以进行读、写等操作),`...
《unix网络编程》第六章,使用poll函数的客户服务器程序
poll_initwait 函数是 sys_poll 函数中的一个关键函数,它负责初始化 table 变量。poll_initwait 函数将 table 变量的 qproc 成员设置为 __pollwait 函数,这是一个回调函数,用于等待文件描述符的事件。 在 poll_...
《poll()函数详解》 poll()函数是Unix/Linux系统中的一种I/O多路复用机制,它允许程序同时监视多个文件描述符,等待一个或多个文件描述符变为可读、可写或者出现错误状态。这一机制提高了程序的并发性和效率,避免...
`poll()`函数是Unix/Linux系统中的一个I/O多路复用函数,用于高效地监控多个文件描述符(file descriptor)的状态变化,如可读、可写或者错误等事件。通过`poll()`,程序可以同时等待多个文件描述符就绪,避免了轮询...
sys_poll函数首先对超时参数进行处理,然后调用do_sys_poll函数。do_sys_poll函数位于fs/select.c文件中,负责实际的poll操作。它首先初始化一个poll_wqueues结构体table,然后调用do_poll函数来执行poll操作。 do_...
在进行"Unix网络编程 第6章 I/O复用:select和poll函数"的代码练习时,你可能会涉及到以下内容: 1. 创建并初始化`fd_set`或`pollfd`结构。 2. 使用`FD_SET()`或`pollfd`结构添加文件描述符。 3. 设置合适的超时时间...
里面 是两个版本,一个是带工程的,基于Linux开发板的GPIO子系统,使用poll()函数监听io口的实时电平变化,使用示例: GpioApi ioTest = new GpioApi(this); ioTest->addOutIO(GpioApi::IO_C_0);//添加输出口 ...
6. **多路复用I/O**:`select()`,`poll()`和`WSAAsyncSelect()`,用于在多个套接字上等待事件。 7. **错误处理**:`WSAGetLastError()`,`WSAClearError()`和`WSASetLastError()`等函数用于处理和报告网络错误。 *...
poll函数与select函数差不多 函数原型: #include <poll> int poll(struct pollfd fd[], nfds_t nfds, int timeout); struct pollfd的结构如下: struct pollfd{ int fd; // 文件描述符 short event;//...
1. **poll函数封装**:库可能提供了对原始系统调用`poll()`的封装,使得开发者能够更容易地在自己的代码中使用这一功能,而无需直接处理底层的细节。 2. **事件驱动模型**:基于poll机制,jaracil-poll可能会构建一...
"4412_poll阻塞"这一主题主要涉及到Linux系统中的I/O模型,特别是poll函数在特定场景下可能会出现阻塞的情况。poll是Linux提供的一种I/O多路复用技术,它允许程序同时监视多个文件描述符,等待数据就绪后再进行处理...
poll 函数与 select 函数类似,但它使用 pollfd 结构来描述文件描述符的状态。poll 函数的基本接口为: ```c int poll(struct pollfd *fds, nfds_t nfds, int timeout); ``` 其中: * `fds` 是一个 pollfd 结构的...
2.3.8 Makefile 中的函数.............................................. 46 2 . 4 用G D B 调试程序..................................................... 47 2 . 4 . 1编译可调试程序............................