our $VERSION = '0.001043';
use Fcntl qw/LOCK_EX LOCK_UN SEEK_SET/;sub init {
my $self = shift;
$self->SUPER::init();
my $tail = $self->{+TAIL} or return;
return unless $self->exists;
my @lines = $self->poll_with_index;
if (@lines < $self->{+TAIL}) {
$self->seek(0);
}
else {
$self->seek($lines[0 - $tail]->[0]);
}
}
sub poll_with_index {
my $self = shift;
my %params = @_;
my $max = delete $params{max} || 0;
my $pos = $params{from};
$pos = $self->{+LINE_POS} ||= 0 unless defined $pos;
my @out;
while (!$max || @out < $max) {
my ($spos, $epos, $line) = $self->read_line(%params, from => $pos);
last unless defined($line) || defined($spos) || defined($epos);
$self->{+LINE_POS} = $epos unless $params{peek} || defined $params{from};
push @out => [$spos, $epos, $line];
$pos = $epos;
}
return @out;
}
sub read {
my $self = shift;
return $self->poll(from => 0);
}
sub poll {
my $self = shift;
my @lines = $self->poll_with_index(@_);
return map { $_->[-1] } @lines;
}
sub write {
my $self = shift;
my $name = $self->{+NAME};
my $fh = $self->open_file('>>');
flock($fh, LOCK_EX) or die "Could not lock file '$name': $!"
if $self->{+USE_WRITE_LOCK};
seek($fh,2,0);
print $fh $self->encode($_) for @_;
$fh->flush;
flock($fh, LOCK_UN) or die "Could not unlock file '$name': $!"
if $self->{+USE_WRITE_LOCK};
close($fh) or die "Could not clone file '$name': $!";
return @_;
}
sub seek {
my $self = shift;
my ($pos) = @_;
my $fh = $self->fh;
my $name = $self->{+NAME};
seek($fh, $pos, SEEK_SET) or die "Could not seek to position $pos in file '$name': $!";
$self->{+LINE_POS} = $pos;
}
1;