Without commenting on the design of this, it does seem like you have a
typo in your start_tasks sub:
my $delay_id = $poe_kernel->delay_set("task_kill",$timeout,$task);
should be:
my $delay_id = $poe_kernel->delay_set("task_kill",$timeout,$task->ID);
After the change it seems to start working. I think you were catching
the wrong thing on your ARG0 in the task_kill handler. See?
> On 6/7/05, phaidros <[EMAIL PROTECTED]> wrote:
> > 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 ..
> >
>
