#
# Use Event for the IO::Event event handler
#
my $debug = $IO::Event::debug;
my $edebug = $IO::Event::edebug;
my $sdebug = $IO::Event::sdebug;
package IO::Event::Event;
require IO::Event;
use strict;
use warnings;
our @ISA = qw(IO::Event::Common);
sub import
{
require IO::Event;
IO::Event->import('no_emulate_Event');
}
sub new
{
my ($pkg, @stuff) = @_;
require Event;
require Event::Watcher;
$pkg->SUPER::new(@stuff);
}
sub loop
{
require Event;
Event::loop(@_);
}
sub unloop_all
{
require Event;
Event::unloop_all(@_);
}
sub timer
{
require Event;
shift;
Event->timer(@_);
}
sub idle
{
require Event;
shift;
Event->idle(@_);
}
sub set_write_polling
{
my ($self, $new) = @_;
my $event = ${*$self}{ie_event};
if ($new) {
$event->poll($event->poll | Event::Watcher::W());
} else {
$event->poll($event->poll & ~Event::Watcher::W());
}
}
sub set_read_polling
{
my ($self, $new) = @_;
my $event = ${*$self}{ie_event};
if ($new) {
$event->poll($event->poll | Event::Watcher::R());
} else {
if ($event) {
$event->poll($event->poll & ~Event::Watcher::R());
}
}
}
sub ie_register
{
my ($self) = @_;
my ($fh, $fileno) = $self->SUPER::ie_register();
my $R = ${*$self}{ie_readclosed}
? 0
: Event::Watcher::R();
${*$self}{ie_want_read_events} = ! ${*$self}{ie_readclosed};
${*$self}{ie_want_write_events} = '';
${*$self}{ie_event} = Event->io(
fd => $fileno,
poll => Event::Watcher::E()|Event::Watcher::T()|$R,
cb => [ $self, 'ie_dispatch' ],
desc => ${*$self}{ie_desc},
edebug => $edebug,
);
print STDERR "registered ${*$self}{ie_fileno}:${*$self}{ie_desc} $self $fh ${*$self}{ie_event}\n"
if $debug;
}
sub ie_deregister
{
my ($self) = @_;
$self->SUPER::ie_deregister();
${*$self}{ie_event}->cancel
if ${*$self}{ie_event};
delete ${*$self}{ie_event};
}
1;