使用 Posix 分叉和管道的 NativeCall 代码不起作用

Question

好的，所以我是 Perl 和 Perl 6 的新手。我想看看我是否可以让 fork 和管道工作，但到目前为止还不能。这是我的 Perl 6 代码：

use NativeCall;

# http://www.perlmonks.org/?node_id=989766
our sub c_close(int32) returns int32 is native is symbol('close') { * }
sub pipe(CArray[int32]) returns int32 is native { ... }
our sub c_read(int32, Str is encoded('utf8'), size_t) returns ssize_t is native is symbol('read') { *}
our sub c_write(int32, Str is encoded('utf8'), size_t) returns ssize_t is native is symbol('write') { *}
our sub c_wait(int32 is rw) is native is symbol('wait') { * }
sub c_puts(Str) is native is symbol("puts") { * }
sub waitpid(int32, Pointer, int32) returns int32 is native {*};

my @fd := CArray[int32].new;
#my ($child, $parent);
my $pok = pipe(@fd);
if ($pok == -1) { die "Pipe failed" ; }

sub fork() returns int32 is native { ... };

# See:
# https://rosettacode.org/wiki/Fork#Perl_6
my $pid = fork();
if ( $pid < 0) { die "Fork failed" ; }
if ( $pid == 0) {
        print "C: I am the child\n";
        if (c_close(@fd[1]) == -1) { die "Child couldn't close fd[1]" };
        my $msg_in = "";
        say "C: starting read";
        my $nread = c_read(@fd[0], $msg_in, 80);
        print "C: nread=$nread\n";
        print "C: message:$msg_in.\n";
        c_close(@fd[0]);
} else {
        print "P: I am the parent of $pid\n";
        if (c_close(@fd[0]) == -1) { die "Parent couldn't close fd[0]"; } ;
        my $msg  = "Hello from parent";
        my $len =  $msg.encode('utf8').bytes + 1;
        print "P: test put string: ";
        c_puts($msg);
        #print "P: len=$len\n";
        my $nwritten =c_write(@fd[1], $msg, $len);
        print "P: len $len, wrote $nwritten\n";
        say "P: Finished writing";
        c_close(@fd[1]);
        #my $null= 0;
        #c_wait($null);
        my $stat_loc;
        waitpid($pid, $stat_loc ,0);
}

这是运行的结果：

P: I am the parent of 25809
C: I am the child
C: starting read
C: nread=-1
C: message:.
P: test put string: Hello from parent
P: len 18, wrote -1
P: Finished writing

似乎c_read() 函数由于某种原因没有阻塞，AFAIK 是不可能的。反正我对分叉了解不多。

知道解决方法是什么吗？

回答

2016 年 12 月 19 日更新

感谢@timotimo，我得到了一个可行的解决方案。看来我的努力可能会有所改进。例如，我认为它不适用于 UTF-8。 Anyhoo，至少“它有效”。

use NativeCall;

# http://www.perlmonks.org/?node_id=989766
our sub c_close(int32) returns int32 is native is symbol('close') { * }
our sub c_fork() returns int32 is native is symbol('fork') { ... };
our sub c_pipe(CArray[int32]) returns int32 is native is symbol('pipe') { ... }
our sub c_puts(Str) is native is symbol("puts") { * }
our sub c_read(int32, CArray[uint8], size_t) returns ssize_t is native is symbol('read') { *}
our sub c_wait(int32 is rw) is native is symbol('wait') { * }
our sub c_waitpid(int32, Pointer, int32) returns int32 is native is symbol('waitpid') {*};
our sub c_write(int32, Str is encoded('utf8'), size_t) returns ssize_t is native is symbol('write') { *}


my @fd := CArray[int32].new(0, 0);
my $pok = c_pipe(@fd);
if ($pok == -1) { die "Pipe failed" ; }


# See:
# https://rosettacode.org/wiki/Fork#Perl_6
my $pid = c_fork();
if ( $pid < 0) { die "Fork failed" ; }
if ( $pid == 0) {
        print "C: I am the child\n";
        if (c_close(@fd[1]) == -1) { die "Child couldn't close fd[1]" };
        my uint8 $b0 = 0;
        my @buf := CArray[uint8].new( $b0 xx 80);
        say "C: starting read";
        my $nread = c_read(@fd[0], @buf, 80);
        print "C: nread=$nread\n";
        my $msg = "";
        for (0..$nread-1) -> $i { $msg = $msg ~ chr(@buf[$i]); } ;
        print "C: message:$msg.\n";
        c_close(@fd[0]);
} else {
        print "P: I am the parent of $pid\n";
        if (c_close(@fd[0]) == -1) { die "Parent couldn't close fd[0]"; } ;
        my $msg  = "Hello from parent";
        my $len =  $msg.encode('utf8').bytes;
        print "P: test put string: ";
        c_puts($msg);
        my $nwritten =c_write(@fd[1], $msg, $len);
        print "P: len $len, wrote $nwritten\n";
        say "P: Finished writing";
        c_close(@fd[1]);
        my $stat_loc;
        c_waitpid($pid, $stat_loc ,0);
}

现在按预期输出：

P: I am the parent of 22448
C: I am the child
P: test put string: Hello from parent
C: starting read
P: len 17, wrote 17
P: Finished writing
C: nread=17
C: message:Hello from parent.

我创建了一个gist，并酌情修改了解决方案。

Answer 1

您的问题完全不同。

您创建了 CArray，但实际上并没有为管道要写入的两个 int 腾出空间。写入进入了谁知道在哪里，而您的 @fd 中只有 [0, 0] 的内容，因此您在读取和写入时获得了 BADF（错误文件描述符），因此它们立即返回。

strace -f 是一个出色的工具，无论您何时使用 posix api 东西。这给了我正确的想法。

这是使@fd 工作所需的代码：

my @fd := CArray[int32].new(0, 0);

pipe made
here's the pipe fds
17
18
P: I am the parent of 13943
C: I am the child
C: starting read
P: test put string: Hello from parent
P: len 18, wrote 18
P: Finished writing
C: nread=18
C: message:.

PS：消息没有正确写入，因为c_read 的 Str 参数没有像您期望的那样工作。您必须再次执行相同的 CArray 操作，为其提供正确的大小（通过分配 0 xx $size 或执行 @result[$size + 1] = 0），然后您必须将其解码为 utf8 或 latin1 或 what-have-you .