File Coverage

blib/lib/Data/RingBuffer/Time.pm

Criterion	Covered	Total	%
statement	35	35	100.0
branch	8	8	100.0
condition			n/a
subroutine	11	11	100.0
pod	4	4	100.0
total	58	58	100.0

#!/usr/bin/perl
#made by: KorG
# vim: sw=4 ts=4 et cc=79 :

package Data::RingBuffer::Time;

use 5.008;
use strict;
use warnings FATAL => 'all';
use Carp;
use Data::RingBuffer;

our $VERSION = '0.02';
$VERSION =~ tr/_//d;

BEGIN { our @ISA = 'Data::RingBuffer' };

# Add an element to the buffer
# args: $obj
sub push {
    $_[0]->[0]->push(time);
    $_[0]->[1]->push($_[1]);
    return $_[1];
}

# (internal) find index of first element with time
sub _find_index {
    my $idx = 0;
    my $buf = $_[0]->[0]->{buf};
    while ($idx <= $#$buf) {
        return $idx if $buf->[$idx] > $_[1];
        $idx++;
    }

    return undef;
}

# Get all elements in the buffer
# args: (optional) time
sub getall {
    if (defined $_[1]) {
        croak "Time must be positive" unless $_[1] >= 0;
        my $idx = $_[0]->_find_index($_[1]);
        return [] unless defined $idx;
        my $buf = $_[0]->[1]->{buf};
        return [@{$buf}[$idx .. $#$buf]];
    }
    return $_[0]->[1]->getall();
}

# Get next element from the buffer
sub get {
    $_[0]->[0]->get(); # handle tail movement
    $_[0]->[1]->get();
}

# OO ctor
# args: $size
sub new {
    bless [
        Data::RingBuffer->new($_[1]), # time storage
        Data::RingBuffer->new($_[1]), # obj storage
    ], $_[0];
}

1; # End of Data::RingBuffer::Time

__END__