Linux программирование в примерах
вернуться

Роббинс Арнольд
Шрифт:

2. Создать то, что мы называем «левым потомком». Это процесс, стандартный вывод которого идет в канал. В данном процессе сделать следующее:

 a. Использовать '

close(pipefd[0])
', поскольку читаемый конец канала в левом потомке не нужен.

 b. Использовать '

close(1)
', чтобы закрыть первоначальный стандартный вывод.

 c. Использовать '

dup(pipefd[1])
' для копирования записываемого конца канала в дескриптор файла 1.

 d. Использовать '

close(pipefd[1])
', поскольку нам не нужны две копии открытого дескриптора.

 e. Выполнить

exec
для запускаемой программы.

3. Создать то, что мы называем «правым потомком». Это процесс, стандартный ввод которого поступает из канала. Шаги для этого потомка являются зеркальным отражением шагов для левого потомка:

 a. Использовать '

close(pipefd[1])
', поскольку записываемый конец канала в правом потомке не нужен.

 b. Использовать '

close(0)
', чтобы закрыть первоначальный стандартный ввод.

 c. Использовать '

dup(pipefd[0])
' для копирования читаемого конца канала в дескриптор файла 0.

 d. Использовать '

close(pipefd[0])
', поскольку нам не нужны две копии открытого дескриптора.

 e. Выполнить

exec
для запускаемой программы.

4. В родителе закрыть оба конца канала — '

close(pipefd[0]); close(pipefd[1])
'.

5. Наконец, использовать в родителе

wait
для ожидания завершения обоих порожденных процессов.

Обратите внимание, как важно закрыть неиспользуемые копии дескрипторов файлов каналов. Как мы отмечали ранее, файл не закрывается до тех пор, пока не будет закрыт последний открытый для него дескриптор. Это верно, даже если дескрипторы файлов разделяют несколько процессов. Закрытие не использующихся дескрипторов файлов имеет значение, поскольку процесс, читающий из канала, не получит указания конца файла, пока все копии записываемого конца не будут закрыты.

В нашем случае после порождения двух потомков имеются три процесса, у каждого из которых есть копии двух дескрипторов файлов каналов: родительский и два порожденных. Родительский процесс закрывает оба конца, поскольку ему не нужен канал. Левый потомок записывает в канал, поэтому ему нужно закрыть читаемый конец. Правый потомок читает из канала, поэтому ему нужно закрыть записываемый конец. Это оставляет открытым ровно по одной копии дескриптора файла.

Когда левый потомок завершает работу, он заканчивается. Система после этого закрывает все его дескрипторы файлов. Когда это случается, правый потомок получает в конечном счете уведомление конца файла и тоже может завершить работу и выйти.

Следующая программа,

ch09-pipeline.c
, создает эквивалент следующего конвейера оболочки:

$ echo hi there | sed s/hi/hello/g

hello there

Вот программа:

1 /* ch09-pipeline.c --- ответвляет два процесса в их собственный конвейер.

2 Для краткости проверка ошибок сведена к минимуму. */

3

4 #include <stdio.h>

5 #include <errno.h>

6 #include <sys/types.h>

7 #include <sys/wait.h>

8 #include <unistd.h>

9

10 int pipefd[2];

11

12 extern void left_child(void), right_child(void);

13

14 /* main --- порождение процессов и ожидание их завершения */

15

16 int main(int argc, char **argv)

17 {

18 pid_t left_pid, right_pid;

19 pid_t ret;

20 int status;

21

22 if (pipe(pipefd) < 0) { /* создать канал в самом начале */

23 perror("pipe");

24 exit(1);

25 }

26

27 if ((left_pid = fork) < 0) { /* порождение левого потомка */

28 perror("fork");

29 exit(1);

30 } else if (left_pid == 0)

31 left_child;

32

33 if ((right_pid = fork) < 0) { /* порождение правого потомка */

34 perror("fork");

35 exit(1);

36 } else if (right_pid == 0)

37 right_child;

38

39 close(pipefd[0])); /* закрыть родительские копии канала */