File Coverage

blib/lib/Data/Log/Shared.pm

Criterion	Covered	Total	%
statement	17	17	100.0
branch	6	8	75.0
condition	2	2	100.0
subroutine	3	3	100.0
pod	0	1	0.0
total	28	31	90.3

package Data::Log::Shared;
use strict;
use warnings;
our $VERSION = '0.04';
require XSLoader;
XSLoader::load('Data::Log::Shared', $VERSION);

sub each_entry {
    my ($self, $cb, $from, $abandon_wait_us) = @_;
    $from //= 0;
    my $trunc = $self->truncation;
    $from = $trunc if $from < $trunc;
    my @wait = defined $abandon_wait_us ? ($abandon_wait_us) : ();
    while (1) {
        my ($data, $next) = $self->read_entry($from, @wait);
        last unless defined $next;            # end of log / uncommitted in-flight
        $cb->($data, $from) if defined $data; # skip abandoned slots silently
        $from = $next;
    }
    return $from;
}

1;
__END__