Tweaked to better test signals.

rcaputo · Aug 11, 1998 · 82e847a · 82e847a
1 parent 30290d8
commit 82e847a
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/samples/forkbomb.perl b/samples/forkbomb.perl
@@ -24,6 +24,7 @@ sub forkbomb {
        my ($k, $me, $from) = @_;
        $me->{'id'} = ++$forkbomber;
        print $me->{'id'}, ": starting...\n";
+       $k->sig('INT', 'signal handler');
        $k->post_state($me, 'fork');
      },
      '_stop' => sub
@@ -41,6 +42,11 @@ sub forkbomb {
        my ($k, $me, $new_parent) = @_;
        print $me->{'id'}, ": parent now is $new_parent ...\n";
      },
+     'signal handler' => sub 
+     {
+       my ($k, $me, $from, $signal) = @_;
+       print $me->{'id'}, ": caught SIG$signal\n";
+     },
      'fork' => sub
      {
        my ($k, $me, $from) = @_;

diff --git a/samples/selects.perl b/samples/selects.perl
@@ -12,6 +12,8 @@
 
 my $kernel = new POE::Kernel();
 
+my $chargen_port = 30020;
+
 #------------------------------------------------------------------------------
 # Chargen server.
 
@@ -21,8 +23,8 @@
    '_start' => sub
    {
      my ($k, $me, $from) = @_;
-     print "Starting chargen server on port 30019 ...\n";
-     my $listener = new IO::Socket::INET('LocalPort' => 30019,
+     print "Starting chargen server on port $chargen_port ...\n";
+     my $listener = new IO::Socket::INET('LocalPort' => $chargen_port,
                                          'Listen'    => 5,
                                          'Proto'     => 'tcp',
                                          'Reuse'     => 'yes',
@@ -32,7 +34,7 @@
        $k->select($listener, 'accept');
      }
      else {
-       warn "chargen service not started - listen on 30019 failed: $!";
+       warn "chargen service not started - listen on $chargen_port failed: $!";
      }
    },
    '_stop' => sub
@@ -134,7 +136,7 @@
      print "Starting chargen client ...\n";
      $me->{'lines read'} = 0;
      my $listener = new IO::Socket::INET('PeerHost' => 'localhost',
-                                         'PeerPort' => 30019,
+                                         'PeerPort' => $chargen_port,
                                          'Proto'    => 'tcp',
                                          'Reuse'    => 'yes',
                                         );
@@ -169,7 +171,7 @@
        print $buffer;
        $me->{'lines read'} += ($buffer =~ s/(\x0D\x0A)/$1/g);
        if ($me->{'lines read'} > 5) {
-         $k->select($handle, undef, undef, undef);
+         $k->select($handle);
        }
      }
    },