File Coverage

blib/lib/Inferno/RegMgr/Lookup.pm

Criterion	Covered	Total	%
statement	24	44	54.5
branch	0	4	0.0
condition			n/a
subroutine	8	14	57.1
pod	1	4	25.0
total	33	66	50.0

package Inferno::RegMgr::Lookup;

use warnings;
use strict;
use Carp;

# update POD & Changes & README
use version; our $VERSION = qv('0.1.0');

# update DEPENDENCIES in POD & Makefile.PL & README
use Scalar::Util qw( weaken );
use EV;
use Inferno::RegMgr::Utils qw( run_callback );


use constant RETRY => 1;    # sec, delay between re-connections


sub new {
    my ($class, $opt) = @_;
    my $self = {
        attr    => $opt->{attr},
        cb      => $opt->{cb},
        method  => $opt->{method},
        manager => undef,
        io      => undef,
        t       => undef,
    };
    return bless $self, $class;
}

sub START {
    my ($self) = @_;
    $self->{io} = $self->{manager}{registry}->open_find({
        attr    => $self->{attr},
        cb      => $self,
        method  => '_cb_find',
    });
    weaken( $self->{io} );
    return;
}

sub _cb_find { ## no critic(ProhibitUnusedPrivateSubroutines)
    my ($self, $svc, $err) = @_;
    if ($svc) {
        $self->{manager}->detach( $self );
        run_callback( $self->{cb}, $self->{method}, $svc );
    }
    else {
        $self->{t} = EV::timer RETRY, 0, sub { $self->START() };
    }
    return;
}

sub STOP {
    my ($self) = @_;
    if (defined $self->{io}) {
        $self->{io}->close();
    }
    $self->{t} = undef;
    return;
}

sub REFRESH {}


1; # Magic true value required at end of module
__END__