Changeset bcde7926 for perl

Timestamp:

Jun 22, 2011, 12:37:21 AM (14 years ago)

Author:

David Benjamin <davidben@mit.edu>

Branches:

master, release-1.10, release-1.8, release-1.9

Children:

bbb7876

Parents:

074bdaa

git-author:

David Benjamin <davidben@mit.edu> (05/24/11 01:10:12)

git-committer:

David Benjamin <davidben@mit.edu> (06/22/11 00:37:21)

Message:

Reimplement BarnOwl::add_io_dispatch with AnyEvent

We can emulate the interesting semantics with perl. The one difference
is that perl code can now register an IO dispatch on file descriptors C
code was interested in. This isn't a big deal was Glib can handle
multiple watches on the same FD. Granted, more than one reader on an FD
would cause trouble, but there was nothing stopping perl code from
reading from an FD we cared about anyway.

AnyEvent also does not support select's exceptfd, so this is a slight
behavior change, but probably an uninteresting one.

File:

• perl/lib/BarnOwl.pm (modified) (5 diffs)

perl/lib/BarnOwl.pm

@@ -166 +166 @@
 read from C<FD>.
 
-C<add_dispatch> has been deprecated in favor of C<add_io_dispatch>,
-and is now a wrapper for it called with C<mode> set to C<'r'>.
+C<add_dispatch> has been deprecated in favor of C<AnyEvent>, and is
+now a wrapper for C<add_io_dispatch> called with C<mode> set to
+C<'r'>.
 
 =cut
@@ -181 +182 @@
 Remove a file descriptor previously registered via C<add_dispatch>
 
-C<remove_dispatch> has been deprecated in favor of
-C<remove_io_dispatch>.
+C<remove_dispatch> has been deprecated in favor of C<AnyEvent>.
 
 =cut
@@ -197 +197 @@
 registered, the old one is removed.
 
-=cut
+C<add_io_dispatch> has been deprecated in favor of C<AnyEvent>.
+
+=cut
+
+our %_io_dispatches;
 
 sub add_io_dispatch {
@@ -203 +207 @@
     my $modeStr = shift;
     my $cb = shift;
-    my $mode = 0;
-
-    $mode |= 0x1 if ($modeStr =~ /r/i); # Read
-    $mode |= 0x2 if ($modeStr =~ /w/i); # Write
-    if ($mode) {
-        $mode |= 0x4;                  # Exceptional
-        BarnOwl::Internal::add_io_dispatch($fd, $mode, $cb);
+    my @modes;
+
+    push @modes, 'r' if $modeStr =~ /r/i; # Read
+    push @modes, 'w' if $modeStr =~ /w/i; # Write
+    if (@modes) {
+        BarnOwl::remove_io_dispatch($fd);
+        for my $mode (@modes) {
+            push @{$_io_dispatches{$fd}}, AnyEvent->io(fh => $fd,
+                                                       poll => $mode,
+                                                       cb => $cb);
+        }
     } else {
         die("Invalid I/O Dispatch mode: $modeStr");
@@ -218 +226 @@
 
 Remove a file descriptor previously registered via C<add_io_dispatch>
+
+C<remove_io_dispatch> has been deprecated in favor of C<AnyEvent>.
+
+=cut
+
+sub remove_io_dispatch {
+    my $fd = shift;
+    undef $_ foreach @{$_io_dispatches{$fd}};
+    delete $_io_dispatches{$fd};
+}
 
 =head2 create_style NAME OBJECT