File Coverage

blib/lib/Memcached/Client/Selector/Traditional.pm

Criterion	Covered	Total	%
statement	44	47	93.6
branch	13	18	72.2
condition	1	2	50.0
subroutine	8	8	100.0
pod	2	2	100.0
total	68	77	88.3

package Memcached::Client::Selector::Traditional;
BEGIN {
  $Memcached::Client::Selector::Traditional::VERSION = '2.01';
}
#ABSTRACT: Implements Traditional Memcached Hashing

use strict;
use warnings;
use Memcached::Client::Log qw{DEBUG};
use String::CRC32 qw{crc32};
use base qw{Memcached::Client::Selector};


sub set_servers {
    my ($self, $list) = @_;
    $self->log ("list: %s", $list) if DEBUG;
    if ($list) {
        my $count = scalar @{$list};
        if (1 < $count) {
            $self->{buckets} = [];
            for my $server (@{$list}) {
                if (ref $server eq "ARRAY") {
                    for (1..$server->[1]) {
                        push @{$self->{buckets}}, $server->[0];
                    }
                } else {
                    push @{$self->{buckets}}, $server;
                }
            }
            $self->{bucketcount} = scalar @{$self->{buckets}};
            $self->log ("bucket count: %d\nbucket list: %s", $self->{bucketcount}, $self->{buckets}) if DEBUG;
        } elsif (1 == $count) {
            $self->{_single_sock} = ref $list->[0] ? $list->[0]->[0] : $list->[0];
        }
    } else {
        delete $self->{buckets};
        delete $self->{bucket_count};
        delete $self->{_single_sock};
    }

    1;
}

sub get_server {
    my ($self, $key, $namespace) = @_;
    return unless $key;
    return $self->{_single_sock} if $self->{_single_sock};
    return unless $self->{buckets};
    $namespace ||= "";
    my $hash = ref $key ? int ($key->[0]) : crc32 ($namespace . $key) >> 16 & 0x7fff;
    $self->log ("Hash is %d, bucket # %d, bucket %s", $hash, $hash % $self->{bucketcount}, $self->{buckets}->[$hash % $self->{bucketcount}]) if DEBUG;
    return $self->{buckets}->[$hash % $self->{bucketcount}];
}

1;

__END__