File Coverage

blib/lib/Cassandra/Client/Policy/Queue/Default.pm

Criterion	Covered	Total	%
statement	8	24	33.3
branch	0	2	0.0
condition	0	5	0.0
subroutine	3	6	50.0
pod	0	3	0.0
total	11	40	27.5

package Cassandra::Client::Policy::Queue::Default;
our $AUTHORITY = 'cpan:TVDW';
$Cassandra::Client::Policy::Queue::Default::VERSION = '0.21';
use 5.010;
use strict;
use warnings;

sub new {
    my ($class, %args)= @_;

    my $max_entries= $args{max_entries} || 0; # Default: never overflow

    return bless {
        max_entries => 0+ $max_entries,
        has_any     => 0, # We're using this as a count.
        queue       => [],
    }, $class;
}

sub enqueue {
    my ($self, $item)= @_;

    if ($self->{max_entries} && $self->{has_any} >= $self->{max_entries}) {
        return "command queue full: $self->{has_any} entries";
    }

    push @{$self->{queue}}, $item;
    $self->{has_any}++;
    return;
}

sub dequeue {
    my ($self)= @_;
    my $item= shift @{$self->{queue}};
    $self->{has_any}= 0+@{$self->{queue}};
    return $item;
}

1;

__END__