readpipes.c

来自「这是linux下的基础C编程代码。都是已经调试成功的」· C语言 代码 · 共 56 行

#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <limits.h>
#include <string.h>
#include <signal.h>

int main(void)
{
	int fd[2],maxfd;
	int len;
	int i=1;
	fd_set inset1,inset;
	char buf[PIPE_BUF];
    
	if((fd[0]=open("pipe1",O_RDONLY|O_NONBLOCK))<0)
	{
		printf("open 1 error");
	}
    if((fd[1]=open("pipe2",O_RDONLY|O_NONBLOCK))<0)
	{
		printf("open 2 error");
	}

	maxfd=fd[0]>fd[1]?fd[0]:fd[1];

	FD_ZERO(&inset1);
	FD_SET(fd[0],&inset1);
	FD_SET(fd[1],&inset1);
    
	while(FD_ISSET(fd[0],&inset1)||FD_ISSET(fd[1],&inset1))
	{
		inset=inset1;

		if(select(maxfd+1,&inset,NULL,NULL,NULL)<0)
		{
			printf("select error\n");
			return 1;
		}
		
        for(i=0;i<2;i++)
		{
			if(FD_ISSET(fd[i],&inset))
			{
				len=read(fd[i],buf,PIPE_BUF-1);
				printf("get %d numbers from pipe%d is %s \n",len,i,buf);
			}
		}
	}

	return(0);
}