- 浏览: 266741 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
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 1000网上很多hadoop集群搭建的文章,我这里只写下hdfs,不 ... -
网站性能优化
2013-10-25 10:43 0好久没写了,最近一直在做些互联网的一些东西。下面介绍些性能优 ... -
html5学习网站
2011-07-29 14:55 904htm5:http://www.w3school.com.cn ... -
HTTP下载
2011-02-09 15:24 1088HTTP下载的关键是修改Content-Type。 C ... -
28.sniffer程序2
2010-07-01 17:51 1772对前面27中sniffer中的一 ... -
27. sniffer程序
2010-06-30 11:51 5913网络抓包,必需从数据链路层开始抓取,至于原因之前在原始套接口中 ... -
java 和 linux c udp通信的样例
2010-05-28 11:58 2466一个简单的例子 java段(客户端) package ... -
26.原始套接字
2010-05-12 16:45 1763一个小程序: //发送方 #include <sys ... -
25.cookies和session
2010-05-10 15:21 898原文出自:http://blog.csdn ... -
24.SOCKET模拟HTTP请求
2010-05-07 14:11 5322HTTP请求头部样例: GET http://www.bai ... -
23.广播
2010-04-29 16:34 943如果想发送广播到目前为止只能使用AF_INET, SOCK_D ... -
22.非阻塞connect
2010-04-28 11:36 2718connect非阻塞套接口时候,一般使用在以下几种情况: ... -
21.非阻塞I/O
2010-04-27 16:54 2073设置一个I/O成为非阻塞很简单,只需要: int val = ... -
20.辅助数据 和 传输描述字
2010-04-26 15:53 2064打开一个文件或者一个 ... -
19.unix域协议与TCP UDP不同之处
2010-04-22 13:46 2616之前说过一些区别,但基本对我们编程来说没有太多影响,但以下几个 ... -
18.unix域协议
2010-04-21 16:47 2624UNIX域协议并不是一个真正的协议族,它是用在同一台主机上进行 ... -
17.I/O函数recvmsg与sendmsg
2010-04-20 15:58 12429想对于之前的几个IO函 ... -
16.I/O函数
2010-04-20 13:51 1242最早使用的read与write函 ... -
15.服务器守护进程
2010-04-16 17:44 1396前面提到过的服务器都占有控制终端。而有些进程并不需要控制终端。 ... -
14.udp与connect
2010-04-13 16:41 3216UDP在调用sendto发送数据 ...
相关推荐
poll函数的使用 客户端 基本流程编写运行正常
基于Linux开发板的GPIO子系统,使用poll()函数监听io口的实时电平变化,使用示例: GpioApi ioTest = new GpioApi(this); ioTest->addOutIO(GpioApi::IO_C_0);//添加输出口 ioTest->addInIO(GpioApi::IO_G_11);//...
TCP服务器IO模型之多路复用(一)POLL函数,使用POLL函数实现多路复用
poll函数与select函数差不多 函数原型: #include <poll> int poll(struct pollfd fd[], nfds_t nfds, int timeout); struct pollfd的结构如下: struct pollfd{ int fd; // 文件描述符 short event;//...
《unix网络编程》第六章,使用poll函数的客户服务器程序
里面 是两个版本,一个是带工程的,基于Linux开发板的GPIO子系统,使用poll()函数监听io口的实时电平变化,使用示例: GpioApi ioTest = new GpioApi(this); ioTest->addOutIO(GpioApi::IO_C_0);//添加输出口 ...
用一个线程echo,主进程中poll端口读取数据,不需要延时
I/O复用:select和poll函数 对本章的代码练习
linux c poll()函数的使用 linux c poll()函数的使用 linux c poll()函数的使用
2.3.8 Makefile 中的函数.............................................. 46 2 . 4 用G D B 调试程序..................................................... 47 2 . 4 . 1编译可调试程序............................
下面文章在这段时间内研究 select/poll/epoll的内核实现的一点心得体会:...这三种函数都需要设备驱动提供poll回调函数,对于套接字而言,他们是 tcp_poll,udp_poll和datagram_poll; 对于自己开发的设备驱动而言,是自
poll函数用法可以man一下。这里提供一个可以运行的示例。 程序流程: 父进程启动并创建子进程 子进程通过管道发送数据给父进程 父进程同时监听管道数据和shell输入,阻塞500毫秒发现没有数据打印一个...
7 1.7 函数 .......................................................... 8 1.8 模块 .......................................................... 8 1.8.1 cmath 和复数 ................................. 9 ...
。。。
。。。
poll、epoll函数事件标志符值常量 | 说明POLLIN | 普通或优先级带数据可读POLLRDNORM | 普通数据可读POLLRDBAND | 优先级
linux下select和poll的用法,关于设备驱动程序中的select和poll函数的用法。
在linux下通过C语言的poll函数实现udp聊天程序(同时跟多个用户进行通信,数据收发,灵活切换)
读核感悟-设计模式-用C来实现虚函数表和多态..................................32 读核感悟-设计模式-用C来实现继承和模板......................................33 读核感悟-设计模式-文件系统和设备的继承和接口...