use strict;
use Test::More;
use Proclet;
use Parallel::Scoreboard;
use File::Temp qw/tempdir/;
my $sb = Parallel::Scoreboard->new(
base_dir => tempdir( CLEANUP => 1 )
);
my $logfile = File::Temp::tmpnam();
my $pid = fork();
die $! if ! defined $pid;
if ( $pid == 0 ) {
my $proclet = Proclet->new(
logger => sub {
my $log = shift;
open( my $fh, '>>:unix', $logfile );
print $fh $log;
close $fh;
},
);
$proclet->service(
code => sub {
warn 'sp2plet';
$sb->update("sp2plet");
sleep 6;
},
worker => 2
);
$proclet->service(
code => sub {
warn 'sp3plet';
$sb->update("sp3plet");
sleep 6;
},
worker => 3
);
$proclet->run;
exit;
}
sleep 2;
for (1..2) {
my $process = 0;
my $sleep2 = 0;
my $sleep3 = 0;
my $stats = $sb->read_all();
for my $pid (sort { $a <=> $b } keys %$stats) {
$process++;
$sleep3++ if $stats->{$pid} =~ m!sp3plet!;
$sleep2++ if $stats->{$pid} =~ m!sp2plet!;
}
is($process,5);
is($sleep2,2);
is($sleep3,3);
sleep 3;
}
kill 'TERM', $pid;
waitpid( $pid, 0);
open(my $fh, $logfile);
my $logok;
while( <$fh> ) {
$logok++ if $_ =~ m!^\d{2}:\d{2}:\d{2} \d\.\d[ ]+\| sp[23]plet!;
}
is($logok, 10);
unlink($logfile);
done_testing();