File Coverage

blib/lib/IO/AIO/LoadLimited.pm

Criterion	Covered	Total	%
statement	32	33	96.9
branch	9	12	75.0
condition			n/a
subroutine	6	6	100.0
pod	1	1	100.0
total	48	52	92.3

package IO::AIO::LoadLimited;

use common::sense;
use base qw(Exporter);
use Carp qw(croak);

# IO:AIO Version 2 supports groups and requests objects
use IO::AIO 2;

our @EXPORT  = qw(aio_load_limited);
our $VERSION = '0.02';

sub aio_load_limited(\@&$;$) {
    my ($paths, $filecb, $grp_or_donecb, $limit) = @_;
    my $group;

    $limit = 10 unless defined $limit;

    if (ref($grp_or_donecb) eq 'CODE') {
        $group = aio_group $grp_or_donecb;
    } elsif (ref($grp_or_donecb) eq 'IO::AIO::GRP') {
        $group = $grp_or_donecb;
    } else {
        croak '3rd parameter must be a callback or IO::AIO::GRP';
    }

    limit $group $limit;
    feed $group sub {
        my $data;
        my $path = shift @$paths or return $group->result(1);
        my $pri  = aioreq_pri;
        my $grp  = aio_group sub { $filecb->( $_[0] >= 0 ? ($path, $data) : ($path, undef) )};
        add $group $grp;

        aioreq_pri $pri;
        add $grp aio_open $path, IO::AIO::O_RDONLY, 0, sub {
            my $fh = shift or return $grp->result(-1);
            aioreq_pri $pri;
            add $grp aio_read $fh, 0, (-s $fh), $data, 0, sub { $grp->result($_[0]) };
        };
    };
};

1;

__END__