어떻게 유닉스 파이프를 동적으로 생성합니까?

Question

나는 자식 프로세스를 만드는 데 fork()을 사용하는 프로그램을 가지고 있으며, 아이들이 유닉스 파이프를 사용하여 부모 프로세스와 다시 통신하도록하고 싶습니다.

문제는 다중 파이프가 생성되지 않았거나 배열에 문제가있는 것입니다. 부모 프로그램에서 prinf()을 사용할 때 각 자식이 다른 데이터를 보내더라도 모든 파이프에서 동일한 데이터를 읽습니다.

여기 내 코드입니다 : 내 의견에 언급 한 바와 같이

// Variables 
int pipes_count = 0; 
int *pipes[MAXCLIENTS]; 
int new_pipefd[2]; 
int pipe_bytes; 
char pipe_buffer[MAXDATASIZE]; 

while(1) { 
    // Pipe creation 
    pipe(new_pipefd); 
    pipes[pipes_count] = new_pipefd; 
    pipes_count++; 

    if (fork()) { 
     // unrelated code for parent here 
     close(new_pipefd[1]); // close the parent's write-end of the pipe 
     break; 
    } else { 
     // unrelated code for child here 
     close(new_pipefd[0]); // close the child's read-end of the pipe 
     break; 
    } 

    if (some condition) { break; } // The parent will stop creating pipes 
} 

while(condition that guarantees this is the child) { 
    write(new_pipefd[1], buffer, strlen(recv_buffer)); 
    close(new_pipefd[1]); 
    return 0; // the child process ends 
} 

// This is a loop where the parent reads what the children sent 
for (int i = 0; i < pipes_count; i++) { 
    pipe_bytes = read(pipes[i][0], pipe_buffer, sizeof pipe_buffer); 
    if (pipe_bytes == 0) { 
     close(pipes[i][0]); 
    } else { 
     printf("Testing: %s\n", pipe_buffer); 
    } 
} 

Answer 1

, 문제가에 할당 pipes[pipes_count] = new_pipefd;에 있습니다

int pipes_count = 0; 
int *pipes[MAXCLIENTS]; 
int new_pipefd[2]; 
int pipe_bytes; 
char pipe_buffer[MAXDATASIZE]; 

while(1) { 
    // Pipe creation 
    pipe(new_pipefd); 
    pipes[pipes_count] = new_pipefd; 
    pipes_count++; 

말썽 변수 new_pipefd가 배열이라는 것이다, 따라서 동일한 배열의 주소를 pipes의 각 요소에 복사합니다. 즉, 부모는 만든 마지막 파이프에만 액세스 할 수 있습니다.

난 당신이 더 같은 코드를 사용해야한다고 생각 :

int pipes_count = 0; 
int pipes[MAXCLIENTS]; // Changed type! 
int new_pipefd[2]; 
char pipe_buffer[MAXDATASIZE]; 

while (1) 
{ 
    // Pipe creation 
    pipe(new_pipefd); 
    pipes[pipes_count++] = new_pipefd[0]; // Just the read end of the pipe 

    if (fork()) 
    { 
     // unrelated code for parent here 
     close(new_pipefd[1]); // close the parent's write-end of the pipe 
     // break;    // This break is not wanted 
    } 
    else 
    { 
     // unrelated code for child here 
     close(new_pipefd[0]); // close the child's read-end of the pipe 
     break; 
    } 

    if (some condition) 
     break;  // The parent will stop creating pipes 
} 

while (condition that guarantees this is the child) 
{ 
    write(new_pipefd[1], buffer, strlen(recv_buffer)); 
    close(new_pipefd[1]); 
    return 0; // the child process ends 
} 

// This is a loop where the parent reads what the children sent 
for (int i = 0; i < pipes_count; i++) { 
    int pipe_bytes = read(pipes[i], pipe_buffer, sizeof(pipe_buffer)); 
    if (pipe_bytes != 0) 
     printf("Testing: %.*s\n", pipe_bytes, pipe_buffer); // Safe! 
    close(pipes[i]); 
} 

는 내 코드 있었, 나는에 호출 (I 전통적 be_childish() 전화) 기능을 가지고하려는 '그것은 아이가' 루프의 코드 블록 이 함수는 절대로 반환되지 않으며 필요한 리소스가 모두 전달됩니다 ( new_pipefd, 아마도 다른 정보도 가능). 나는 종종 부모님의 활동을하기 위해 be_parental()의 기능을 가지고있다. 이 코드는 대부분의 코드를 정리하여 작업을 명확하게 분리합니다.