hi gurus, ; )
I have taken an example from the cookbook and modified it, that it
handles the childs after a certain timout. they shall get killed and the
kernel shall end.
I still have problems that the kernel never returns. I have read alot of
urls friendly people pointed me to in #poe, but still are questions open.
runninf the script with sub POE::Kernel::TRACE_REFCNT () { 1 }, shows me
int the end 1 open event and 5 Files.
I think the event is the sighandler I set up and the files are the
Filter::References(?).
as I'm not able to find out, how to address the left events and files to
dereference, this as my question here:
how do I get rid of the balast the kernel still is carriyng around?
the code comes here:
#!/usr/bin/perl -w
$|=1; #unbuffered input
use strict;
use warnings;
#sub POE::Kernel::TRACE_REFCNT () { 1 }
use POE qw(Wheel::Run Filter::Reference);
our %alarms;
my @tasks = ("1_1","2_2","3_3","4_2","5_1");
my $count = scalar @tasks;
print "we have $count tasks to do\n";
sub MAX_CONCURRENT_TASKS () { $count }
# variables and stuff done here
POE::Session->create
( inline_states =>
{ _start => \&start_tasks,
next_task => \&start_tasks,
task_result => \&handle_task_result,
task_done => \&handle_task_done,
task_debug => \&handle_task_debug,
task_kill => \&handle_task_done,
}
);
sub start_tasks {
my $heap = $_[HEAP];
$poe_kernel->sig(CHLD => 'reaper');
while ( keys( %{ $heap->{task} } ) < MAX_CONCURRENT_TASKS ) {
my $next_task = shift @tasks;
last unless defined $next_task;
my @task_args = split(/_/, $next_task);
my $task = POE::Wheel::Run->new
( Program => sub { do_stuff($task_args[0], $task_args[1]) },
StdoutFilter => POE::Filter::Reference->new(),
StdoutEvent => "task_result",
StderrEvent => "task_debug",
CloseEvent => "task_done",
);
print "wheel $task is running with: name \"$task_args[0]\" and
param \"$task_args[1]\"\n";
my $timeout = 2;
my $delay_id = $poe_kernel->delay_set("task_kill",$timeout,$task);
$alarms{$task} = $delay_id ;
$heap->{task}->{ $task->ID } = $task;
}
}
sub reaper {
my ($self, $kernel, $heap) = @_[OBJECT, KERNEL, HEAP];
if ($heap->{task}->ID ) {
print STDERR "child has died prematurely\n";
} else {
print STDERR "child has completed when the counter ran out\n";
}
#($self->{task}->ID) = undef;
$kernel->sig_handled;
}
sub regx{
#do sumthing
my $result = shift;
return("done");
}
sub do_stuff {
my $name = shift;
my $param = shift;
my $filter = POE::Filter::Reference->new();
# some dummy action here
my $ergebnis = regx($name);
my %result =
( task => $name,
status => "$ergebnis"
);
my $output = $filter->put( [ \%result ] );
print @$output;
}
sub handle_task_result {
my $result = $_[ARG0];
print "$result->{task} returned: $result->{status}\n";
}
sub handle_task_debug {
my $result = $_[ARG0];
print "Debug: $result\n";
}
sub handle_task_done {
my ( $kernel, $heap, $task_id ) = @_[ KERNEL, HEAP, ARG0 ];
delete $heap->{task}->{$task_id};
}
sub handle_task_kill {
my ( $kernel, $heap, $task_id ) = @_[ KERNEL, HEAP, ARG0 ];
$kernel->refcount_decrement( $heap->{task}->{$task_id} );
$task_id->kill();
delete $heap->{task}->{$task_id};
my $delay_id = $alarms{$task_id};
$kernel->alarm_remove($delay_id);
}
$poe_kernel->run();
print STDERR "kernel now finished. we can continue with sumthin else\n";
exit 0;
regards,
phai
--
better burn out than fade away ..
