Changeset 8764 for lang/perl/Parallel-Prefork

Timestamp:

04/03/08 17:03:42 (5 years ago)

Author:

kazuho

Message:

add received_signal function

Location:

lang/perl/Parallel-Prefork/trunk

Files:

• lib/Parallel/Prefork.pm (modified) (2 diffs)
• t/01-base.t (modified) (1 diff)

lang/perl/Parallel-Prefork/trunk/lib/Parallel/Prefork.pm

@@ -5 +5 @@
 
 use base qw/Class::Accessor::Fast/;
+use List::Util qw/first/;
 use Proc::Wait3;
 
@@ -79 +80 @@
 }
 
+sub received_signal {
+    my ($self, @signames) = @_;
+    foreach my $rs (@{$self->signals_received}) {
+        return 1 if first { $_ eq $rs } @signames;
+    }
+    undef;
+}
+
 1;
 

lang/perl/Parallel-Prefork/trunk/t/01-base.t

@@ -27 +27 @@
 my $c;
 
-while (! @{$pm->signals_received}) {
+until ($pm->received_signal('TERM')) {
     $pm->start and next;
     open $fh, '+<', $filename