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.117 by root, Sat Oct 6 14:05:19 2007 UTC vs.
Revision 1.120 by root, Sun Dec 2 21:51:36 2007 UTC

… …
26 $req->cancel; # cancel request if still in queue 26 $req->cancel; # cancel request if still in queue
27 27
28 my $grp = aio_group sub { print "all stats done\n" }; 28 my $grp = aio_group sub { print "all stats done\n" };
29 add $grp aio_stat "..." for ...; 29 add $grp aio_stat "..." for ...;
30 30
31 # AnyEvent integration 31 # AnyEvent integration (EV, Event, Glib, Tk, urxvt, pureperl...)
32 open my $fh, "<&=" . IO::AIO::poll_fileno or die "$!"; 32 open my $fh, "<&=" . IO::AIO::poll_fileno or die "$!";
33 my $w = AnyEvent->io (fh => $fh, poll => 'r', cb => sub { IO::AIO::poll_cb }); 33 my $w = AnyEvent->io (fh => $fh, poll => 'r', cb => sub { IO::AIO::poll_cb });
34
35 # EV integration
36 my $w = EV::io IO::AIO::poll_fileno, EV::READ, \&IO::AIO::poll_cb;
34 37
35 # Event integration 38 # Event integration
36 Event->io (fd => IO::AIO::poll_fileno, 39 Event->io (fd => IO::AIO::poll_fileno,
37 poll => 'r', 40 poll => 'r',
38 cb => \&IO::AIO::poll_cb); 41 cb => \&IO::AIO::poll_cb);
… …
191use strict 'vars'; 194use strict 'vars';
192 195
193use base 'Exporter'; 196use base 'Exporter';
194 197
195BEGIN { 198BEGIN {
196 our $VERSION = '2.51'; 199 our $VERSION = '2.6';
197 200
198 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
199 aio_lstat aio_unlink aio_rmdir aio_readdir aio_scandir aio_symlink 202 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir
200 aio_readlink 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
201 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
202 aio_chown aio_chmod aio_utime aio_truncate); 207 aio_chmod aio_utime aio_truncate);
208
203 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice aio_block)); 209 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice aio_block));
204 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush 210 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush
205 min_parallel max_parallel max_idle 211 min_parallel max_parallel max_idle
206 nreqs nready npending nthreads 212 nreqs nready npending nthreads
207 max_poll_time max_poll_reqs); 213 max_poll_time max_poll_reqs);
… …
647 653
648 # those should not normally block. should. should. 654 # those should not normally block. should. should.
649 utime $stat[8], $stat[9], $dst; 655 utime $stat[8], $stat[9], $dst;
650 chmod $stat[2] & 07777, $dst_fh; 656 chmod $stat[2] & 07777, $dst_fh;
651 chown $stat[4], $stat[5], $dst_fh; 657 chown $stat[4], $stat[5], $dst_fh;
658
659 aioreq_pri $pri;
652 close $dst_fh; 660 add $grp aio_close $dst_fh;
653 } else { 661 } else {
654 $grp->result (-1); 662 $grp->result (-1);
655 close $src_fh; 663 close $src_fh;
656 close $dst_fh; 664 close $dst_fh;
657 665
… …
890 898
891 $grp 899 $grp
892 } 900 }
893} 901}
894 902
903=item aio_sync $callback->($status)
904
905Asynchronously call sync and call the callback when finished.
906
895=item aio_fsync $fh, $callback->($status) 907=item aio_fsync $fh, $callback->($status)
896 908
897Asynchronously call fsync on the given filehandle and call the callback 909Asynchronously call fsync on the given filehandle and call the callback
898with the fsync result code. 910with the fsync result code.
899 911
… …
902Asynchronously call fdatasync on the given filehandle and call the 914Asynchronously call fdatasync on the given filehandle and call the
903callback with the fdatasync result code. 915callback with the fdatasync result code.
904 916
905If 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
906detected, it will be emulated by calling C<fsync> instead. 918detected, it will be emulated by calling C<fsync> instead.
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}
907 959
908=item aio_group $callback->(...) 960=item aio_group $callback->(...)
909 961
910This 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
911container 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
… …
1048itself. 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.
1049 1101
1050=item $grp->result (...) 1102=item $grp->result (...)
1051 1103
1052Set 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
1053subrequests have finished and set thre groups errno to the current value 1105subrequests have finished and set the groups errno to the current value
1054of 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,
1055no argument will be passed and errno is zero. 1107no argument will be passed and errno is zero.
1056 1108
1057=item $grp->errno ([$errno]) 1109=item $grp->errno ([$errno])
1058 1110

Diff Legend

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