免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
最近访问板块 发新帖
查看: 1595 | 回复: 1
打印 上一主题 下一主题

[应用] 有名管道 [复制链接]

论坛徽章:
0
跳转到指定楼层
1 [收藏(0)] [报告]
发表于 2014-09-23 08:59 |只看该作者 |倒序浏览
程序实现的功能是在管道fifo1中读数据,然后写入管道fifo2中;可是运行结果是只读了一次,然后不停的写,请问下是什么情况?
#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);
}


论坛徽章:
1
IT运维版块每日发帖之星
日期:2015-09-15 06:20:00
2 [报告]
发表于 2014-12-05 23:41 |只看该作者
你的这程序用的工具有点没看明白,呵呵。select是轮询模式,我理解是在FD_ISSET监测元素是否被激活,然后执行相应的代码。
管道本来就是IPC。你可以创建两个进程啊,一个写,一个读。我觉得你可以换个写法实现是一点问题都没有。select你在研究研究。我也研究研究。
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号:11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们:huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP