--- IO-AIO/AIO.pm 2005/07/10 22:19:48 1.6 +++ IO-AIO/AIO.pm 2005/07/11 00:51:32 1.11 @@ -14,12 +14,12 @@ aio_unlink "/tmp/file", sub { }; aio_read $fh, 30000, 1024, $buffer, 0, sub { - $_[0] >= 0 or die "read error: $!"; + $_[0] > 0 or die "read error: $!"; }; # Event Event->io (fd => IO::AIO::poll_fileno, - poll => 'r', async => 1, + poll => 'r', cb => \&IO::AIO::poll_cb); # Glib/Gtk2 @@ -30,6 +30,11 @@ Tk::Event::IO->fileevent (IO::AIO::poll_fileno, "", readable => \&IO::AIO::poll_cb); + # Danga::Socket + Danga::Socket->AddOtherFds (IO::AIO::poll_fileno => + \&IO::AIO::poll_cb); + + =head1 DESCRIPTION This module implements asynchronous I/O using whatever means your @@ -56,7 +61,7 @@ use Fcntl (); BEGIN { - $VERSION = 0.2; + $VERSION = 0.3; @EXPORT = qw(aio_read aio_write aio_open aio_close aio_stat aio_lstat aio_unlink aio_fsync aio_fdatasync aio_readahead); @@ -130,8 +135,8 @@ offset C<0> within the scalar: aio_read $fh, 7, 15, $buffer, 0, sub { - $_[0] >= 0 or die "read error: $!"; - print "read <$buffer>\n"; + $_[0] > 0 or die "read error: $!"; + print "read $_[0] bytes: <$buffer>\n"; }; =item aio_readahead $fh,$offset,$length, $callback