AnyEvent-ForkObject
view release on metacpan or search on metacpan
{
my $cv = condvar AnyEvent;
my $obj = new AnyEvent::ForkObject;
ok $obj, "Constructor";
my $phase = 0;
$obj->do(require => 'Data::Dumper', cb => sub {
$phase++;
diag explain \@_ unless ok $_[0] eq 'ok', 'require Data::Dumper';
$obj->do(
module => 'Data::Dumper',
args => [ [ 1, 2, 3 ]],
cb => sub {
my ($s, $o) = @_;
diag explain \@_ unless ok $s eq 'ok', 'Data::Dumper created';
$phase++;
$o->Indent(0, sub { ok $_[0] eq 'ok', 'dumper->Indent(0)' });
$o->Terse(1, sub { ok $_[0] eq 'ok', 'dumper->Terse(1)' });
$o->Useqq(1, sub { ok $_[0] eq 'ok', 'dumper->Useqq(1)' });
$o->Deepcopy(1,
sub { ok $_[0] eq 'ok', 'dumper->Deepcopy(1)' }
);
$o->Dump(sub {
ok $timeout, "Timeout wasn't reached";
}
{
my $cv = condvar AnyEvent;
my $obj = new AnyEvent::ForkObject;
ok $obj, "Constructor";
$obj->do(require => 'Data::Dumper', cb => sub {
diag explain \@_ unless ok $_[0] eq 'ok', 'require Data::Dumper';
$obj->do(
module => 'Data::Dumper',
args => [ [ 1, 2, 3 ]],
cb => sub {
my ($s, $o) = @_;
ok $s eq 'ok', 'Data::Dumper created';
undef $obj;
$o->Dump(0, sub {
my ($st, $ob) = @_;
ok $st eq 'fatal', 'Object has been destroyed';
ok $ob =~ /destroyed/, 'Fatal message is right';
});
});
{
my $cv = condvar AnyEvent;
my $obj = new AnyEvent::ForkObject;
my $obj2 = new AnyEvent::ForkObject;
ok $obj, "Constructor";
kill KILL => $obj->{pid};
waitpid $obj->{pid}, 0;
$obj->do(require => 'Data::Dumper', cb => sub {
diag explain \@_ unless ok $_[0] eq 'fatal', 'Child was killed';
my $t;
$t = AE::timer 0.3, 0 => sub {
undef $t;
$cv->send;
}
});
my $dont_call_if_destroyed = 1;
$obj2->do(require => 'Data::Dumper', cb => sub {
diag explain \@_;
$dont_call_if_destroyed = 0;
});
kill KILL => $obj2->{pid};
undef $obj2;
my $timeout; $timeout = AE::timer 1, 0 => sub { undef $timeout; $cv->send };
$cv->recv;
( run in 0.556 second using v1.01-cache-2.11-cpan-a5abf4f5562 )