父进程重定向子进程标准输出失败问题求助

江南愚人

走过路过，都来帮忙看看哈，谢谢

小弟在编个原型程序，要求父进程能把子进程的stdin/stdout都重定向到管道里，这样子进程可以从stdin读入父进程管道给的数据，stdout写出到父进程的管道中。
调试中发现子进程可以获得数据，但是父进程一直拿不到数据。困惑中，求各位大神帮助

父进程code

file:enc_dec_test.c

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>

#include <fcntl.h>
/*****************MACRO*******************/

#define BUFFER_SIZE 100
#define STDIN_FILENO 0
#define STDOUT_FILENO 1

#define USE_PIPE

/******************variable******************/

/******************function******************/


int main(int argc, char *argv[])
{
    char buffer[BUFFER_SIZE];
    char *pRead;
    int i, len;
    int child = 0;

    pid_t proc_enc, proc_dec;
    int pipe_in_enc[2];
    int pipe_out_enc[2];
    int pipe_in_dec[2];
    int pipe_out_dec[2];
    char *arg_enc[] = {"./enc_dec_test_sub", "enc", NULL};
    char *arg_dec[] = {"./enc_dec_test_sub", "dec", NULL};
    int status;

    /* create enc pipe */
    pipe(pipe_in_enc);
    pipe(pipe_out_enc);
    if (0 == (proc_enc = fork()))
    {
        child = 1;
        int fd_out = open("out.txt", O_CREAT | O_RDWR, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);

        close(pipe_in_enc[0]);      // 1رո¸½ø3ìμĶá1üμàμÄ×ó½ø3ì¶á¶Ë
        close(pipe_out_enc[1]);     // 1رո¸½ø3ìμÄD′1üμàμÄ×ó½ø3ìD′¶Ë
#ifdef USE_PIPE
        dup2(pipe_out_enc[0], STDIN_FILENO);        // ¸′ÖƸ¸½ø3ìμÄD′1üμàμ½×ó½ø3ìμıê×¼êäèë
        close(pipe_out_enc[0]);     // 1رÕòѸ′ÖÆμÄD′1üμà

#if 0
        dup2(fd_out, STDOUT_FILENO);    // ¸′ÖƸ¸½ø3ìμĶá1üμàμ½×ó½ø3ìμıê×¼êä3ö
        close(fd_out);       // 1رÕòѸ′ÖÆμĶá1üμà
#else
        dup2(pipe_in_enc[1], STDOUT_FILENO);        // ¸′ÖƸ¸½ø3ìμĶá1üμàμ½×ó½ø3ìμıê×¼êä3ö
        close(pipe_in_enc[1]);             // 1رÕòѸ′ÖÆμĶá1üμà
#endif
#endif

        execve(arg_enc[0], arg_enc, NULL);
    }
    else
    {        // ¸¸½ø3ì
        close(pipe_in_enc[1]);        // 1رնá1üμàμÄD′¶Ë
        close(pipe_out_enc[0]);        // 1رÕD′1üμàμĶá¶Ë
    }

    if (!child)
    {
        sleep(1);
        write(pipe_out_enc[1], argv[0], strlen(argv[0]));
        fprintf(stdout, "write %s to enc\n", argv[0]);
        for (i = 0; i < 100; i++)
        {
            if (read(pipe_in_enc[0], buffer, sizeof(buffer) ))
                fprintf(stdout, "get %s from enc\n", buffer);
         }

        waitpid(proc_enc, &status, 0);
    }

    return 0;
}

子进程code
file:enc_dec_test_sub.c

#include<stdio.h>
#include<stdlib.h>
#include<string.h>

/*****************MACRO*******************/

#define BUFFER_SIZE 100
#define USE_PIPE

/******************variable******************/

/******************function******************/

int main(int argc, char *argv[])
{
    char buffer[BUFFER_SIZE];
    char *pRead=NULL;
   
    /* process arguments */
    if (argc < 2)
    {
        fprintf(stderr, "usage: %s sub_id\n", argv[0]);
        return -1;
    }

    do
    {
        pRead = fgets(buffer, BUFFER_SIZE, stdin);
        if (NULL != pRead)
            fprintf(stdout, "[%s -> %s(%s)]\n", buffer, argv[0], argv[1]);
        fflush(stdout);
    }while(1);

    return 0;
}

Makefile
object:enc_dec_test.c enc_dec_test_sub.c
        gcc -g -o enc_dec_test -lpthread enc_dec_test.c
        gcc -g -o enc_dec_test_sub -lpthread enc_dec_test_sub.c

timespace

回复 1# 江南愚人
麻烦用code标签把代码格式化，与人方便与己方便。


   

timespace

死锁了。父进程write没有写‘\n’，子进程fgets无法返回。
“write(pipe_out_enc[1], argv[0], strlen(argv[0]));”

其他就不吐槽了，属于C语言基础（返回值，C str边界等等），不是Linux系统编程。这功能学习研究可以写写，真实项目直接用popen。

江南愚人

回复 3# timespace
感谢指导，已经解决
可是boss的要求和这个不符，需要支持任意二进制文件，所以我不能用fgets，改用read。
修改后的问题是，父进程读不到子进程的输出。

enc_dec_test.c

1. #include<stdio.h>
   
2. #include<stdlib.h>
   
3. #include<string.h>
   
4. #include<unistd.h>
   
5. 
   
6. #include <fcntl.h>
   
7. /*****************MACRO*******************/
   
8. 
   
9. #define BUFFER_SIZE 10
   
10. 
    
11. #define USE_PIPE
    
12. 
    
13. /******************variable******************/
    
14. 
    
15. /******************function******************/
    
16. 
    
17. void dumpMem(char *name, char *pdata, int len)
    
18. {
    
19.     int i;
    
20. 
    
21.     fprintf(stderr, "%s %x:", name, (int)pdata);
    
22.     for (i = 0; i < len; i++)
    
23.     {
    
24.         if (0 == (i % 16))
    
25.             fprintf(stderr, "\n");
    
26.         fprintf(stderr, "0x%02x  ", pdata[i]);
    
27.     }
    
28.     fprintf(stderr, "\n");
    
29. }
    
30. 
    
31. int main(int argc, char *argv[])
    
32. {
    
33.     char buffer[BUFFER_SIZE];
    
34.     char buffer_enc[BUFFER_SIZE];
    
35.     char buffer_dec[BUFFER_SIZE];
    
36.     int  read_cnt, total;
    
37.     int i, len;
    
38.     int child = 0;
    
39. 
    
40.     pid_t proc_enc, proc_dec;
    
41.     int pipe_in_enc[2];
    
42.     int pipe_out_enc[2];
    
43.     int pipe_in_dec[2];
    
44.     int pipe_out_dec[2];
    
45.     char *arg_enc[] = {"./enc_dec_test_sub", "enc", NULL};
    
46.     char *arg_dec[] = {"./enc_dec_test_sub", "dec", NULL};
    
47. 
    
48.     /* create enc pipe */
    
49.     pipe(pipe_in_enc);
    
50.     pipe(pipe_out_enc);
    
51.     if(!(proc_enc = fork()))
    
52.     {
    
53.         child = 1;
    
54.         close(pipe_in_enc[0]);      // 1رո¸½ø3ìμĶá1üμàμÄ×ó½ø3ì¶á¶Ë
    
55.         close(pipe_out_enc[1]);     // 1رո¸½ø3ìμÄD′1üμàμÄ×ó½ø3ìD′¶Ë
    
56. #ifdef USE_PIPE
    
57.         close(STDOUT_FILENO);
    
58.         dup2(pipe_in_enc[1], STDOUT_FILENO);        // ¸′ÖƸ¸½ø3ìμĶá1üμàμ½×ó½ø3ìμıê×¼êä3ö
    
59. //        close(pipe_in_enc[1]);             // 1رÕòѸ′ÖÆμĶá1üμà
    
60. 
    
61.         close(STDIN_FILENO);
    
62.         dup2(pipe_out_enc[0], STDIN_FILENO);        // ¸′ÖƸ¸½ø3ìμÄD′1üμàμ½×ó½ø3ìμıê×¼êäèë
    
63. //        close(pipe_out_enc[0]);     // 1رÕòѸ′ÖÆμÄD′1üμà
    
64. #endif
    
65.         execve(arg_enc[0], arg_enc, NULL);
    
66.         printf("enc pid is %d\n", getpid());
    
67.     }else {        // ¸¸½ø3ì
    
68.         close(pipe_in_enc[1]);        // 1رնá1üμàμÄD′¶Ë
    
69.         close(pipe_out_enc[0]);        // 1رÕD′1üμàμĶá¶Ë
    
70.     }
    
71. #if 1
    
72.     /* create dec pipe */
    
73.     pipe(pipe_in_dec);
    
74. //    pipe(pipe_out_dec);
    
75.     if(!(proc_dec = fork()))
    
76.     {
    
77.         child = 1;
    
78. 
    
79. //        close(pipe_in_enc[0]);
    
80.         close(pipe_in_enc[1]);
    
81.         close(pipe_out_enc[0]);
    
82.         close(pipe_out_enc[1]);
    
83.         
    
84.         close(pipe_in_dec[0]);      // 1رո¸½ø3ìμĶá1üμàμÄ×ó½ø3ì¶á¶Ë
    
85. //        close(pipe_out_dec[1]);     // 1رո¸½ø3ìμÄD′1üμàμÄ×ó½ø3ìD′¶Ë
    
86. #ifdef USE_PIPE
    
87.         close(STDOUT_FILENO);
    
88.         dup2(pipe_in_dec[1], STDOUT_FILENO);        // ¸′ÖƸ¸½ø3ìμĶá1üμàμ½×ó½ø3ìμıê×¼êä3ö
    
89. //        close(pipe_in_dec[1]);             // 1رÕòѸ′ÖÆμĶá1üμà
    
90. 
    
91.         close(STDIN_FILENO);
    
92.         dup2(pipe_in_enc[0], STDIN_FILENO);        // ¸′ÖƸ¸½ø3ìμÄD′1üμàμ½×ó½ø3ìμıê×¼êäèë
    
93. //        close(pipe_in_enc[0]);     // 1رÕòѸ′ÖÆμÄD′1üμà
    
94. #endif
    
95.         execve(arg_dec[0], arg_dec, NULL);
    
96.     }else {        // ¸¸½ø3ì
    
97.         close(pipe_in_dec[1]);        // 1رնá1üμàμÄD′¶Ë
    
98. //        close(pipe_out_dec[0]);        // 1رÕD′1üμàμĶá¶Ë
    
99.     }
    
100. #endif
     
101.     if (!child)
     
102.     {
     
103.         total = 0;
     
104.         do
     
105.         {
     
106.             read_cnt = read(STDIN_FILENO, buffer,BUFFER_SIZE);
     
107.             if (read_cnt)
     
108.             {
     
109.                 write(pipe_out_enc[1], buffer, read_cnt);
     
110. //                read(pipe_in_enc[0], buffer_enc, read_cnt);
     
111. //                printf("get %d bytes\n", total);
     
112. //                write(1, buffer, read_cnt);
     
113. #if 1
     
114. //                fprintf(stdout, "get %d bytes:%s from enc\n", strlen(buffer_enc), buffer_enc);
     
115. //                write(pipe_out_dec[1], buffer_enc, read_cnt);
     
116.                 memset(buffer_dec, 0x5a, BUFFER_SIZE);
     
117.                 read(pipe_in_dec[0], buffer_dec, read_cnt);
     
118.                 total+=read_cnt;
     
119.                 printf("parent get %d bytes\n", total);
     
120.                 if (memcmp(buffer, buffer_dec, read_cnt))
     
121.                 {
     
122.                     printf("different data\n");
     
123.                     dumpMem("parent orign", buffer, read_cnt);
     
124.                     dumpMem("parent dec", buffer_dec, read_cnt);
     
125.                 }
     
126. #endif
     
127.             }
     
128.         }while(read_cnt);
     
129. 
     
130. //        printf("loop over\n");
     
131. 
     
132.         //enc
     
133.         close(pipe_out_enc[1]);        // 1رÕD′1üμà
     
134.         close(pipe_in_enc[0]);        // 1رնá1üμà
     
135.         //dec
     
136.         close(pipe_out_enc[1]);        // 1رÕD′1üμà
     
137.         close(pipe_in_enc[0]);        // 1رնá1üμà
     
138. 
     
139.         /* ê1óÃwaitÏμáDoˉêyμè′y×ó½ø3ìíË3ö2￠è¡μÃíË3ö′úÂë */
     
140.         wait4(proc_enc, NULL, 0, NULL);
     
141.         wait4(proc_dec, NULL, 0, NULL);
     
142.     }
     
143. 
     
144.     return 0;
     
145. }
     

复制代码

enc_dec_test_sub.c

1. #include<stdio.h>
   
2. #include<stdlib.h>
   
3. #include<string.h>
   
4. 
   
5. /*****************MACRO*******************/
   
6. 
   
7. #define BUFFER_SIZE 10
   
8. #define XOR 0X5A
   
9. /******************variable******************/
   
10. 
    
11. /******************function******************/
    
12. 
    
13. void dumpMem(char *name, char *pdata, int len)
    
14. {
    
15.     int i;
    
16. 
    
17.     fprintf(stderr, "%s %x:", name, (int)pdata);
    
18.     for (i = 0; i < len; i++)
    
19.     {
    
20.         if (0 == (i % 16))
    
21.             fprintf(stderr, "\n");
    
22.         fprintf(stderr, "0x%02x  ", pdata[i]);
    
23.     }
    
24.     fprintf(stderr, "\n");
    
25. }
    
26. 
    
27. int main(int argc, char *argv[])
    
28. {
    
29.     char buffer[BUFFER_SIZE];
    
30.     int cnt = 0;
    
31.     int i, total;
    
32.    
    
33.     /* process arguments */
    
34.     if (argc < 2)
    
35.     {
    
36.         fprintf(stderr, "usage: %s sub_id\n", argv[0]);
    
37.         return -1;
    
38.     }
    
39. 
    
40.     total = 0;
    
41.     do
    
42.     {
    
43.         cnt = read(0, buffer, BUFFER_SIZE);
    
44.         if (cnt)
    
45.         {
    
46.                 total += cnt;
    
47. //                fprintf(stderr, "%s got %d bytes\n", argv[1], total);
    
48.                 dumpMem(argv[1], buffer, cnt);
    
49. //            fprintf(stdout, "%s", buffer);
    
50.                 for (i = 0; i < cnt; i++)
    
51.                 {
    
52.                     buffer[i]^=XOR;
    
53.                 }
    
54. //                dumpMem(argv[1], buffer, cnt);
    
55.                 write(1, buffer, cnt);
    
56. //                fflush(stdout);
    
57.         }
    
58.     }while(cnt);
    
59. 
    
60.     exit (0);
    
61. }
    

复制代码

makefile

1. object:enc_dec.c
   
2.         gcc -g -o enc_dec -lpthread enc_dec.c
   
3.         gcc -g -o enc_dec_test -lpthread enc_dec_test.c
   
4.         gcc -g -o enc_dec_test_sub -lpthread enc_dec_test_sub.c
   

复制代码

运行结果

1. [root@linux enc_dec]# ./enc_dec_test
   
2. a
   
3. parent get 2 bytes
   
4. different data
   
5. parent orign bfbadb26:
   
6. 0x61  0x0a
   
7. parent dec bfbadb12:
   
8. 0x00  0x00
   
9. enc bfcdc5ce:
   
10. 0x61  0x0a
    
11. enc bfcdc5ce:
    
12. 0x3b  0x50
    
13. dec bfacad5e:
    
14. 0x3b  0x50
    
15. dec bfacad5e:
    
16. 0x61  0x0a
    

复制代码

546588532

你们BOSS要求的是什么？怎么感觉你这个实现的想法好别扭啊。