File Coverage

blib/lib/Redis/Jet.pm

Criterion	Covered	Total	%
statement	48	50	96.0
branch	5	12	41.6
condition			n/a
subroutine	15	15	100.0
pod	1	3	33.3
total	69	80	86.2

package Redis::Jet;

use 5.010001;
use strict;
use warnings;
use POSIX qw(EINTR EAGAIN EWOULDBLOCK :sys_wait_h);
use IO::Socket qw(:crlf IPPROTO_TCP TCP_NODELAY);
use IO::Socket::INET;
use IO::Socket::UNIX;
use IO::Select;
use Time::HiRes qw/time/;
use base qw/Exporter/;

our @EXPORT_OK = qw/
                    parse_message parse_message_utf8
                /;

our $VERSION = "0.09";

use XSLoader;
XSLoader::load(__PACKAGE__, $VERSION);

sub new {
    my $class = shift;
    my %args = ref $_[0] ? %{$_[0]} : @_;
    %args = (
        server => '127.0.0.1:6379',
        connect_timeout => 5,
        io_timeout => 1,
        utf8 => 0,
        noreply => 0,
        reconnect_attempts => 0,
        reconnect_delay => 0.1,
        %args,
    );
    $class->_new(\%args);
}

sub set_socket {
    my ($self,$socket) = @_;
    $self->get_bucket->{socket} = $socket;
    $self->set_fileno(fileno($socket));
}

sub connect {
    my $self = shift;
    my $socket;
    if ($self->get_server =~ m!/!) {
        $socket = IO::Socket::UNIX->new(
            Peer => $self->get_server,
            Timeout => $self->get_connect_timeout,
        ) or return;
    } else {
        $socket = IO::Socket::INET->new(
            PeerAddr => $self->get_server,
            Timeout => $self->get_connect_timeout,
        ) or return;
        $socket->setsockopt(IPPROTO_TCP, TCP_NODELAY, 1)
            or die "setsockopt(TCP_NODELAY) failed:$!";
    }
    $socket->blocking(0) or die $!;
    $self->set_socket($socket);
    $socket;
}

sub DESTROY {
    $_[0]->_destroy();
}


1;
__END__