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	#!/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