1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
use Test::More;
use POSIX ":sys_wait_h";
my $es = do "es_sync.pl" or die( $@ || $! );
my $cxn_class = ref $es->transport->cxn_pool->cxns->[0];
ok $es->info, "$cxn_class - Info before fork";
my $Kids = 4;
my %pids;
for my $child ( 1 .. $Kids ) {
my $pid = fork();
if ($pid) {
$pids{$pid} = $child;
next;
}
if ( !defined $pid ) {
skip "fork() not supported";
done_testing;
last;
}
for ( 1 .. 100 ) {
$es->info;
}
exit;
}
my $ok = 0;
for ( 1 .. 10 ) {
my $pid = waitpid( -1, WNOHANG );
if ( $pid > 0 ) {
delete $pids{$pid};
$ok++ unless $?;
redo;
}
last unless keys %pids;
sleep 1;
}
is $ok, $Kids, "$cxn_class - Fork";
done_testing;
|
