При подобном применении open, когда родитель хочет передать данные потомку, он использует нечто похожее на пример 16.5.

Пример 16.5. pipe3

#!/usr/bin/perl -w

# pipe3 - применение разветвляющего вызова open

# для передачи данных от родителя к потомку

use 10::Handle;

If ($pid = open(CHILD, "l-")) { CHILD->autoflush(1);

print CHILD "Parent Pid $$ is sending this\n"; close(CHILD); } else {

die "cannot fork: $!" unless defined Spid; chomp($line = <STDIN>);

print "Child Pid $$ just read this; $line\n"; exit;

Поскольку STDIN потомка уже подключен к родителю, потомок может запустить через exec другую программу, читающую данные из стандартного ввода - например, Ipr. Это полезная и часто используемая возможность.

Если потомок захочет передать данные родителю, он делает нечто похожее на пример 16.6.

Пример 16.6. pipe4

#!/usr/bin/perl -w

# pipe4 - применение разветвляющего вызова open

# для передачи данных от потомка к родителю

use 10::Handle;

if (Spid = open(CHILD, "-!")) { chomp($line = <CHILD>);

print "Parent Pid $S just read this; SlineXn"; close(CHILD); ! else {

die "cannot fork: $!" unless defined Spid; STD0UT->autoflush(1);

print STDOUT "Child Pid SS is sending this\n"; exit;

И снова, поскольку STDOUT потомка уже подключен к родителю, потомок может запустить через exec другую программу, выдающую нечто интересное в его стандартный вывод. Эти данные также будут переданы родителю как ввод от <CHILD>.

При подобном использовании open мы не обязаны вручную вызывать waitpid, поскольку не было явного вызова fork. Однако close вызвать все же надо. В обоих случаях неременная $? содержит статус ожидания порожденного процесса (о том, как интерпретировать это значение, рассказано в рецепте 16.19).

В предыдущих примерах рассматривалась однонаправленная связь. Что делать, если вы хотите, чтобы данные передавались в обе стороны? Дважды вызовите pipe перед вызовом fork. Вам придется следить за тем, кто, что и когда передает, иначе может возникнуть взаимная блокировка (см. пример 16.7).

Пример 16.7. pipes

#!/usr/bin/perl -w

# pipes - двусторонний обмен данными с использованием двух каналов

# без применения socketpair use 10::Handle; pipe(PARENT RDR, CHILD.WTR); pipe(CHlLD RDR, PARENT WTR); CHlLD WTR->autoflush(1); PARENT WTR->autoflush(1);

if ($pid = fork) {

close PARENT RDR; close PARENT WTR;

print CHILD WTR "Parent Pid $$ is sending this\n";

chomp($line = <CHILD RDR>);

print "Parent Pid $$ ]ust read this: $line\n";

close CHILD RDR; close CHILD WTR;

waitpid($pid,0); } else {

die "cannot fork: $!" unless defined $pid;

close CH1LD RDR; close CH1LD WTR;

chomp($line = <PARENT RDR>);

print "Child Pid $$ ]ust read this: SlineXn";

print PARENT WTR "Child Pid $$ is sending this\n":

close PARENT RDR; close PARENT,WTR:

exit;

Ситуация усложняется. Оказывается, существует специальная системная функция socketpair (см. пример 16.8), которая упрощает предыдущий пример. Она работает аналогично pipe, за исключением того, что оба манипулятора могут использоваться как для приема, так и для передачи.

Пример 16.8. р1реб

#!/usr/bin/perl -W

# pipeO - двусторонний обмен данными с применением socketpair

use Socket; use 10:;Handle;

# Мы говорим AF UN1X, потому что хотя константа * LOCAL

# соответствует P0S1X 1003,1д, на многих компьютерах

# она еще не поддерживается.

socketpair(CHILD, PARENT, AF.UNIX, SOCK STREAM, PF UNSPEC) or die "socketpair; $!";

580 Глава 16 • Управление процессами и межпроцессные взаимодействия Пример 16.8 (продолжение)

CHIL0->autoflush(1), PARENT->autoflush(1),

If ($pid = fork) { close PARENT,

print CHILD Parent Pid $$ is sending this\n chomp($line = <CH1LD>)

print Parent Pid $$ just read this $line \n , close CHILD waitpid($pid 0), } else {

die cannot fork $ unless defined $pid, close CHILD, chomp($line = <PARENT>)

print Child Pid $$ ]ust read this $line \n , print PARENT Child Pid $$ is sending this\n close PARENT, exit

В некоторых системах каналы исторически были реализованы как два полузакрытых конца пары сокетов. Фактически реализация pipe(READER, WRITER) выглядела так:

socketpair(READER WRITER AF UNIX, SOCK STREAM, PF UNSPEC) shutdown(READER, 1), # Запретить запись для READER

shutdom(WRITER 0) # Запретить чтение для WRITER

В ядрах Lmux до версии 2.0.34 системная функция shutdown(2) работала iieeep-но. Приходилось запрещать чтение для READER и запись для WRITER.

О Смотри также-

Описания всех использованных функций вperlfunc{i); документация но стандартному модулю 1РС::0реп2; рецепт 16.8.

16.11. Имитация файла на базе именованного канала

Проблема

Вы хотите, чтобы процесс перехватывал все обращения к файлу. Например, файл -/.plan должен превратиться в программу, которая будет возвращать случайную цитату.

Решение

Воспользуйтесь именованными каналами. Сначала создайте канал (вероятно, в командном интерпретаторе):