XV6中多管道函数无法写入正确数据且执行停滞问题排查

问题描述 #

我在XV6环境中实现了一个处理三个命令管道并将结果写入输出文件的函数，用三个字符数组存储操作指令，但遇到两个问题：

• 调用close(1)时程序一直阻塞无法退出
• 注释close(1)后，输出文件能创建但内容是随机值

预期输入如ls | grep tests | grep user，期望输出文件写入usertests 2 15 180504，但当前程序执行到close(1)就停滞。

原代码 #

int handle_multiple_pipes(char **operation1, char **operation2, char **operation3){
int fd1[2];
if(pipe(fd1) == -1){
    return -1;
}
int status;
int pid1 = fork();
if (pid1 < 0) {
    return -1;
}
if(pid1 == 0){
    close(1);
    dup(fd1[1]);
    close(fd1[1]);
    close(fd1[0]);
    exec(operation1[0], operation1);
    exit(1);
}
int pid2 = fork();
if (pid2 < 0) {
    return -1;
}
if(pid2 == 0){
    close(0);
    dup(fd1[1]);
    close(fd1[1]);
    close(1);
    dup(fd1[0]);
    close(fd1[1]);
    exec(operation2[0], operation2);
    exit(1);
}
int pid3 = fork();
if (pid3 < 0) {
    return -1;
}
if(pid3 == 0){
    int i=0;
    int type_of_direction = 0;
    char *output_file_path = "NULL";
    while(operation3[i] != 0){
        int redirection = strcmp(operation3[i], ">");
        if (redirection == 0){
            type_of_direction = 1;
            output_file_path = operation3[i+1];
            operation3[i] = '\0';
            operation3[i+1] = '\0';
        }
        i++;
    }
    if (type_of_direction == 0){
        close(0);
        dup(fd1[0]);
        close(fd1[0]);
        close(fd1[1]);
        exec(operation3[0], operation3);
        exit(1);
    }
    else if (type_of_direction == 1){
        printf("IN HERE 0\n");
        int output_file = open(output_file_path, O_CREATE | O_WRONLY);
        printf("IN HERE 1\n");
        close(fd1[0]);
        // close(fd1[1]);
        printf("IN HERE 2\n");
        wait(&status);
        close(1);
        printf("IN HERE 3\n");
        dup(output_file);
        printf("IN HERE 4\n");
        exec(operation3[0], operation3);
        close(output_file);
        exit(1);
    }
}
close(fd1[0]);
close(fd1[1]);
wait(&status);
wait(&status);
wait(&status);
return 1;
}

核心问题分析 #

1. 管道复用错误：三个命令需要两个管道传递数据，原代码只用一个管道fd1，且第二个子进程的管道方向完全搞反，导致数据流混乱引发阻塞。
2. 子进程多余wait调用：第三个子进程内的wait(&status)完全错误，子进程无需等待其他进程，父进程统一处理等待逻辑即可，该调用直接导致阻塞。
3. 文件打开参数不完整：XV6中open函数创建文件时必须指定权限位，原代码缺失权限参数会导致文件权限异常，引发写入问题。
4. 管道描述符未完全关闭：各进程未关闭所有未使用的管道端，导致管道无法检测EOF，引发阻塞。
5. 重定向顺序错误：关闭stdout后调用printf会失效，且重定向逻辑未先处理标准输入，导致命令无法读取前序管道的数据。

修复后的代码 #

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/wait.h>

int handle_multiple_pipes(char **operation1, char **operation2, char **operation3){
    int fd1[2]; // 用于operation1 -> operation2的管道
    int fd2[2]; // 用于operation2 -> operation3的管道
    if(pipe(fd1) == -1 || pipe(fd2) == -1){
        return -1;
    }
    int status;
    int pid1 = fork();
    if (pid1 < 0) {
        return -1;
    }
    if(pid1 == 0){
        // 第一个进程：stdout重定向到fd1写端
        close(1);
        dup(fd1[1]);
        // 关闭所有未使用的管道端
        close(fd1[0]);
        close(fd1[1]);
        close(fd2[0]);
        close(fd2[1]);
        exec(operation1[0], operation1);
        exit(1); // exec失败才会执行到这里
    }
    int pid2 = fork();
    if (pid2 < 0) {
        return -1;
    }
    if(pid2 == 0){
        // 第二个进程：stdin从fd1读，stdout写到fd2
        close(0);
        dup(fd1[0]);
        close(1);
        dup(fd2[1]);
        // 关闭所有未使用的管道端
        close(fd1[0]);
        close(fd1[1]);
        close(fd2[0]);
        close(fd2[1]);
        exec(operation2[0], operation2);
        exit(1);
    }
    int pid3 = fork();
    if (pid3 < 0) {
        return -1;
    }
    if(pid3 == 0){
        int i=0;
        int type_of_direction = 0;
        char *output_file_path = NULL;
        while(operation3[i] != NULL){
            if (strcmp(operation3[i], ">") == 0){
                type_of_direction = 1;
                output_file_path = operation3[i+1];
                operation3[i] = NULL; // 截断命令参数
                break; // 找到重定向符后停止遍历
            }
            i++;
        }
        // 先将stdin重定向到fd2读端
        close(0);
        dup(fd2[0]);
        // 关闭所有未使用的管道端
        close(fd1[0]);
        close(fd1[1]);
        close(fd2[0]);
        close(fd2[1]);
        
        if (type_of_direction == 1){
            // 打开输出文件，添加截断和权限参数
            int output_file = open(output_file_path, O_CREATE | O_WRONLY | O_TRUNC, 0644);
            if(output_file < 0){
                exit(1);
            }
            // 重定向stdout到文件
            close(1);
            dup(output_file);
            close(output_file); // 复制完成后关闭原文件描述符
        }
        exec(operation3[0], operation3);
        exit(1);
    }
    // 父进程关闭所有管道端，避免子进程阻塞
    close(fd1[0]);
    close(fd1[1]);
    close(fd2[0]);
    close(fd2[1]);
    // 等待所有子进程结束
    wait(&status);
    wait(&status);
    wait(&status);
    return 1;
}

关键修复点说明 #

• 新增第二个管道fd2：三个命令需要两个管道串联数据流，解决原代码单管道复用的混乱问题。
• 修正管道重定向方向：每个子进程仅保留自身需要的管道端，正确关联标准输入/输出。
• 移除子进程内的wait调用：父进程统一处理子进程等待，避免子进程不必要的阻塞。
• 完善文件打开参数：添加O_TRUNC（覆盖原有内容）和权限位0644，符合XV6的系统调用要求。
• 调整重定向顺序：先处理标准输入，再处理标准输出，避免关闭stdout后调试信息无法输出。
• 完全关闭管道描述符：所有进程关闭未使用的管道端，确保管道能正确检测EOF，消除阻塞根源。

内容的提问来源于stack exchange，提问作者Shubham Bajaj