File Coverage

blib/lib/Event/RPC/Loop/AnyEvent.pm

Criterion	Covered	Total	%
statement	32	42	76.1
branch			n/a
condition			n/a
subroutine	10	12	83.3
pod	6	8	75.0
total	48	62	77.4

#-----------------------------------------------------------------------
# Copyright (C) 2002-2015 by Jörn Reder .
# All Rights Reserved. See file COPYRIGHT for details.
#
# This module is part of Event::RPC, which is free software; you can
# redistribute it and/or modify it under the same terms as Perl itself.
#-----------------------------------------------------------------------

package Event::RPC::Loop::AnyEvent;

use base qw( Event::RPC::Loop );

use strict;
use utf8;

use AnyEvent;

my %watchers;

sub get_loop_cv                 { shift->{loop_cv}                      }
sub set_loop_cv                 { shift->{loop_cv}              = $_[1] }

sub add_io_watcher {
    my $self = shift;
    my %par = @_;
    my ($fh, $cb, $desc, $poll) = @par{'fh','cb','desc','poll'};

    my $watcher = AnyEvent->io (
      fh   => $fh,
      poll => $poll,
      cb   => $cb,
    );

    $watchers{"$watcher"} = $watcher;

    return $watcher;
}

sub del_io_watcher {
    my $self = shift;
    my ($watcher) = @_;

    delete $watchers{"$watcher"};

    1;
}

sub add_timer {
    my $self = shift;
    my %par = @_;
    my  ($interval, $after, $cb, $desc) =
    @par{'interval','after','cb','desc'};

    my $timer = AnyEvent->timer (
        after       => $after,
        interval    => $interval,
        cb          => $cb,
    );

    $watchers{"$timer"} = $timer;

    return $timer;
}

sub del_timer {
    my $self = shift;
    my ($timer) = @_;

    delete $watchers{"$timer"};

    1;
}

sub enter {
    my $self = shift;

    my $loop_cv = AnyEvent->condvar;

    $self->set_loop_cv($loop_cv);

    $loop_cv->wait;

    1;
}

sub leave {
    my $self = shift;

    $self->get_loop_cv->send;

    1;
}

1;

__END__