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.195 by root, Fri May 27 19:56:31 2011 UTC vs.
Revision 1.196 by root, Fri Jun 10 06:50:42 2011 UTC

… …
436 436
437Tries to copy C<$length> bytes from C<$in_fh> to C<$out_fh>. It starts 437Tries to copy C<$length> bytes from C<$in_fh> to C<$out_fh>. It starts
438reading at byte offset C<$in_offset>, and starts writing at the current 438reading at byte offset C<$in_offset>, and starts writing at the current
439file offset of C<$out_fh>. Because of that, it is not safe to issue more 439file offset of C<$out_fh>. Because of that, it is not safe to issue more
440than one C<aio_sendfile> per C<$out_fh>, as they will interfere with each 440than one C<aio_sendfile> per C<$out_fh>, as they will interfere with each
441other. 441other. The same C<$in_fh> works fine though, as this function does not
442move or use the file offset of C<$in_fh>.
442 443
443Please note that C<aio_sendfile> can read more bytes from C<$in_fh> than 444Please note that C<aio_sendfile> can read more bytes from C<$in_fh> than
444are written, and there is no way to find out how many bytes have been read 445are written, and there is no way to find out how many more bytes have been
445from C<aio_sendfile> alone, as C<aio_sendfile> only provides the number of 446read from C<aio_sendfile> alone, as C<aio_sendfile> only provides the
446bytes written to C<$out_fh>. Only if the result value equals C<$length> 447number of bytes written to C<$out_fh>. Only if the result value equals
447one can assume that C<$length> bytes have been read. 448C<$length> one can assume that C<$length> bytes have been read.
448 449
449Unlike with other C<aio_> functions, it makes a lot of sense to use 450Unlike with other C<aio_> functions, it makes a lot of sense to use
450C<aio_sendfile> on non-blocking sockets, as long as one end (typically 451C<aio_sendfile> on non-blocking sockets, as long as one end (typically
451the C<$in_fh>) is a file - the file I/O will then be asynchronous, while 452the C<$in_fh>) is a file - the file I/O will then be asynchronous, while
452the socket I/O will be non-blocking. Note, however, that you can run into 453the socket I/O will be non-blocking. Note, however, that you can run
453a trap where C<aio_sendfile> reads some data with readahead, then fails 454into a trap where C<aio_sendfile> reads some data with readahead, then
454to write all data, and when the socket is ready the next time, the data 455fails to write all data, and when the socket is ready the next time, the
455in the cache is already lost, forcing C<aio_sendfile> to again hit the 456data in the cache is already lost, forcing C<aio_sendfile> to again hit
456disk. Explicit C<aio_read> + C<aio_write> let's you control resource usage 457the disk. Explicit C<aio_read> + C<aio_write> let's you better control
457much better. 458resource usage.
458 459
459This call tries to make use of a native C<sendfile> syscall to provide 460This call tries to make use of a native C<sendfile>-like syscall to
460zero-copy operation. For this to work, C<$out_fh> should refer to a 461provide zero-copy operation. For this to work, C<$out_fh> should refer to
461socket, and C<$in_fh> should refer to an mmap'able file. 462a socket, and C<$in_fh> should refer to an mmap'able file.
462 463
463If a native sendfile cannot be found or it fails with C<ENOSYS>, 464If a native sendfile cannot be found or it fails with C<ENOSYS>,
464C<ENOTSUP>, C<EOPNOTSUPP>, C<EAFNOSUPPORT>, C<EPROTOTYPE> or C<ENOTSOCK>, 465C<EINVAL>, C<ENOTSUP>, C<EOPNOTSUPP>, C<EAFNOSUPPORT>, C<EPROTOTYPE> or
465it will be emulated, so you can call C<aio_sendfile> on any type of 466C<ENOTSOCK>, it will be emulated, so you can call C<aio_sendfile> on any
466filehandle regardless of the limitations of the operating system. 467type of filehandle regardless of the limitations of the operating system.
468
469As native sendfile syscalls (as practically any non-POSIX interface hacked
470together in a hurry to improve benchmark numbers) tend to be rather buggy
471on many systems, this implementation tries to work around some known bugs
472in Linux and FreeBSD kernels (probably others, too), but that might fail,
473so you really really should check the return value of C<aio_sendfile> -
474fewre bytes than expected might have been transferred.
467 475
468 476
469=item aio_readahead $fh,$offset,$length, $callback->($retval) 477=item aio_readahead $fh,$offset,$length, $callback->($retval)
470 478
471C<aio_readahead> populates the page cache with data from a file so that 479C<aio_readahead> populates the page cache with data from a file so that
… …
862 if ($_[0] && $! == EXDEV) { 870 if ($_[0] && $! == EXDEV) {
863 aioreq_pri $pri; 871 aioreq_pri $pri;
864 add $grp aio_copy $src, $dst, sub { 872 add $grp aio_copy $src, $dst, sub {
865 $grp->result ($_[0]); 873 $grp->result ($_[0]);
866 874
867 if (!$_[0]) { 875 unless ($_[0]) {
868 aioreq_pri $pri; 876 aioreq_pri $pri;
869 add $grp aio_unlink $src; 877 add $grp aio_unlink $src;
870 } 878 }
871 }; 879 };
872 } else { 880 } else {

Diff Legend

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