pipe: Плохой дескриптор файла

Question

Я пытаюсь реализовать оболочку simpel c, которая будет конвейерное произвольное количество команд. Вот соответствующий цикл:

int status; 
int i,j,inputFile,outputFile,pid; 
int pipeNum = info->pipeNum; 

struct commandType *command; 

int pipes[pipeNum * 2]; 
for(i=0;i<pipeNum;i++){ 
    pipe(pipes+2*i); 
    printf("PIPE NUMBER %d CREATED\n", i+1); 
} 
for(j=0;j<=pipeNum;j++){ 
    if((pid=fork()) ==0){ 
    if(j!=0){ 
     if(dup2(pipes[(j-1)*2],STDIN_FILENO)<0){ 
     perror("pipe"); 
     exit(2); 
     } 
    } 
    if(j!=pipeNum){ 
     if(dup2(pipes[2*j+1],STDOUT_FILENO)<0){ 
     perror("pipe"); 
     exit(2); 
     } 
    } 
    if(j==0 && info->boolInfile==1){ 
     if((inputFile = open(info->inFile,O_RDONLY))<0){ 
    perror("file"); 
    exit(2); 
     } 
     if(dup2(inputFile,STDIN_FILENO)<0){ 
     perror("dup2"); 
     exit(2); 
     } 
    } 
    if(j==pipeNum && info->boolOutfile){ 
     if((outputFile = open(info->outFile,O_WRONLY | O_CREAT | O_TRUNC, 666)<0)){ 
    perror("file"); 
    exit(2); 
     } 

     if(dup2(outputFile,STDOUT_FILENO)<0){ 
     perror("dup2"); 
     exit(2); 
     } 
    } 
    for(i=0;i<pipeNum*2;i++){ 
     close(pipes[i]); 
     } 
    command=&info->CommArray[j]; 
    execvp(command->VarList[0],command->VarList); 
    perror("Bad command"); 
    } 
    for(i=0;i<pipeNum*2;i++){ 
    close(pipes[i]); 
    } 
    for(i=0;i<pipeNum+1;i++){ 
    wait(&status); 
    } 
} 

Но когда я пытаюсь запустить команду

cat file.txt | wc 

Я получаю следующее сообщение об ошибке:

pipe: Bad file descriptor. 

Видит кто-нибудь изъян в моем коде Вот? Я не могу понять, чтобы спасти свою жизнь.

Я добавил несколько операторов строки печати, и я получаю дескриптор плохого файла для каждого отдельного канала. тьфу.

Answer 1

Плохие строки кода находятся в самом конце цикла for. Вместо

} 
    for(i=0;i<pipeNum*2;i++){ 
    close(pipes[i]); 
    } 
    for(i=0;i<pipeNum+1;i++){ 
    wait(&status); 
    } 
} 

я должен

}  
} 
for(i=0;i<pipeNum*2;i++){ 
    close(pipes[i]); 
} 
for(i=0;i<pipeNum+1;i++){ 
    wait(&status); 
}