ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/IO-AIO/AIO.pm
(Generate patch)

Comparing IO-AIO/AIO.pm (file contents):
Revision 1.125 by root, Sat May 10 22:47:34 2008 UTC vs.
Revision 1.133 by root, Sat Sep 6 07:14:52 2008 UTC

… …
193use strict 'vars'; 193use strict 'vars';
194 194
195use base 'Exporter'; 195use base 'Exporter';
196 196
197BEGIN { 197BEGIN {
198 our $VERSION = '3.0'; 198 our $VERSION = '3.07';
199 199
200 our @AIO_REQ = qw(aio_sendfile aio_read aio_write aio_open aio_close 200 our @AIO_REQ = qw(aio_sendfile aio_read aio_write aio_open aio_close
201 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir 201 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir
202 aio_scandir aio_symlink aio_readlink aio_sync aio_fsync 202 aio_scandir aio_symlink aio_readlink aio_sync aio_fsync
203 aio_fdatasync aio_pathsync aio_readahead 203 aio_fdatasync aio_pathsync aio_readahead
… …
1013Their lifetime, simplified, looks like this: when they are empty, they 1013Their lifetime, simplified, looks like this: when they are empty, they
1014will finish very quickly. If they contain only requests that are in the 1014will finish very quickly. If they contain only requests that are in the
1015C<done> state, they will also finish. Otherwise they will continue to 1015C<done> state, they will also finish. Otherwise they will continue to
1016exist. 1016exist.
1017 1017
1018That means after creating a group you have some time to add requests. And 1018That means after creating a group you have some time to add requests
1019in the callbacks of those requests, you can add further requests to the 1019(precisely before the callback has been invoked, which is only done within
1020group. And only when all those requests have finished will the the group 1020the C<poll_cb>). And in the callbacks of those requests, you can add
1021itself finish. 1021further requests to the group. And only when all those requests have
1022finished will the the group itself finish.
1022 1023
1023=over 4 1024=over 4
1024 1025
1025=item add $grp ... 1026=item add $grp ...
1026 1027
… …
1117See C<poll_cb> for an example. 1118See C<poll_cb> for an example.
1118 1119
1119=item IO::AIO::poll_cb 1120=item IO::AIO::poll_cb
1120 1121
1121Process some outstanding events on the result pipe. You have to call this 1122Process some outstanding events on the result pipe. You have to call this
1122regularly. Returns the number of events processed. Returns immediately 1123regularly. Returns C<0> if all events could be processed, or C<-1> if it
1124returned earlier for whatever reason. Returns immediately when no events
1123when no events are outstanding. The amount of events processed depends on 1125are outstanding. The amount of events processed depends on the settings of
1124the settings of C<IO::AIO::max_poll_req> and C<IO::AIO::max_poll_time>. 1126C<IO::AIO::max_poll_req> and C<IO::AIO::max_poll_time>.
1125 1127
1126If not all requests were processed for whatever reason, the filehandle 1128If not all requests were processed for whatever reason, the filehandle
1127will still be ready when C<poll_cb> returns. 1129will still be ready when C<poll_cb> returns, so normally you don't have to
1130do anything special to have it called later.
1128 1131
1129Example: Install an Event watcher that automatically calls 1132Example: Install an Event watcher that automatically calls
1130IO::AIO::poll_cb with high priority: 1133IO::AIO::poll_cb with high priority:
1131 1134
1132 Event->io (fd => IO::AIO::poll_fileno, 1135 Event->io (fd => IO::AIO::poll_fileno,

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines