有名管道

knight565

程序?qū)崿F(xiàn)的功能是在管道fifo1中讀數(shù)據(jù)，然后寫入管道fifo2中；可是運行結(jié)果是只讀了一次，然后不停的寫，請問下是什么情況？
#include <sys/stat.h>
#include <sys/types.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <unistd.h>
#include <time.h>
#include <stdlib.h>
int main()
{
  int fds[2];
  char buf[7];
  int i,rc,maxfd;
  fd_set inset1,inset2;
  struct timeval tv;
  /**********creat fifo**********/
  if(((mkfifo("/tmp/fifo1",O_CREAT|O_EXCL|O_RDONLY))<0) && (errno != EEXIST))
    printf("cannot creat fifoserver.\n");
  if(((mkfifo("/tmp/fifo2",O_CREAT|O_EXCL))<0) && (errno != EEXIST))
    printf("cannot creat fifoserver2.\n");
  
  /************open fifo****************/
  if((fds[0] = open("/tmp/fifo1",O_RDWR|O_NONBLOCK,0))<0)
    perror("open fifo1");
  if((fds[1] = open("/tmp/fifo2",O_RDWR|O_NONBLOCK,0))<0)
    perror("open fifo2");
  if((rc = write(fds[0],"hello!\n",7)))
     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))
    {
      if((i=select(maxfd+1,&inset1,&inset2,NULL,NULL)) < 0)
        {
          perror("select");
        }
      else
        {

          printf("%d  %d  \n",fds[0],fds[1]);
          printf("%d\n",i);

          if (FD_ISSET(fds[0],&inset1))
            {
              printf("read rc=%d \n",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("write: %s\n",buf);
                  sleep(2);
                }
              else
                perror("write");
            }
        }       
    }
  close(fds[0]);
  close(fds[1]);
  exit(0);
}

yangchao1117

你的這程序用的工具有點沒看明白，呵呵。select是輪詢模式，我理解是在FD_ISSET監(jiān)測元素是否被激活，然后執(zhí)行相應(yīng)的代碼。
管道本來就是IPC。你可以創(chuàng)建兩個進(jìn)程啊，一個寫，一個讀。我覺得你可以換個寫法實現(xiàn)是一點問題都沒有。select你在研究研究。我也研究研究。