请教关于有名管道实现进程通信的问题

johncby

我现在想编写两个函数，分别用于向fifo中写一个字符串和从fifo中读取此字符串，
但我写了一下代码，总是实现不了，请教高手是什么原因？

1. 
   
2. #include <stdio.h>
   
3. #include <fcntl.h>
   
4. #include <unistd.h>
   
5. #include <sys/types.h>
   
6. #include <sys/stat.h>
   
7. 
   
8. int write_to_fifo (char *data);
   
9. int read_from_fifo (char *data, int len);
   
10. 
    
11. 
    
12. int write_to_fifo (char *data)
    
13. {
    
14.         int        len, lens;
    
15.         int        fd;
    
16.         int         n;
    
17.        
    
18.         len = strlen (data);
    
19.         printf ("strlen (data) is :%d\n", len);
    
20.         lens = len + 1;
    
21.        
    
22.        
    
23.         fd = open ("fifo", O_WRONLY | O_NONBLOCK);
    
24.         if ((n = write (fd, data, lens)) < 0)
    
25.         {
    
26.                 printf ("write to fifo error\n");
    
27.                 return -1;
    
28.         }
    
29.         close (fd);
    
30.         return lens;
    
31. }
    
32. 
    
33. int read_from_fifo (char *data, int len)
    
34. {
    
35.         int         fd;
    
36.         int         num;
    
37.        
    
38.         data = (char *)malloc (sizeof (char) * (len + 1));       
    
39.         fd = open ("fifo", O_RDONLY | O_NONBLOCK);
    
40.         num = read (fd, data, len);
    
41.         printf ("num = %d\n", num);
    
42.         close (fd);
    
43.         unlink ("fifo");
    
44.         return 0;
    
45. }
    
46. 
    
47. int main (int argc, char **argv)
    
48. {
    
49.         char *s = NULL;
    
50.         char *buf = NULL;
    
51.         int  m;
    
52.         int         err;
    
53.         pid_t        pid;
    
54. 
    
55.         s = (char *)malloc (sizeof (char) * 8);
    
56.         s = "abcdefg";       
    
57.         err = mkfifo ("fifo", 0666);
    
58.         printf ("mkfifo return is %d\n", err);
    
59.         if ((pid = fork ()) == 0)
    
60.         {
    
61.                 sleep (1);
    
62.                 read_from_fifo (buf, m);
    
63.                 printf ("read from fifo: %s\n", buf);
    
64.                 exit (0);
    
65.         }
    
66.         else if (pid > 0)
    
67.         {
    
68.                 m = write_to_fifo (s);
    
69.                 if (m < 0)
    
70.                         printf ("write_to_fifo error\n");
    
71.                 printf ("m = %d\n", m);
    
72.        
    
73.         }
    
74.         return 0;
    
75. }
    

复制代码

[ 本帖最后由 johncby 于 2007-1-17 14:20 编辑 ]

Benson_linux

帮顶一下，为什么没有人回答他的问题呢。
高手出来一下。

wyaccent

问题有几个
1、最严重的问题，你在滥用malloc
   s = (char *)malloc (sizeof (char) * ;
   s = "abcdefg";
   这样你的malloc还有用吗？？结果是内存泄漏
2、把读写函数里面的fd = open ("fifo", O_RDONLY | O_NONBLOCK);改成fd = open ("fifo", 0666);
   你的程序读写报错的时候你可以跟踪一下errno
3、读函数里面的malloc是不能把你需要的值传出的，函数return后，内存就释放了，你malloc申请的内存再次泄漏

hmilymb

除了楼上说的问题外
主要是：

1. 
   
2. if ((pid = fork ()) == 0)
   

复制代码

不能够这样写的，
应该

1. 
   
2.         pid = fork ();
   
3.         if (pid == 0)
   

复制代码

还有你读写命令管道的时候，不能写一次关掉，然后再读，管道的作用不是消息队列那样的存很多信息，而是一个通道，不能再里面存信息（正确的说可以存PIPE_BUF长度的信息）。用法基本是读写进程描述符都打开，然后互相通信，通信完毕后关掉描述符号，而不是存在里面。

简单帮你调通管道，还又不少错误，自己改吧。

1. 
   
2. #include <stdio.h>
   
3. #include <fcntl.h>
   
4. #include <unistd.h>
   
5. #include <sys/types.h>
   
6. #include <sys/stat.h>
   
7. #include <errno.h>
   
8. 
   
9. int write_to_fifo (char *data,int fd)
   
10. {
    
11.         int        len, lens;
    
12.         int         n;
    
13.       
    
14.         len = strlen (data);
    
15.         printf ("strlen (data) is :%d\n", len);
    
16.         lens = len + 1;
    
17.       
    
18.       
    
19.         if ((n = write (fd, data, lens)) < 0)
    
20.         {
    
21.                 printf ("write to fifo error\n");
    
22.                 return -1;
    
23.         }
    
24.         printf ("write to fifo %d\n",n);
    
25.         sleep(2);
    
26.         return lens;
    
27. }
    
28. 
    
29. int read_from_fifo (char *data, int len,int fd)
    
30. {
    
31.         int         num;
    
32.       
    
33.         data = (char *)malloc (sizeof (char) * (len + 1));
    
34.         num = read (fd, data, len);
    
35.         printf ("num = %d,data[%s] \n", num,data);
    
36.         unlink ("fifo");
    
37.         return 0;
    
38. }
    
39. 
    
40. int main (int argc, char **argv)
    
41. {
    
42.         char *s = NULL;
    
43.         char *buf = NULL;
    
44.         int  m;
    
45.         int         err;
    
46.         pid_t        pid;
    
47.         int fdr;
    
48.         int fdw;
    
49. 
    
50.         s = (char *)malloc (sizeof (char) * 8);
    
51.         s = "abcdefg";      
    
52.         err = mkfifo ("fifo", 0666);
    
53.         printf ("mkfifo return is %d\n", err);
    
54.         pid = fork ();
    
55.         if (pid == 0)
    
56.         {
    
57.                 fdr = open ("fifo", O_RDONLY | O_NONBLOCK);
    
58.                 sleep (2);
    
59.                 read_from_fifo (buf, m,fdr);
    
60.                 printf ("read from fifo: %s\n", buf);
    
61.                 close (fdr);
    
62.                 exit (0);
    
63.         }
    
64.         else if (pid > 0)
    
65.         {
    
66.                 fdw = open ("fifo", O_WRONLY | O_NONBLOCK);
    
67.                 m = write_to_fifo (s,fdw);
    
68.                 if (m < 0)
    
69.                         printf ("write_to_fifo error,errno[%d],message[%s]\n",errno,strerror(errno));
    
70.                 close(fdw);
    
71.                 printf ("m = %d\n", m);
    
72.       
    
73.         }
    
74.         return 0;
    
75. }
    

复制代码

[ 本帖最后由 hmilymb 于 2007-1-17 16:29 编辑 ]

wyaccent

fdr = write ("fifo", O_WRONLY | O_NONBLOCK);
这样写是不行的
看看帮助，WRONLY的时候加O_NONBLOCK是会报错的，不能加这个参数

[ 本帖最后由 wyaccent 于 2007-1-17 18:43 编辑 ]

langue

原帖由 hmilymb 于 2007-1-17 16:02 发表
除了楼上说的问题外
主要是：

1. 
   
2. if ((pid = fork ()) == 0)
   

复制代码

不能够这样写的，
应该

1. 
   
2.         pid = fork ();
   
3.         if (pid == 0)
   

复制代码

可以这样写。再用 else if 和 else 语句来判断其它情况即可

====

hmilymb

原帖由 langue 于 2007-1-17 18:43 发表


可以这样写。再用 else if 和 else 语句来判断其它情况即可

====

楼上说对了。


我前几天发现
if( pid = fork() < 0 ){
}else if (pid == 0){
} else {
}

出现错误，误以为是不能够这样写，
原来是＝比<优先级低导致的。



[ 本帖最后由 hmilymb 于 2007-1-17 20:37 编辑 ]

wyaccent

关键的错误是open (...,O_WRONLY)的时候不能加O_NONBLOCK
  When opening a FIFO with O_RDONLY or O_WRONLY set:

  If O_NONBLOCK is set:
          An open for reading only returns without delay. An open for writing
          only returns an error if no process currently has the file open for
          reading.


不过楼主的程序其他漏洞实在很多

langue

原帖由 wyaccent 于 2007-1-17 20:54 发表
关键的错误是open (...,O_WRONLY)的时候不能加O_NONBLOCK
  When opening a FIFO with O_RDONLY or O_WRONLY set:

  If O_NONBLOCK is set:
          An open for reading only returns without delay. An open for writing
          only returns an error if no process currently has the file open for
          reading.


不过楼主的程序其他漏洞实在很多

不过，如果允许我再说得确切一些的话，就是：错误多。漏洞，在代码方面有其特定的含义。

====

wyaccent

谢谢版主纠正