aDriv4 website!

Linux web1060.sh.fuk1 4.18.0-425.19.2.lve.el7h.x86_64 #1 SMP Thu Apr 6 13:40:55 UTC 2023 x86_64
Apache
127.0.0.1

File Name : k_signals.pm

#!/usr/bin/perl -w
# vim: ts=2 sw=2 expandtab

# Tests various signals using POE's stock signal handlers.  These are
# plain Perl signals, so mileage may vary.

use strict;
use lib qw(./mylib ../mylib);

use Test::More;

sub POE::Kernel::ASSERT_DEFAULT () { 1 }

BEGIN {
  package POE::Kernel;
{
  $POE::Kernel::VERSION = '1.352';
}
  use constant TRACE_DEFAULT => exists($INC{'Devel/Cover.pm'});
}

BEGIN {
  # We can't "plan skip_all" because that calls exit().  And Tk will
  # croak if you call BEGIN { exit() }.  And that croak will cause
  # this test to FAIL instead of skip.

my $error;
  if ($^O eq "MSWin32" and not $ENV{POE_DANTIC}) {
    $error = "$^O does not support signals";
  }
  elsif ($^O eq "MacOS" and not $ENV{POE_DANTIC}) {
    $error = "$^O does not support fork";
  }

if ($error) {
    print "1..0 # Skip $error\n";
    CORE::exit();
  }

plan tests => 8;
}

BEGIN { use_ok("POE") }

# This is the number of processes to fork.  Increase this number if
# your system can handle the resource use.  Also try increasing it if
# you suspect a problem with POE's SIGCHLD handling.  Be warned
# though: setting this too high can cause timing problems and test
# failures on some systems.

my $fork_count = 8;

# Set up a signal catching session.  This test uses plain fork(2) and
# POE's $SIG{CHLD} handler.

POE::Session->create(
  inline_states => {
    _start => sub {
      my ($kernel, $heap) = @_[KERNEL, HEAP];

# Clear the status counters, and catch SIGCHLD.

$heap->{forked} = $heap->{reaped} = 0;
      $kernel->sig( CHLD => 'catch_sigchld' );

# Fork some child processes, all to exit at the same time.

my $fork_start_time = time();

for (my $child = 0; $child < $fork_count; $child++) {
        my $child_pid = fork;

if (defined $child_pid) {
          if ($child_pid) {
            # Parent side keeps track of child IDs.
            $heap->{forked}++;
            $heap->{children}->{$child_pid} = 1;
          }
          else {
            # Child side sleeps. With the fishes.
            $SIG{INT} = 'DEFAULT';
            sleep 3600;
            exit;
          }
        }
        else {
          die "fork error: $!";
        }
      }

ok(
        $heap->{forked} == $fork_count,
        "forked $heap->{forked} processes (out of $fork_count)"
      );

# Wait a factor of the fork time for things to settle down.
      # This prevents false negatives on slower systems.

my $fork_delay = time() - $fork_start_time;

if ($fork_delay < 2) {
        $fork_delay = 2;
      }
      elsif ($fork_delay < 5) {
        $fork_delay = 5;
      }
      else {
        $fork_delay = 10;
      }

$kernel->delay( forking_time_is_up => $fork_delay );
      diag("Waiting $fork_delay seconds for child processes to settle.");
    },

_stop => sub {
      my $heap = $_[HEAP];

# Everything is done.  See whether it succeeded.
      ok(
        $heap->{reaped} == $heap->{forked},
        "reaped $heap->{reaped} processes (out of $heap->{forked})"
      );
    },

catch_sigchld => sub {
      my ($kernel, $heap) = @_[KERNEL, HEAP];

# Count the child reap.
      $heap->{reaped}++;

# Refresh the fork timeout.
      $kernel->delay(
        reaping_time_is_up => 2 * ($heap->{forked} - $heap->{reaped} + 1)
      );
    },

forking_time_is_up => sub {
      my ($kernel, $heap) = @_[KERNEL, HEAP];

# Forking time is over.  We kill all the child processes as
      # immediately as possible.

my $kill_count = kill INT => keys(%{$heap->{children}});
      ok(
        $kill_count == $heap->{forked},
        "killed $kill_count processes (out of $heap->{forked})"
      );

# Start the reap timer.  This will tell us how long to wait
      # between CHLD signals.

$heap->{reap_start} = time();

# Wait a factor of the number of child processes, plus one, for
      # reaped children.  The extra time is to ensure we don't reap
      # more processes than we started with.

$kernel->delay(
        reaping_time_is_up => 2 * ($heap->{forked} - $heap->{reaped} + 1)
      );
    },

# Do nothing here.  The timer exists just to keep the session
    # alive.  Once it's dispatched, the session can exit.
    reaping_time_is_up => sub {
      $_[KERNEL]->sig( CHLD => undef );
    },
  },
);

# mstevens found a subtle incompatibility between nested sessions and
# SIGIDLE.  This should be fun to debug, but first I'll add the test
# case here.

sub spawn_server {
  POE::Session->create(
    inline_states => {
      _start => sub {
        $_[KERNEL]->alias_set("server");
      },
      do_thing => sub {
        $_[KERNEL]->post($_[SENDER], thing_done => $_[ARG0]);
      },
      _child  => sub { 0 },
      _stop   => sub { 0 },
    },
  );
}

POE::Session->create(
  inline_states => {
    _start => sub {
      spawn_server();
      $_[KERNEL]->post(server => do_thing => 1);
    },
    thing_done => sub { 0 },
    _child  => sub { 0 },
    _stop   => sub { 0 },
  },
);

# See how SIGPIPE gets handled.

POE::Session->create(
  inline_states => {
    _start => sub {
      $_[KERNEL]->sig(USR1 => "got_usr1");
      $_[KERNEL]->sig(PIPE => "got_pipe");
      $_[KERNEL]->yield("send_signals");
    },
    send_signals => sub {
      ok(kill("USR1", $$) == 1, "sent self SIGUSR1");
      ok(kill("PIPE", $$) == 1, "sent self SIGPIPE");
      $_[KERNEL]->delay(wait_for_signals => 1);
    },
    got_usr1 => sub {
      $_[HEAP]->{usr1}++;
    },
    got_pipe => sub {
      $_[HEAP]->{pipe}++;
    },
    wait_for_signals => sub {
      $_[KERNEL]->sig( USR1 => undef );
      $_[KERNEL]->sig( PIPE => undef );
    },
    _stop => sub {
      ok($_[HEAP]->{usr1} == 1, "caught SIGUSR1");
      ok($_[HEAP]->{pipe} == 1, "caught SIGPIPE");
    },
  },
);

# Run the tests.

POE::Kernel->run();

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2023-08-25 11:53:03
..	dir	-	root/root	0755	2023-08-25 11:53:03
00_info.pm	text/x-perl	791 B	root/root	0644	2013-08-20 05:18:53
all_errors.pm	text/x-perl	10.04 KB	root/root	0644	2013-08-20 05:18:53
comp_tcp.pm	text/x-perl	7.21 KB	root/root	0644	2013-08-20 05:18:53
comp_tcp_concurrent.pm	text/x-perl	8.32 KB	root/root	0644	2013-08-20 05:18:53
connect_errors.pm	text/x-perl	2.3 KB	root/root	0644	2013-08-20 05:18:53
k_alarms.pm	text/x-perl	14.43 KB	root/root	0644	2013-08-20 05:18:53
k_aliases.pm	text/x-perl	3.67 KB	root/root	0644	2013-08-20 05:18:53
k_detach.pm	text/x-perl	7.58 KB	root/root	0644	2013-08-20 05:18:53
k_run_returns.pm	text/x-perl	588 B	root/root	0644	2013-08-20 05:18:53
k_selects.pm	text/x-perl	6.62 KB	root/root	0644	2013-08-20 05:18:53
k_sig_child.pm	text/x-perl	5.53 KB	root/root	0644	2013-08-20 05:18:53
k_signals.pm	text/x-perl	5.74 KB	root/root	0644	2013-08-20 05:18:53
k_signals_rerun.pm	text/plain	3.21 KB	root/root	0644	2013-08-20 05:18:53
sbk_signal_init.pm	text/x-perl	936 B	root/root	0644	2013-08-20 05:18:53
ses_nfa.pm	text/x-perl	8.92 KB	root/root	0644	2013-08-20 05:18:53
ses_session.pm	text/x-perl	17.48 KB	root/root	0644	2013-08-20 05:18:53
wheel_accept.pm	text/x-perl	2.91 KB	root/root	0644	2013-08-20 05:18:53
wheel_curses.pm	text/x-perl	2.76 KB	root/root	0644	2013-08-20 05:18:53
wheel_readline.pm	text/x-perl	10.55 KB	root/root	0644	2013-08-20 05:18:53
wheel_readwrite.pm	text/x-perl	12.26 KB	root/root	0644	2013-08-20 05:18:53
wheel_run.pm	text/x-perl	18.05 KB	root/root	0644	2013-08-20 05:18:53
wheel_run_size.pm	text/x-perl	2.15 KB	root/root	0644	2013-08-20 05:18:53
wheel_sf_ipv6.pm	text/x-perl	5.21 KB	root/root	0644	2013-08-20 05:18:53
wheel_sf_tcp.pm	text/x-perl	5.22 KB	root/root	0644	2013-08-20 05:18:53
wheel_sf_udp.pm	text/x-perl	6.2 KB	root/root	0644	2013-08-20 05:18:53
wheel_sf_unix.pm	text/x-perl	6.7 KB	root/root	0644	2013-08-20 05:18:53
wheel_tail.pm	text/x-perl	8.75 KB	root/root	0644	2013-08-20 05:18:53
z_kogman_sig_order.pm	text/plain	10.72 KB	root/root	0644	2013-08-20 05:18:53
z_leolo_wheel_run.pm	text/x-perl	3.41 KB	root/root	0644	2013-08-20 05:18:53
z_merijn_sigchld_system.pm	text/x-perl	2.73 KB	root/root	0644	2013-08-20 05:18:53
z_rt39872_sigchld.pm	text/x-perl	4.09 KB	root/root	0644	2013-08-20 05:18:53
z_rt39872_sigchld_stop.pm	text/x-perl	3.42 KB	root/root	0644	2013-08-20 05:18:53
z_rt53302_fh_watchers.pm	text/x-perl	2.95 KB	root/root	0644	2013-08-20 05:18:53
z_rt54319_bazerka_followtail.pm	text/x-perl	1.38 KB	root/root	0644	2013-08-20 05:18:53
z_steinert_signal_integrity.pm	text/x-perl	1.42 KB	root/root	0644	2013-08-20 05:18:53

For more Private tool come to me!

https://t.me/aDriv4vz