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.119 by root, Sun Dec 2 20:54:33 2007 UTC vs.
Revision 1.120 by root, Sun Dec 2 21:51:36 2007 UTC

… …
196use base 'Exporter'; 196use base 'Exporter';
197 197
198BEGIN { 198BEGIN {
199 our $VERSION = '2.6'; 199 our $VERSION = '2.6';
200 200
201 our @AIO_REQ = qw(aio_sendfile aio_read aio_write aio_open aio_close aio_stat 201 our @AIO_REQ = qw(aio_sendfile aio_read aio_write aio_open aio_close
202 aio_lstat aio_unlink aio_rmdir aio_readdir aio_scandir aio_symlink 202 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir
203 aio_readlink aio_sync aio_fsync aio_fdatasync aio_readahead aio_rename aio_link 203 aio_scandir aio_symlink aio_readlink aio_sync aio_fsync
204 aio_fdatasync aio_pathsync aio_readahead
205 aio_rename aio_link aio_move aio_copy aio_group
204 aio_move aio_copy aio_group aio_nop aio_mknod aio_load aio_rmtree aio_mkdir 206 aio_nop aio_mknod aio_load aio_rmtree aio_mkdir aio_chown
205 aio_chown aio_chmod aio_utime aio_truncate); 207 aio_chmod aio_utime aio_truncate);
208
206 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice aio_block)); 209 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice aio_block));
207 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush 210 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush
208 min_parallel max_parallel max_idle 211 min_parallel max_parallel max_idle
209 nreqs nready npending nthreads 212 nreqs nready npending nthreads
210 max_poll_time max_poll_reqs); 213 max_poll_time max_poll_reqs);
… …
650 653
651 # those should not normally block. should. should. 654 # those should not normally block. should. should.
652 utime $stat[8], $stat[9], $dst; 655 utime $stat[8], $stat[9], $dst;
653 chmod $stat[2] & 07777, $dst_fh; 656 chmod $stat[2] & 07777, $dst_fh;
654 chown $stat[4], $stat[5], $dst_fh; 657 chown $stat[4], $stat[5], $dst_fh;
658
659 aioreq_pri $pri;
655 close $dst_fh; 660 add $grp aio_close $dst_fh;
656 } else { 661 } else {
657 $grp->result (-1); 662 $grp->result (-1);
658 close $src_fh; 663 close $src_fh;
659 close $dst_fh; 664 close $dst_fh;
660 665
… …
910callback with the fdatasync result code. 915callback with the fdatasync result code.
911 916
912If this call isn't available because your OS lacks it or it couldn't be 917If this call isn't available because your OS lacks it or it couldn't be
913detected, it will be emulated by calling C<fsync> instead. 918detected, it will be emulated by calling C<fsync> instead.
914 919
920=item aio_pathsync $path, $callback->($status)
921
922This request tries to open, fsync and close the given path. This is a
923composite request intended tosync directories after directory operations
924(E.g. rename). This might not work on all operating systems or have any
925specific effect, but usually it makes sure that directory changes get
926written to disc. It works for anything that can be opened for read-only,
927not just directories.
928
929Passes C<0> when everything went ok, and C<-1> on error.
930
931=cut
932
933sub aio_pathsync($;$) {
934 aio_block {
935 my ($path, $cb) = @_;
936
937 my $pri = aioreq_pri;
938 my $grp = aio_group $cb;
939
940 aioreq_pri $pri;
941 add $grp aio_open $path, O_RDONLY, 0, sub {
942 my ($fh) = @_;
943 if ($fh) {
944 aioreq_pri $pri;
945 add $grp aio_fsync $fh, sub {
946 $grp->result ($_[0]);
947
948 aioreq_pri $pri;
949 add $grp aio_close $fh;
950 };
951 } else {
952 $grp->result (-1);
953 }
954 };
955
956 $grp
957 }
958}
959
915=item aio_group $callback->(...) 960=item aio_group $callback->(...)
916 961
917This is a very special aio request: Instead of doing something, it is a 962This is a very special aio request: Instead of doing something, it is a
918container for other aio requests, which is useful if you want to bundle 963container for other aio requests, which is useful if you want to bundle
919many requests into a single, composite, request with a definite callback 964many requests into a single, composite, request with a definite callback
… …
1055itself. Useful when you queued a lot of events but got a result early. 1100itself. Useful when you queued a lot of events but got a result early.
1056 1101
1057=item $grp->result (...) 1102=item $grp->result (...)
1058 1103
1059Set the result value(s) that will be passed to the group callback when all 1104Set the result value(s) that will be passed to the group callback when all
1060subrequests have finished and set thre groups errno to the current value 1105subrequests have finished and set the groups errno to the current value
1061of errno (just like calling C<errno> without an error number). By default, 1106of errno (just like calling C<errno> without an error number). By default,
1062no argument will be passed and errno is zero. 1107no argument will be passed and errno is zero.
1063 1108
1064=item $grp->errno ([$errno]) 1109=item $grp->errno ([$errno])
1065 1110

Diff Legend

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