- my $sock = new IO::Socket::INET;
- local *H;
- my $wrt = \*H;
-
- if ($conn->{pid} = open3("<&$sock", ">&$sock", '', $line)) {
- $conn->{sock} = $sock;
- $conn->{csort} = $sort;
- $conn->{lineend} = "\cM" if $sort eq 'ax25';
- dbg('connect', "started pid: $conn->{pid} as $line");
+ local $^F = 10000; # make sure it ain't closed on exec
+ my ($a, $b) = IO::Socket->socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC);
+ if ($a && $b) {
+ $r = 1;
+ $a->autoflush(1);
+ $b->autoflush(1);
+ my $pid = fork;
+ if (defined $pid) {
+ if ($pid) {
+ close $b;
+ $conn->{sock} = $a;
+ $conn->{csort} = $sort;
+ $conn->{lineend} = "\cM" if $sort eq 'ax25';
+ $conn->{pid} = $pid;
+ if ($conn->{rproc}) {
+ my $callback = sub {$conn->_rcv};
+ Msg::set_event_handler ($a, read => $callback);
+ }
+ dbg('connect', "started pid: $conn->{pid} as $line");
+ } else {
+ $^W = 0;
+ dbgclose();
+ STDIN->close;
+ STDOUT->close;
+ STDOUT->close;
+ *STDIN = IO::File->new_from_fd($b, 'r') or die;
+ *STDOUT = IO::File->new_from_fd($b, 'w') or die;
+ *STDERR = IO::File->new_from_fd($b, 'w') or die;
+ close $a;
+ unless ($^O =~ /^MS/) {
+# $SIG{HUP} = 'IGNORE';
+ $SIG{HUP} = $SIG{CHLD} = $SIG{TERM} = $SIG{INT} = 'DEFAULT';
+ alarm(0);
+ }
+ exec "$line" or dbg('err', "exec '$line' failed $!");
+ }
+ } else {
+ dbg('err', "cannot fork");
+ $r = undef;
+ }