#include
#include
#include
#include
#include
#include
#include
#include
int main(void)
{
int fds[2];
char buf[7];
int i,rc,maxfd;
fd_set inset1,inset2;
struct timeval tv;
if((mkfifo("fifo1",O_CREAT|O_EXCL)<0)&&(errno!=EEXIST))//创建两个有名管道
{
printf("can not create fifoserver\n");
}
if((mkfifo("fifo2",O_CREAT|O_EXCL)<0)&&(errno!=EEXIST))
{
printf("can not create fifoserver\n");
}
if((fds[0]=open("fifo1",O_RDWR|O_NONBLOCK,0))<0)//打开有名管道
{
perror("open fifo1");
}
if((fds[1]=open("fifo2",O_RDWR|O_NONBLOCK,0))<0)
{
perror("open fifo2");
}
if((rc=write(fds[0],"hello!\n",7)))//向管道0中写数据
{
printf("rc=%d\n",rc);
}
lseek(fds[0],0,SEEK_SET);//定义文件的文件指针偏移
maxfd=fds[0]>fds[1]?fds[0]:fds[1];
FD_ZERO(&inset1);
FD_SET(fds[0],&inset1);
FD_ZERO(&inset2);
FD_SET(fds[1],&inset2);//初始化描述集,并将文件描述符加入到相应的描述集
while(FD_ISSET(fds[0],&inset1)||FD_ISSET(fds[1],&inset2))
//循环测试该文件描述符是否准备就绪,并调用select
{
if(select(maxfd+1,&inset1,&inset2,NULL,NULL)<0)
{
perror("select");
}
else
{
if(FD_ISSET(fds[0],&inset1))//对相关文件描述符做对应操作
{
rc=read(fds[0],buf,7);//读管道的内容
if(rc>0)
{
buf[rc]='\0';
printf("read :%s\n",buf);
}
else
{
perror("read");
}
}
if(FD_ISSET(fds[1],&inset2))
{
rc=write(fds[1],buf,7);//向管道一中写数据
if(rc>0)
{
buf[rc]='\0';
printf("rc=%d,write:%s\n",rc,buf);
}
else
{
perror("write");
}
}
}
}
exit(0);
}
/*-------------------------------------------------
1.本程序目的:
编写有名管道多路通信实验,首先读出管道一中的数据,再把从管道一中读入的数据写入
到管道二中。采用select函数。
2.实验:
1)
----------------------------------------------------*/
阅读(700) | 评论(0) | 转发(0) |