1

我正在尝试使用匿名管道实现以下管道：

cat filename | grep "a" | wc -c

该程序似乎挂在grep命令上，我不明白为什么。我尝试过使用其他一些命令而不是 grep，并且效果很好。

这是到目前为止的代码......

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

    #define READ  0
    #define WRITE 1

    #define handle_errno(msg)   do{perror(msg); exit(EXIT_FAILURE);}while(0);

int main(int argc, char *argv[]){

int fd1[2], fd2[2];

if(argc != 2 || !strcmp(argv[1], "--help")){
    fprintf(stderr, "Usage : %s <filepath>\n", argv[0]);
    exit(EXIT_FAILURE);
}

if(access(argv[1], F_OK) == -1)
    handle_errno("access error");

if(pipe(fd1) == -1)
    handle_errno("pipe 1 error");

if(pipe(fd2) == -1)
    handle_errno("pipe 2 error");

switch(fork()){
    case -1:    handle_errno("fork 1 error");

    case  0:        
            /* first child: writer on pipe1 */
            if(close(fd1[READ]) == -1)
                handle_errno("child 1, close error");

            if(fd1[WRITE] != STDOUT_FILENO){
                if(dup2(fd1[WRITE], STDOUT_FILENO) == -1)
                    handle_errno("child 1, dup 2 error");

                if(close(fd1[WRITE]) == -1)
                    handle_errno("child 1, close error");
            }

            execlp("cat", "cat", argv[1], (char*)NULL);
            handle_errno("child 1, execlp cat error");
    default:
            break;
}

switch(fork()){
    case -1:    handle_errno("fork 2 error");

    case  0:        
            /* second child: reader on pipe1, writer on pipe2 */
            if(close(fd1[WRITE]) == -1)
                handle_errno("child 2, close error");

            if(close(fd2[READ]) == -1)
                handle_errno("child 2, close error");

            if(fd1[READ] != STDIN_FILENO){
                if(dup2(fd1[READ], STDIN_FILENO) == -1)
                    handle_errno("child 2, dup 2 error");

                if(close(fd1[READ]) == -1)
                    handle_errno("child 2, close error");
            }

            if(fd2[WRITE] != STDOUT_FILENO){
                if(dup2(fd2[WRITE], STDOUT_FILENO) == -1)
                    handle_errno("child 2, dup 2 error");

                if(close(fd2[WRITE]) == -1)
                    handle_errno("child 2, close error");
            }

            execlp("grep", "grep", "\"a\"", (char*)NULL);
            handle_errno("child 2, execlp grep error");

    default:
            break;
}

switch(fork()){
    case -1:    handle_errno("fork 3 error");

    case  0:        
            /* third child: reader on pipe2 */
            if(close(fd2[WRITE]) == -1)
                handle_errno("child 3, close error");

            if(fd2[READ] != STDIN_FILENO){
                if(dup2(fd2[READ], STDIN_FILENO) == -1)
                    handle_errno("child 3, dup 2 error");

                if(close(fd2[READ]) == -1)
                    handle_errno("child 3, close error");
            }

            execlp("wc", "wc", "-c", (char*)NULL);
            handle_errno("child 3, execlp wc error");
        default:
            break;
    }

    if(close(fd1[READ]) == -1)
        handle_errno("father, close error");

    if(close(fd1[WRITE]) == -1)
        handle_errno("father, close error");

    if(close(fd2[READ]) == -1)
        handle_errno("father, close error");    

    if(close(fd2[WRITE]) == -1)
        handle_errno("father, close error");

    if(wait(NULL) == -1)
        handle_errno("father, wait error");

    if(wait(NULL) == -1)
        handle_errno("father, wait error");

    if(wait(NULL) == -1)
        handle_errno("father, wait error");

    exit(EXIT_SUCCESS);
}
4

2 回答 2

0

问题是您在进程 3 (wc) 中打开了管道 #1 的额外管道句柄。在调用 exec 之前关闭所有不必要的句柄。

于 2012-01-07T22:31:17.977 回答
0

您在寻找“a”还是a？双引号可能会从 shell 语法中遗留下来。

于 2012-01-06T18:13:15.823 回答