use vars qw($VERSION $BRANCH);
$VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
-$BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/ ) || 0;
+$BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/ || (0,0));
$main::build += $VERSION;
$main::branch += $BRANCH;
BEGIN {
# Checks if blocking is supported
eval {
+ local $^W;
require POSIX; POSIX->import(qw(O_NONBLOCK F_SETFL F_GETFL))
};
if ($@ || $main::is_win) {
# import as many of these errno values as are available
eval {
+ local $^W;
require Errno; Errno->import(qw(EAGAIN EINPROGRESS EWOULDBLOCK));
};
unless ($^O eq 'MSWin32') {
if ($] >= 5.6) {
eval {
+ local $^W;
require Socket; Socket->import(qw(IPPROTO_TCP TCP_NODELAY));
};
} else {
}
sub event_loop {
- my ($pkg, $loop_count, $timeout) = @_; # event_loop(1) to process events once
+ my ($pkg, $loop_count, $timeout, $wronly) = @_; # event_loop(1) to process events once
my ($conn, $r, $w, $e, $rset, $wset, $eset);
while (1) {
# Quit the loop if no handles left to process
- last unless ($rd_handles->count() || $wt_handles->count());
+ if ($wronly) {
+ last unless $wt_handles->count();
- ($rset, $wset, $eset) = IO::Select->select($rd_handles, $wt_handles, $er_handles, $timeout);
-
- foreach $e (@$eset) {
- &{$er_callbacks{$e}}($e) if exists $er_callbacks{$e};
- }
- foreach $r (@$rset) {
- &{$rd_callbacks{$r}}($r) if exists $rd_callbacks{$r};
- }
- foreach $w (@$wset) {
- &{$wt_callbacks{$w}}($w) if exists $wt_callbacks{$w};
- }
+ ($rset, $wset, $eset) = IO::Select->select(undef, $wt_handles, undef, $timeout);
+
+ foreach $w (@$wset) {
+ &{$wt_callbacks{$w}}($w) if exists $wt_callbacks{$w};
+ }
+ } else {
+
+ last unless ($rd_handles->count() || $wt_handles->count());
+
+ ($rset, $wset, $eset) = IO::Select->select($rd_handles, $wt_handles, $er_handles, $timeout);
+
+ foreach $e (@$eset) {
+ &{$er_callbacks{$e}}($e) if exists $er_callbacks{$e};
+ }
+ foreach $r (@$rset) {
+ &{$rd_callbacks{$r}}($r) if exists $rd_callbacks{$r};
+ }
+ foreach $w (@$wset) {
+ &{$wt_callbacks{$w}}($w) if exists $wt_callbacks{$w};
+ }
+ }
Timer::handler;