view release on metacpan or  search on metacpan

lib/AnyEvent/Worker.pm  view on Meta::CPAN

384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
sub _error {
        my ($self, $error, $filename, $line, $fatal) = @_;
        my $caller = '';
        my @caller = ($filename,$line);
        if ($fatal) {
                delete $self->{tw};
                delete $self->{rw};
                delete $self->{ww};
                delete $self->{fh};
                 
                # for fatal errors call all enqueued callbacks with error
                while (my $req = shift @{$self->{queue}}) {
                        @caller = ($req->[1],$req->[2]) unless $caller;
                        $caller ||= " after $req->[1] line $req->[2],";
                        local $@ = "$error at $req->[1] line $req->[2].\n";
                        $req->[0]->($self);
                }
                $self->kill_child;
        }
         
        local $@ = $error;