POE/jobs-tasks/run2.pl

#!/usr/bin/perl

use warnings;
use strict;

use POE qw( Wheel::Run Filter::Line );

# Start the session.  Spawn a simple program, and describe the events
# it will generate as it does things.

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

    $heap->{child} = POE::Wheel::Run->new
      #( Program => [ "/bin/ls", "-1", "/" ],    # Program to run.
      ( Program => [ "dir", "-1", "/" ],    # Program to run.
      #( Program => [ "bin/ls.exe", "-1", "/" ],    # Program to run.
        Filter      => POE::Filter::Line->new(),    # Child speaks in lines.
        StdoutEvent => "got_child_stdout",          # Child wrote to STDOUT.
        StderrEvent => "got_child_stderr",          # Child wrote to STDERR.
        #CloseEvent  => "got_child_close",           # Child stopped writing.
      );
}

# Deal with information the child wrote to its STDOUT.

sub got_child_stdout {
    my $stdout = $_[ARG0];
    print "STDOUT: $stdout\n";
}

# Deal with information the child wrote to its STDERR.  These are
# warnings and possibly error messages.

sub got_child_stderr {
    my $stderr = $_[ARG0];
    $stderr =~ tr[ -~][]cd;
    print "STDERR: $stderr\n";
}

# The child has closed its output filehandles.  It will not be sending
# us any more information, so destroy it.

sub got_child_close {
    my $heap = $_[HEAP];
    print "child closed.\n";
    delete $heap->{child};
}

# A list of functions that will handle the events they're named after.

my @handlers =
  qw( _start got_child_stdout got_child_stderr got_child_close
);

# Start a session where each event is handled by a function with the
# same name.  Run POE's Kernel (and thus all its sessions) until done.

POE::Session->create( package_states => [ main => \@handlers ] );
$poe_kernel->run();

1	joko	1.1	#!/usr/bin/perl
2
3			use warnings;
4			use strict;
5
6			use POE qw( Wheel::Run Filter::Line );
7
8			# Start the session. Spawn a simple program, and describe the events
9			# it will generate as it does things.
10
11			sub _start {
12			my ( $kernel, $heap ) = @_[ KERNEL, HEAP ];
13
14			$heap->{child} = POE::Wheel::Run->new
15			#( Program => [ "/bin/ls", "-1", "/" ], # Program to run.
16			( Program => [ "dir", "-1", "/" ], # Program to run.
17			#( Program => [ "bin/ls.exe", "-1", "/" ], # Program to run.
18			Filter => POE::Filter::Line->new(), # Child speaks in lines.
19			StdoutEvent => "got_child_stdout", # Child wrote to STDOUT.
20			StderrEvent => "got_child_stderr", # Child wrote to STDERR.
21			#CloseEvent => "got_child_close", # Child stopped writing.
22			);
23			}
24
25			# Deal with information the child wrote to its STDOUT.
26
27			sub got_child_stdout {
28			my $stdout = $_[ARG0];
29			print "STDOUT: $stdout\n";
30			}
31
32			# Deal with information the child wrote to its STDERR. These are
33			# warnings and possibly error messages.
34
35			sub got_child_stderr {
36			my $stderr = $_[ARG0];
37			$stderr =~ tr[ -~][]cd;
38			print "STDERR: $stderr\n";
39			}
40
41			# The child has closed its output filehandles. It will not be sending
42			# us any more information, so destroy it.
43
44			sub got_child_close {
45			my $heap = $_[HEAP];
46			print "child closed.\n";
47			delete $heap->{child};
48			}
49
50			# A list of functions that will handle the events they're named after.
51
52			my @handlers =
53			qw( _start got_child_stdout got_child_stderr got_child_close
54			);
55
56			# Start a session where each event is handled by a function with the
57			# same name. Run POE's Kernel (and thus all its sessions) until done.
58
59			POE::Session->create( package_states => [ main => \@handlers ] );
60			$poe_kernel->run();
61
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26