Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Is it possible to have pipe between two child processes created by same parent (LINUX, POSIX)

Tags:

c

linux

pipe

ipc

I have multiple child "forked" by the same parent and I try to construct pipe connection between all these child processes like a linked list structure. Child 1 sends data to child2, child 2 to child 3.... child N to child 1. Is there any proper way to do it?

In addition, if I create and communicate between processes how I force the parent to "wait" all the process to finish their job since wait() or waitpid() waits for first finished process but I need to wait them all. It is the another question that arises.

Thanks...

like image 309
erogol Avatar asked Mar 07 '11 22:03

erogol


People also ask

Which pipe allows communication between parent and child processes?

Here is a simple Python program to demonstrate communication between the parent process and child process using the pipe method. pipe() System call : The method pipe() creates a pipe and returns a pair of file descriptors (r, w) usable for reading and writing, respectively.

Can multiple processes write to the same pipe?

Yes, multiple processes can read from (or write to) a pipe. But data isn't duplicated for the processes.

Can a process have multiple child processes?

Creating multiple process using fork() Explanation – Here, we had used fork() function to create four processes one Parent and three child processes. An existing process can create a new one by calling the fork( ) function. The new process created by fork() is called the child process.

Which segment will not be shared between parent and child in Linux?

Explanation: In Unix operating system, when a process creates a new process using the fork () system call, then memory segments are shared between parent process and child process but stack and heap area are not shared between parent process and child process.


1 Answers

This is essentially what a shell does if build a redirection chain, i.e. something like

ls | grep foo | sort | uniq

There are some excellent introducionary texts on Unix programming, in which a simple shell is implemented through the book. And one of the tasks of a shell is redirection. One of these books is "Linux Application Programming" by Michael K. Johnson and Erik W. Troan.

The book's homepage: http://ladweb.net/

To build a chain of redirections for N processes you need N-1 pipes. For each redirection you create a pipe using the pipe(int fds[2]) system call. After fork()ing, but before execving use dup2(int from, int to) to "connect" a pipe's end to the standard input (0) or standard output of each process. Here's a overly simplified code, without error checking:

int pipe_A[2];
int pipe_B[2];

pipe(pipe_A);
pipe(pipe_B);

pid_t pid_A, pid_B, pid_C;

if( !(pid_A = fork()) ) {
    dup2(pipe_A[1], 1); /* redirect standard output to pipe_A write end */
    execv(...);
}

if( !(pid_B = fork()) ) {
    dup2(pipe_A[0], 0); /* redirect standard input to pipe_A read end */
    dup2(pipe_B[1], 1); /* redirect standard output to pipe_B write end */
    execv(...);
}

if( !(pid_C = fork()) ) {
    dup2(pipe_B[0], 0); /* redirect standard input to pipe_B read end */
    execv(...);
}

Take note that the pipe's array indices have been choosen in a way that they reflect the standard input/output file descriptors if they're used for stdio redirection. This choice was not arbitrary.

Of course you can connect pipes to any file descriptors (e.g. there are some applications, which expect their parent to open, say fd 3 and 4, connected to pipes) and most shells directly support this, too (for example 1>&3 will redirect stdout into fd 3). However the array indices for pipe(int fds[2]) are 0 and 1 of course. I'm just telling this, because I had some cargo-cult-programming students, which mindlessly took the target fds also for the pipe syscall array.

To wait for all the children to finish use waitpid(-1, NULL, 0) – I think that's the -1 my pre-answerer meant, which means: Wait for all child processes to finish. The other option was calling wait() in a loop which will return the pid of the just terminated child. If called again and there's still a child running, it will block again. If there's no child left, it will return -1; I prefer the waitpid solution.

like image 175
datenwolf Avatar answered Sep 22 '22 23:09

datenwolf