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

Comparing IO-AIO/README (file contents):
Revision 1.25 by root, Mon Sep 24 19:28:50 2007 UTC vs.
Revision 1.28 by root, Sun Mar 30 06:31:49 2008 UTC

24 $req->cancel; # cancel request if still in queue 24 $req->cancel; # cancel request if still in queue
25 25
26 my $grp = aio_group sub { print "all stats done\n" }; 26 my $grp = aio_group sub { print "all stats done\n" };
27 add $grp aio_stat "..." for ...; 27 add $grp aio_stat "..." for ...;
28 28
29 # AnyEvent integration 29 # AnyEvent integration (EV, Event, Glib, Tk, urxvt, pureperl...)
30 open my $fh, "<&=" . IO::AIO::poll_fileno or die "$!"; 30 open my $fh, "<&=" . IO::AIO::poll_fileno or die "$!";
31 my $w = AnyEvent->io (fh => $fh, poll => 'r', cb => sub { IO::AIO::poll_cb }); 31 my $w = AnyEvent->io (fh => $fh, poll => 'r', cb => sub { IO::AIO::poll_cb });
32
33 # EV integration
34 my $w = EV::io IO::AIO::poll_fileno, EV::READ, \&IO::AIO::poll_cb;
32 35
33 # Event integration 36 # Event integration
34 Event->io (fd => IO::AIO::poll_fileno, 37 Event->io (fd => IO::AIO::poll_fileno,
35 poll => 'r', 38 poll => 'r',
36 cb => \&IO::AIO::poll_cb); 39 cb => \&IO::AIO::poll_cb);
258 } 261 }
259 }; 262 };
260 263
261 aio_close $fh, $callback->($status) 264 aio_close $fh, $callback->($status)
262 Asynchronously close a file and call the callback with the result 265 Asynchronously close a file and call the callback with the result
263 code. *WARNING:* although accepted, you should not pass in a perl 266 code.
264 filehandle here, as perl will likely close the file descriptor
265 another time when the filehandle is destroyed. Normally, you can
266 safely call perls "close" or just let filehandles go out of scope.
267 267
268 This is supposed to be a bug in the API, so that might change. It's 268 Unfortunately, you can't do this to perl. Perl *insists* very
269 therefore best to avoid this function. 269 strongly on closing the file descriptor associated with the
270 filehandle itself. Here is what aio_close will try:
271
272 1. dup()licate the fd
273 2. asynchronously close() the duplicated fd
274 3. dup()licate the fd once more
275 4. let perl close() the filehandle
276 5. asynchronously close the duplicated fd
277
278 The idea is that the first close() flushes stuff to disk that
279 closing an fd will flush, so when perl closes the fd, nothing much
280 will need to be flushed. The second async. close() will then flush
281 stuff to disk that closing the last fd to the file will flush.
282
283 Just FYI, SuSv3 has this to say on close:
284
285 All outstanding record locks owned by the process on the file
286 associated with the file descriptor shall be removed.
287
288 If fildes refers to a socket, close() shall cause the socket to be
289 destroyed. ... close() shall block for up to the current linger
290 interval until all data is transmitted.
291 [this actually sounds like a specification bug, but who knows]
292
293 And at least Linux additionally actually flushes stuff on every
294 close, even when the file itself is still open.
295
296 Sounds enourmously inefficient and complicated? Yes... please show
297 me how to nuke perl's fd out of existence...
270 298
271 aio_read $fh,$offset,$length, $data,$dataoffset, $callback->($retval) 299 aio_read $fh,$offset,$length, $data,$dataoffset, $callback->($retval)
272 aio_write $fh,$offset,$length, $data,$dataoffset, $callback->($retval) 300 aio_write $fh,$offset,$length, $data,$dataoffset, $callback->($retval)
273 Reads or writes $length bytes from the specified $fh and $offset 301 Reads or writes $length bytes from the specified $fh and $offset
274 into the scalar given by $data and offset $dataoffset and calls the 302 into the scalar given by $data and offset $dataoffset and calls the
521 Delete a directory tree starting (and including) $path, return the 549 Delete a directory tree starting (and including) $path, return the
522 status of the final "rmdir" only. This is a composite request that 550 status of the final "rmdir" only. This is a composite request that
523 uses "aio_scandir" to recurse into and rmdir directories, and unlink 551 uses "aio_scandir" to recurse into and rmdir directories, and unlink
524 everything else. 552 everything else.
525 553
554 aio_sync $callback->($status)
555 Asynchronously call sync and call the callback when finished.
556
526 aio_fsync $fh, $callback->($status) 557 aio_fsync $fh, $callback->($status)
527 Asynchronously call fsync on the given filehandle and call the 558 Asynchronously call fsync on the given filehandle and call the
528 callback with the fsync result code. 559 callback with the fsync result code.
529 560
530 aio_fdatasync $fh, $callback->($status) 561 aio_fdatasync $fh, $callback->($status)
531 Asynchronously call fdatasync on the given filehandle and call the 562 Asynchronously call fdatasync on the given filehandle and call the
532 callback with the fdatasync result code. 563 callback with the fdatasync result code.
533 564
534 If this call isn't available because your OS lacks it or it couldn't 565 If this call isn't available because your OS lacks it or it couldn't
535 be detected, it will be emulated by calling "fsync" instead. 566 be detected, it will be emulated by calling "fsync" instead.
567
568 aio_pathsync $path, $callback->($status)
569 This request tries to open, fsync and close the given path. This is
570 a composite request intended tosync directories after directory
571 operations (E.g. rename). This might not work on all operating
572 systems or have any specific effect, but usually it makes sure that
573 directory changes get written to disc. It works for anything that
574 can be opened for read-only, not just directories.
575
576 Passes 0 when everything went ok, and -1 on error.
536 577
537 aio_group $callback->(...) 578 aio_group $callback->(...)
538 This is a very special aio request: Instead of doing something, it 579 This is a very special aio request: Instead of doing something, it
539 is a container for other aio requests, which is useful if you want 580 is a container for other aio requests, which is useful if you want
540 to bundle many requests into a single, composite, request with a 581 to bundle many requests into a single, composite, request with a
622 }; 663 };
623 664
624 This makes it very easy to create composite requests (see the source of 665 This makes it very easy to create composite requests (see the source of
625 "aio_move" for an application) that work and feel like simple requests. 666 "aio_move" for an application) that work and feel like simple requests.
626 667
627 * The IO::AIO::GRP objects will be cleaned up during calls to 668 * The IO::AIO::GRP objects will be cleaned up during calls to
628 "IO::AIO::poll_cb", just like any other request. 669 "IO::AIO::poll_cb", just like any other request.
670
629 * They can be canceled like any other request. Canceling will cancel not 671 * They can be canceled like any other request. Canceling will cancel
630 only the request itself, but also all requests it contains. 672 not only the request itself, but also all requests it contains.
673
631 * They can also can also be added to other IO::AIO::GRP objects. 674 * They can also can also be added to other IO::AIO::GRP objects.
675
632 * You must not add requests to a group from within the group callback 676 * You must not add requests to a group from within the group callback
633 (or any later time). 677 (or any later time).
634 678
635 Their lifetime, simplified, looks like this: when they are empty, they 679 Their lifetime, simplified, looks like this: when they are empty, they
636 will finish very quickly. If they contain only requests that are in the 680 will finish very quickly. If they contain only requests that are in the
637 "done" state, they will also finish. Otherwise they will continue to 681 "done" state, they will also finish. Otherwise they will continue to
638 exist. 682 exist.
655 request itself. Useful when you queued a lot of events but got a 699 request itself. Useful when you queued a lot of events but got a
656 result early. 700 result early.
657 701
658 $grp->result (...) 702 $grp->result (...)
659 Set the result value(s) that will be passed to the group callback 703 Set the result value(s) that will be passed to the group callback
660 when all subrequests have finished and set thre groups errno to the 704 when all subrequests have finished and set the groups errno to the
661 current value of errno (just like calling "errno" without an error 705 current value of errno (just like calling "errno" without an error
662 number). By default, no argument will be passed and errno is zero. 706 number). By default, no argument will be passed and errno is zero.
663 707
664 $grp->errno ([$errno]) 708 $grp->errno ([$errno])
665 Sets the group errno value to $errno, or the current value of errno 709 Sets the group errno value to $errno, or the current value of errno

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines