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.262 by root, Thu Jun 9 03:15:37 2016 UTC vs.
Revision 1.282 by root, Tue Feb 20 05:23:47 2018 UTC

1=head1 NAME 1=head1 NAME
2 2
3IO::AIO - Asynchronous Input/Output 3IO::AIO - Asynchronous/Advanced Input/Output
4 4
5=head1 SYNOPSIS 5=head1 SYNOPSIS
6 6
7 use IO::AIO; 7 use IO::AIO;
8 8
58not well-supported or restricted (GNU/Linux doesn't allow them on normal 58not well-supported or restricted (GNU/Linux doesn't allow them on normal
59files currently, for example), and they would only support aio_read and 59files currently, for example), and they would only support aio_read and
60aio_write, so the remaining functionality would have to be implemented 60aio_write, so the remaining functionality would have to be implemented
61using threads anyway. 61using threads anyway.
62 62
63In addition to asynchronous I/O, this module also exports some rather
64arcane interfaces, such as C<madvise> or linux's C<splice> system call,
65which is why the C<A> in C<AIO> can also mean I<advanced>.
66
63Although the module will work in the presence of other (Perl-) threads, 67Although the module will work in the presence of other (Perl-) threads,
64it is currently not reentrant in any way, so use appropriate locking 68it is currently not reentrant in any way, so use appropriate locking
65yourself, always call C<poll_cb> from within the same thread, or never 69yourself, always call C<poll_cb> from within the same thread, or never
66call C<poll_cb> (or other C<aio_> functions) recursively. 70call C<poll_cb> (or other C<aio_> functions) recursively.
67 71
167use common::sense; 171use common::sense;
168 172
169use base 'Exporter'; 173use base 'Exporter';
170 174
171BEGIN { 175BEGIN {
172 our $VERSION = 4.34; 176 our $VERSION = 4.4;
173 177
174 our @AIO_REQ = qw(aio_sendfile aio_seek aio_read aio_write aio_open aio_close 178 our @AIO_REQ = qw(aio_sendfile aio_seek aio_read aio_write aio_open aio_close
175 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir aio_readdirx 179 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir aio_readdirx
176 aio_scandir aio_symlink aio_readlink aio_realpath aio_fcntl aio_ioctl 180 aio_scandir aio_symlink aio_readlink aio_realpath aio_fcntl aio_ioctl
177 aio_sync aio_fsync aio_syncfs aio_fdatasync aio_sync_file_range 181 aio_sync aio_fsync aio_syncfs aio_fdatasync aio_sync_file_range
178 aio_pathsync aio_readahead aio_fiemap aio_allocate 182 aio_pathsync aio_readahead aio_fiemap aio_allocate
179 aio_rename aio_link aio_move aio_copy aio_group 183 aio_rename aio_rename2 aio_link aio_move aio_copy aio_group
180 aio_nop aio_mknod aio_load aio_rmtree aio_mkdir aio_chown 184 aio_nop aio_mknod aio_load aio_rmtree aio_mkdir aio_chown
181 aio_chmod aio_utime aio_truncate 185 aio_chmod aio_utime aio_truncate
182 aio_msync aio_mtouch aio_mlock aio_mlockall 186 aio_msync aio_mtouch aio_mlock aio_mlockall
183 aio_statvfs 187 aio_statvfs
188 aio_slurp
184 aio_wd); 189 aio_wd);
185 190
186 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice)); 191 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice));
187 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush 192 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush
188 min_parallel max_parallel max_idle idle_timeout 193 min_parallel max_parallel max_idle idle_timeout
229 aio_link $srcpath, $dstpath, $callback->($status) 234 aio_link $srcpath, $dstpath, $callback->($status)
230 aio_symlink $srcpath, $dstpath, $callback->($status) 235 aio_symlink $srcpath, $dstpath, $callback->($status)
231 aio_readlink $pathname, $callback->($link) 236 aio_readlink $pathname, $callback->($link)
232 aio_realpath $pathname, $callback->($path) 237 aio_realpath $pathname, $callback->($path)
233 aio_rename $srcpath, $dstpath, $callback->($status) 238 aio_rename $srcpath, $dstpath, $callback->($status)
239 aio_rename2 $srcpath, $dstpath, $flags, $callback->($status)
234 aio_mkdir $pathname, $mode, $callback->($status) 240 aio_mkdir $pathname, $mode, $callback->($status)
235 aio_rmdir $pathname, $callback->($status) 241 aio_rmdir $pathname, $callback->($status)
236 aio_readdir $pathname, $callback->($entries) 242 aio_readdir $pathname, $callback->($entries)
237 aio_readdirx $pathname, $flags, $callback->($entries, $flags) 243 aio_readdirx $pathname, $flags, $callback->($entries, $flags)
238 IO::AIO::READDIR_DENTS IO::AIO::READDIR_DIRS_FIRST 244 IO::AIO::READDIR_DENTS IO::AIO::READDIR_DIRS_FIRST
248 aio_syncfs $fh, $callback->($status) 254 aio_syncfs $fh, $callback->($status)
249 aio_fsync $fh, $callback->($status) 255 aio_fsync $fh, $callback->($status)
250 aio_fdatasync $fh, $callback->($status) 256 aio_fdatasync $fh, $callback->($status)
251 aio_sync_file_range $fh, $offset, $nbytes, $flags, $callback->($status) 257 aio_sync_file_range $fh, $offset, $nbytes, $flags, $callback->($status)
252 aio_pathsync $pathname, $callback->($status) 258 aio_pathsync $pathname, $callback->($status)
253 aio_msync $scalar, $offset = 0, $length = undef, flags = 0, $callback->($status) 259 aio_msync $scalar, $offset = 0, $length = undef, flags = MS_SYNC, $callback->($status)
254 aio_mtouch $scalar, $offset = 0, $length = undef, flags = 0, $callback->($status) 260 aio_mtouch $scalar, $offset = 0, $length = undef, flags = 0, $callback->($status)
255 aio_mlock $scalar, $offset = 0, $length = undef, $callback->($status) 261 aio_mlock $scalar, $offset = 0, $length = undef, $callback->($status)
256 aio_mlockall $flags, $callback->($status) 262 aio_mlockall $flags, $callback->($status)
257 aio_group $callback->(...) 263 aio_group $callback->(...)
258 aio_nop $callback->() 264 aio_nop $callback->()
272 IO::AIO::idle_timeout $seconds 278 IO::AIO::idle_timeout $seconds
273 IO::AIO::max_outstanding $maxreqs 279 IO::AIO::max_outstanding $maxreqs
274 IO::AIO::nreqs 280 IO::AIO::nreqs
275 IO::AIO::nready 281 IO::AIO::nready
276 IO::AIO::npending 282 IO::AIO::npending
283 $nfd = IO::AIO::get_fdlimit [EXPERIMENTAL]
284 IO::AIO::min_fdlimit $nfd [EXPERIMENTAL]
277 285
278 IO::AIO::sendfile $ofh, $ifh, $offset, $count 286 IO::AIO::sendfile $ofh, $ifh, $offset, $count
279 IO::AIO::fadvise $fh, $offset, $len, $advice 287 IO::AIO::fadvise $fh, $offset, $len, $advice
280 IO::AIO::mmap $scalar, $length, $prot, $flags[, $fh[, $offset]] 288 IO::AIO::mmap $scalar, $length, $prot, $flags[, $fh[, $offset]]
281 IO::AIO::munmap $scalar 289 IO::AIO::munmap $scalar
441=item aio_read $fh,$offset,$length, $data,$dataoffset, $callback->($retval) 449=item aio_read $fh,$offset,$length, $data,$dataoffset, $callback->($retval)
442 450
443=item aio_write $fh,$offset,$length, $data,$dataoffset, $callback->($retval) 451=item aio_write $fh,$offset,$length, $data,$dataoffset, $callback->($retval)
444 452
445Reads or writes C<$length> bytes from or to the specified C<$fh> and 453Reads or writes C<$length> bytes from or to the specified C<$fh> and
446C<$offset> into the scalar given by C<$data> and offset C<$dataoffset> 454C<$offset> into the scalar given by C<$data> and offset C<$dataoffset> and
447and calls the callback without the actual number of bytes read (or -1 on 455calls the callback with the actual number of bytes transferred (or -1 on
448error, just like the syscall). 456error, just like the syscall).
449 457
450C<aio_read> will, like C<sysread>, shrink or grow the C<$data> scalar to 458C<aio_read> will, like C<sysread>, shrink or grow the C<$data> scalar to
451offset plus the actual number of bytes read. 459offset plus the actual number of bytes read.
452 460
604 namemax => 255, 612 namemax => 255,
605 frsize => 1024, 613 frsize => 1024,
606 fsid => 1810 614 fsid => 1810
607 } 615 }
608 616
609Here is a (likely partial - send me updates!) list of fsid values used by
610Linux - it is safe to hardcode these when C<$^O> is C<linux>:
611
612 0x0000adf5 adfs
613 0x0000adff affs
614 0x5346414f afs
615 0x09041934 anon-inode filesystem
616 0x00000187 autofs
617 0x42465331 befs
618 0x1badface bfs
619 0x42494e4d binfmt_misc
620 0x9123683e btrfs
621 0x0027e0eb cgroupfs
622 0xff534d42 cifs
623 0x73757245 coda
624 0x012ff7b7 coh
625 0x28cd3d45 cramfs
626 0x453dcd28 cramfs-wend (wrong endianness)
627 0x64626720 debugfs
628 0x00001373 devfs
629 0x00001cd1 devpts
630 0x0000f15f ecryptfs
631 0x00414a53 efs
632 0x0000137d ext
633 0x0000ef53 ext2/ext3/ext4
634 0x0000ef51 ext2
635 0xf2f52010 f2fs
636 0x00004006 fat
637 0x65735546 fuseblk
638 0x65735543 fusectl
639 0x0bad1dea futexfs
640 0x01161970 gfs2
641 0x47504653 gpfs
642 0x00004244 hfs
643 0xf995e849 hpfs
644 0x00c0ffee hostfs
645 0x958458f6 hugetlbfs
646 0x2bad1dea inotifyfs
647 0x00009660 isofs
648 0x000072b6 jffs2
649 0x3153464a jfs
650 0x6b414653 k-afs
651 0x0bd00bd0 lustre
652 0x0000137f minix
653 0x0000138f minix 30 char names
654 0x00002468 minix v2
655 0x00002478 minix v2 30 char names
656 0x00004d5a minix v3
657 0x19800202 mqueue
658 0x00004d44 msdos
659 0x0000564c novell
660 0x00006969 nfs
661 0x6e667364 nfsd
662 0x00003434 nilfs
663 0x5346544e ntfs
664 0x00009fa1 openprom
665 0x7461636F ocfs2
666 0x00009fa0 proc
667 0x6165676c pstorefs
668 0x0000002f qnx4
669 0x68191122 qnx6
670 0x858458f6 ramfs
671 0x52654973 reiserfs
672 0x00007275 romfs
673 0x67596969 rpc_pipefs
674 0x73636673 securityfs
675 0xf97cff8c selinux
676 0x0000517b smb
677 0x534f434b sockfs
678 0x73717368 squashfs
679 0x62656572 sysfs
680 0x012ff7b6 sysv2
681 0x012ff7b5 sysv4
682 0x01021994 tmpfs
683 0x15013346 udf
684 0x00011954 ufs
685 0x54190100 ufs byteswapped
686 0x00009fa2 usbdevfs
687 0x01021997 v9fs
688 0xa501fcf5 vxfs
689 0xabba1974 xenfs
690 0x012ff7b4 xenix
691 0x58465342 xfs
692 0x012fd16d xia
693
694=item aio_utime $fh_or_path, $atime, $mtime, $callback->($status) 617=item aio_utime $fh_or_path, $atime, $mtime, $callback->($status)
695 618
696Works like perl's C<utime> function (including the special case of $atime 619Works like perl's C<utime> function (including the special case of $atime
697and $mtime being undef). Fractional times are supported if the underlying 620and $mtime being undef). Fractional times are supported if the underlying
698syscalls support them. 621syscalls support them.
735C<$mode> is usually C<0> or C<IO::AIO::FALLOC_FL_KEEP_SIZE> to allocate 658C<$mode> is usually C<0> or C<IO::AIO::FALLOC_FL_KEEP_SIZE> to allocate
736space, or C<IO::AIO::FALLOC_FL_PUNCH_HOLE | IO::AIO::FALLOC_FL_KEEP_SIZE>, 659space, or C<IO::AIO::FALLOC_FL_PUNCH_HOLE | IO::AIO::FALLOC_FL_KEEP_SIZE>,
737to deallocate a file range. 660to deallocate a file range.
738 661
739IO::AIO also supports C<FALLOC_FL_COLLAPSE_RANGE>, to remove a range 662IO::AIO also supports C<FALLOC_FL_COLLAPSE_RANGE>, to remove a range
740(without leaving a hole) and C<FALLOC_FL_ZERO_RANGE>, to zero a range (see 663(without leaving a hole), C<FALLOC_FL_ZERO_RANGE>, to zero a range,
741your L<fallocate(2)> manpage). 664C<FALLOC_FL_INSERT_RANGE> to insert a range and C<FALLOC_FL_UNSHARE_RANGE>
665to unshare shared blocks (see your L<fallocate(2)> manpage).
742 666
743The file system block size used by C<fallocate> is presumably the 667The file system block size used by C<fallocate> is presumably the
744C<f_bsize> returned by C<statvfs>. 668C<f_bsize> returned by C<statvfs>, but different filesystems and filetypes
669can dictate other limitations.
745 670
746If C<fallocate> isn't available or cannot be emulated (currently no 671If C<fallocate> isn't available or cannot be emulated (currently no
747emulation will be attempted), passes C<-1> and sets C<$!> to C<ENOSYS>. 672emulation will be attempted), passes C<-1> and sets C<$!> to C<ENOSYS>.
748 673
749 674
806rename(2) and call the callback with the result code. 731rename(2) and call the callback with the result code.
807 732
808On systems that support the AIO::WD working directory abstraction 733On systems that support the AIO::WD working directory abstraction
809natively, the case C<[$wd, "."]> as C<$srcpath> is specialcased - instead 734natively, the case C<[$wd, "."]> as C<$srcpath> is specialcased - instead
810of failing, C<rename> is called on the absolute path of C<$wd>. 735of failing, C<rename> is called on the absolute path of C<$wd>.
736
737
738=item aio_rename2 $srcpath, $dstpath, $flags, $callback->($status)
739
740Basically a version of C<aio_rename> with an additional C<$flags>
741argument. Calling this with C<$flags=0> is the same as calling
742C<aio_rename>.
743
744Non-zero flags are currently only supported on GNU/Linux systems that
745support renameat2. Other systems fail with C<ENOSYS> in this case.
746
747The following constants are available (missing ones are, as usual C<0>),
748see renameat2(2) for details:
749
750C<IO::AIO::RENAME_NOREPLACE>, C<IO::AIO::RENAME_EXCHANGE>
751and C<IO::AIO::RENAME_WHITEOUT>.
811 752
812 753
813=item aio_mkdir $pathname, $mode, $callback->($status) 754=item aio_mkdir $pathname, $mode, $callback->($status)
814 755
815Asynchronously mkdir (create) a directory and call the callback with 756Asynchronously mkdir (create) a directory and call the callback with
901C<$type>'s are known, which can be used to speed up some algorithms. 842C<$type>'s are known, which can be used to speed up some algorithms.
902 843
903=back 844=back
904 845
905 846
847=item aio_slurp $pathname, $offset, $length, $data, $callback->($status)
848
849Opens, reads and closes the given file. The data is put into C<$data>,
850which is resized as required.
851
852If C<$offset> is negative, then it is counted from the end of the file.
853
854If C<$length> is zero, then the remaining length of the file is
855used. Also, in this case, the same limitations to modifying C<$data> apply
856as when IO::AIO::mmap is used, i.e. it must only be modified in-place
857with C<substr>. If the size of the file is known, specifying a non-zero
858C<$length> results in a performance advantage.
859
860This request is similar to the older C<aio_load> request, but since it is
861a single request, it might be more efficient to use.
862
863Example: load F</etc/passwd> into C<$passwd>.
864
865 my $passwd;
866 aio_slurp "/etc/passwd", 0, 0, $passwd, sub {
867 $_[0] >= 0
868 or die "/etc/passwd: $!\n";
869
870 printf "/etc/passwd is %d bytes long, and contains:\n", length $passwd;
871 print $passwd;
872 };
873 IO::AIO::flush;
874
875
906=item aio_load $pathname, $data, $callback->($status) 876=item aio_load $pathname, $data, $callback->($status)
907 877
908This is a composite request that tries to fully load the given file into 878This is a composite request that tries to fully load the given file into
909memory. Status is the same as with aio_read. 879memory. Status is the same as with aio_read.
880
881Using C<aio_slurp> might be more efficient, as it is a single request.
910 882
911=cut 883=cut
912 884
913sub aio_load($$;$) { 885sub aio_load($$;$) {
914 my ($path, undef, $cb) = @_; 886 my ($path, undef, $cb) = @_;
934=item aio_copy $srcpath, $dstpath, $callback->($status) 906=item aio_copy $srcpath, $dstpath, $callback->($status)
935 907
936Try to copy the I<file> (directories not supported as either source or 908Try to copy the I<file> (directories not supported as either source or
937destination) from C<$srcpath> to C<$dstpath> and call the callback with 909destination) from C<$srcpath> to C<$dstpath> and call the callback with
938a status of C<0> (ok) or C<-1> (error, see C<$!>). 910a status of C<0> (ok) or C<-1> (error, see C<$!>).
911
912Existing destination files will be truncated.
939 913
940This is a composite request that creates the destination file with 914This is a composite request that creates the destination file with
941mode 0200 and copies the contents of the source file into it using 915mode 0200 and copies the contents of the source file into it using
942C<aio_sendfile>, followed by restoring atime, mtime, access mode and 916C<aio_sendfile>, followed by restoring atime, mtime, access mode and
943uid/gid, in that order. 917uid/gid, in that order.
1053Scans a directory (similar to C<aio_readdir>) but additionally tries to 1027Scans a directory (similar to C<aio_readdir>) but additionally tries to
1054efficiently separate the entries of directory C<$path> into two sets of 1028efficiently separate the entries of directory C<$path> into two sets of
1055names, directories you can recurse into (directories), and ones you cannot 1029names, directories you can recurse into (directories), and ones you cannot
1056recurse into (everything else, including symlinks to directories). 1030recurse into (everything else, including symlinks to directories).
1057 1031
1058C<aio_scandir> is a composite request that creates of many sub requests_ 1032C<aio_scandir> is a composite request that generates many sub requests.
1059C<$maxreq> specifies the maximum number of outstanding aio requests that 1033C<$maxreq> specifies the maximum number of outstanding aio requests that
1060this function generates. If it is C<< <= 0 >>, then a suitable default 1034this function generates. If it is C<< <= 0 >>, then a suitable default
1061will be chosen (currently 4). 1035will be chosen (currently 4).
1062 1036
1063On error, the callback is called without arguments, otherwise it receives 1037On error, the callback is called without arguments, otherwise it receives
1248So in general, you should only use these calls for things that do 1222So in general, you should only use these calls for things that do
1249(filesystem) I/O, not for things that wait for other events (network, 1223(filesystem) I/O, not for things that wait for other events (network,
1250other processes), although if you are careful and know what you are doing, 1224other processes), although if you are careful and know what you are doing,
1251you still can. 1225you still can.
1252 1226
1227The following constants are available (missing ones are, as usual C<0>):
1228
1229C<F_DUPFD_CLOEXEC>,
1230
1231C<F_OFD_GETLK>, C<F_OFD_SETLK>, C<F_OFD_GETLKW>,
1232
1233C<FIFREEZE>, C<FITHAW>, C<FITRIM>, C<FICLONE>, C<FICLONERANGE>, C<FIDEDUPERANGE>.
1234
1235C<FS_IOC_GETFLAGS>, C<FS_IOC_SETFLAGS>, C<FS_IOC_GETVERSION>, C<FS_IOC_SETVERSION>,
1236C<FS_IOC_FIEMAP>.
1237
1238C<FS_IOC_FSGETXATTR>, C<FS_IOC_FSSETXATTR>, C<FS_IOC_SET_ENCRYPTION_POLICY>,
1239C<FS_IOC_GET_ENCRYPTION_PWSALT>, C<FS_IOC_GET_ENCRYPTION_POLICY>, C<FS_KEY_DESCRIPTOR_SIZE>.
1240
1241C<FS_SECRM_FL>, C<FS_UNRM_FL>, C<FS_COMPR_FL>, C<FS_SYNC_FL>, C<FS_IMMUTABLE_FL>,
1242C<FS_APPEND_FL>, C<FS_NODUMP_FL>, C<FS_NOATIME_FL>, C<FS_DIRTY_FL>,
1243C<FS_COMPRBLK_FL>, C<FS_NOCOMP_FL>, C<FS_ENCRYPT_FL>, C<FS_BTREE_FL>,
1244C<FS_INDEX_FL>, C<FS_JOURNAL_DATA_FL>, C<FS_NOTAIL_FL>, C<FS_DIRSYNC_FL>, C<FS_TOPDIR_FL>,
1245C<FS_FL_USER_MODIFIABLE>.
1246
1247C<FS_XFLAG_REALTIME>, C<FS_XFLAG_PREALLOC>, C<FS_XFLAG_IMMUTABLE>, C<FS_XFLAG_APPEND>,
1248C<FS_XFLAG_SYNC>, C<FS_XFLAG_NOATIME>, C<FS_XFLAG_NODUMP>, C<FS_XFLAG_RTINHERIT>,
1249C<FS_XFLAG_PROJINHERIT>, C<FS_XFLAG_NOSYMLINKS>, C<FS_XFLAG_EXTSIZE>, C<FS_XFLAG_EXTSZINHERIT>,
1250C<FS_XFLAG_NODEFRAG>, C<FS_XFLAG_FILESTREAM>, C<FS_XFLAG_DAX>, C<FS_XFLAG_HASATTR>,
1251
1253=item aio_sync $callback->($status) 1252=item aio_sync $callback->($status)
1254 1253
1255Asynchronously call sync and call the callback when finished. 1254Asynchronously call sync and call the callback when finished.
1256 1255
1257=item aio_fsync $fh, $callback->($status) 1256=item aio_fsync $fh, $callback->($status)
1325 }; 1324 };
1326 1325
1327 $grp 1326 $grp
1328} 1327}
1329 1328
1330=item aio_msync $scalar, $offset = 0, $length = undef, flags = 0, $callback->($status) 1329=item aio_msync $scalar, $offset = 0, $length = undef, flags = MS_SYNC, $callback->($status)
1331 1330
1332This is a rather advanced IO::AIO call, which only works on mmap(2)ed 1331This is a rather advanced IO::AIO call, which only works on mmap(2)ed
1333scalars (see the C<IO::AIO::mmap> function, although it also works on data 1332scalars (see the C<IO::AIO::mmap> function, although it also works on data
1334scalars managed by the L<Sys::Mmap> or L<Mmap> modules, note that the 1333scalars managed by the L<Sys::Mmap> or L<Mmap> modules, note that the
1335scalar must only be modified in-place while an aio operation is pending on 1334scalar must only be modified in-place while an aio operation is pending on
1337 1336
1338It calls the C<msync> function of your OS, if available, with the memory 1337It calls the C<msync> function of your OS, if available, with the memory
1339area starting at C<$offset> in the string and ending C<$length> bytes 1338area starting at C<$offset> in the string and ending C<$length> bytes
1340later. If C<$length> is negative, counts from the end, and if C<$length> 1339later. If C<$length> is negative, counts from the end, and if C<$length>
1341is C<undef>, then it goes till the end of the string. The flags can be 1340is C<undef>, then it goes till the end of the string. The flags can be
1342a combination of C<IO::AIO::MS_ASYNC>, C<IO::AIO::MS_INVALIDATE> and 1341either C<IO::AIO::MS_ASYNC> or C<IO::AIO::MS_SYNC>, plus an optional
1343C<IO::AIO::MS_SYNC>. 1342C<IO::AIO::MS_INVALIDATE>.
1344 1343
1345=item aio_mtouch $scalar, $offset = 0, $length = undef, flags = 0, $callback->($status) 1344=item aio_mtouch $scalar, $offset = 0, $length = undef, flags = 0, $callback->($status)
1346 1345
1347This is a rather advanced IO::AIO call, which works best on mmap(2)ed 1346This is a rather advanced IO::AIO call, which works best on mmap(2)ed
1348scalars. 1347scalars.
1431C<IO::AIO::FIEMAP_EXTENT_DATA_ENCRYPTED>, C<IO::AIO::FIEMAP_EXTENT_NOT_ALIGNED>, 1430C<IO::AIO::FIEMAP_EXTENT_DATA_ENCRYPTED>, C<IO::AIO::FIEMAP_EXTENT_NOT_ALIGNED>,
1432C<IO::AIO::FIEMAP_EXTENT_DATA_INLINE>, C<IO::AIO::FIEMAP_EXTENT_DATA_TAIL>, 1431C<IO::AIO::FIEMAP_EXTENT_DATA_INLINE>, C<IO::AIO::FIEMAP_EXTENT_DATA_TAIL>,
1433C<IO::AIO::FIEMAP_EXTENT_UNWRITTEN>, C<IO::AIO::FIEMAP_EXTENT_MERGED> or 1432C<IO::AIO::FIEMAP_EXTENT_UNWRITTEN>, C<IO::AIO::FIEMAP_EXTENT_MERGED> or
1434C<IO::AIO::FIEMAP_EXTENT_SHARED>. 1433C<IO::AIO::FIEMAP_EXTENT_SHARED>.
1435 1434
1436At the time of this writing (Linux 3.2), this requets is unreliable unless 1435At the time of this writing (Linux 3.2), this request is unreliable unless
1437C<$count> is C<undef>, as the kernel has all sorts of bugs preventing 1436C<$count> is C<undef>, as the kernel has all sorts of bugs preventing
1438it to return all extents of a range for files with large number of 1437it to return all extents of a range for files with a large number of
1439extents. The code works around all these issues if C<$count> is undef. 1438extents. The code (only) works around all these issues if C<$count> is
1439C<undef>.
1440 1440
1441=item aio_group $callback->(...) 1441=item aio_group $callback->(...)
1442 1442
1443This is a very special aio request: Instead of doing something, it is a 1443This is a very special aio request: Instead of doing something, it is a
1444container for other aio requests, which is useful if you want to bundle 1444container for other aio requests, which is useful if you want to bundle
1557There are some caveats: when directories get renamed (or deleted), the 1557There are some caveats: when directories get renamed (or deleted), the
1558pathname string doesn't change, so will point to the new directory (or 1558pathname string doesn't change, so will point to the new directory (or
1559nowhere at all), while the directory fd, if available on the system, 1559nowhere at all), while the directory fd, if available on the system,
1560will still point to the original directory. Most functions accepting a 1560will still point to the original directory. Most functions accepting a
1561pathname will use the directory fd on newer systems, and the string on 1561pathname will use the directory fd on newer systems, and the string on
1562older systems. Some functions (such as realpath) will always rely on the 1562older systems. Some functions (such as C<aio_realpath>) will always rely on
1563string form of the pathname. 1563the string form of the pathname.
1564 1564
1565So this functionality is mainly useful to get some protection against 1565So this functionality is mainly useful to get some protection against
1566C<chdir>, to easily get an absolute path out of a relative path for future 1566C<chdir>, to easily get an absolute path out of a relative path for future
1567reference, and to speed up doing many operations in the same directory 1567reference, and to speed up doing many operations in the same directory
1568(e.g. when stat'ing all files in a directory). 1568(e.g. when stat'ing all files in a directory).
1960This is a very bad function to use in interactive programs because it 1960This is a very bad function to use in interactive programs because it
1961blocks, and a bad way to reduce concurrency because it is inexact: Better 1961blocks, and a bad way to reduce concurrency because it is inexact: Better
1962use an C<aio_group> together with a feed callback. 1962use an C<aio_group> together with a feed callback.
1963 1963
1964Its main use is in scripts without an event loop - when you want to stat 1964Its main use is in scripts without an event loop - when you want to stat
1965a lot of files, you can write somehting like this: 1965a lot of files, you can write something like this:
1966 1966
1967 IO::AIO::max_outstanding 32; 1967 IO::AIO::max_outstanding 32;
1968 1968
1969 for my $path (...) { 1969 for my $path (...) {
1970 aio_stat $path , ...; 1970 aio_stat $path , ...;
2015some "Advanced I/O" function not available to in Perl, without going the 2015some "Advanced I/O" function not available to in Perl, without going the
2016"Asynchronous I/O" route. Many of these have an asynchronous C<aio_*> 2016"Asynchronous I/O" route. Many of these have an asynchronous C<aio_*>
2017counterpart. 2017counterpart.
2018 2018
2019=over 4 2019=over 4
2020
2021=item $numfd = IO::AIO::get_fdlimit
2022
2023This function is I<EXPERIMENTAL> and subject to change.
2024
2025Tries to find the current file descriptor limit and returns it, or
2026C<undef> and sets C<$!> in case of an error. The limit is one larger than
2027the highest valid file descriptor number.
2028
2029=item IO::AIO::min_fdlimit [$numfd]
2030
2031This function is I<EXPERIMENTAL> and subject to change.
2032
2033Try to increase the current file descriptor limit(s) to at least C<$numfd>
2034by changing the soft or hard file descriptor resource limit. If C<$numfd>
2035is missing, it will try to set a very high limit, although this is not
2036recommended when you know the actual minimum that you require.
2037
2038If the limit cannot be raised enough, the function makes a best-effort
2039attempt to increase the limit as much as possible, using various
2040tricks, while still failing. You can query the resulting limit using
2041C<IO::AIO::get_fdlimit>.
2042
2043If an error occurs, returns C<undef> and sets C<$!>, otherwise returns
2044true.
2020 2045
2021=item IO::AIO::sendfile $ofh, $ifh, $offset, $count 2046=item IO::AIO::sendfile $ofh, $ifh, $offset, $count
2022 2047
2023Calls the C<eio_sendfile_sync> function, which is like C<aio_sendfile>, 2048Calls the C<eio_sendfile_sync> function, which is like C<aio_sendfile>,
2024but is blocking (this makes most sense if you know the input data is 2049but is blocking (this makes most sense if you know the input data is
2041=item IO::AIO::madvise $scalar, $offset, $len, $advice 2066=item IO::AIO::madvise $scalar, $offset, $len, $advice
2042 2067
2043Simply calls the C<posix_madvise> function (see its 2068Simply calls the C<posix_madvise> function (see its
2044manpage for details). The following advice constants are 2069manpage for details). The following advice constants are
2045available: C<IO::AIO::MADV_NORMAL>, C<IO::AIO::MADV_SEQUENTIAL>, 2070available: C<IO::AIO::MADV_NORMAL>, C<IO::AIO::MADV_SEQUENTIAL>,
2046C<IO::AIO::MADV_RANDOM>, C<IO::AIO::MADV_WILLNEED>, C<IO::AIO::MADV_DONTNEED>. 2071C<IO::AIO::MADV_RANDOM>, C<IO::AIO::MADV_WILLNEED>,
2072C<IO::AIO::MADV_DONTNEED>.
2073
2074If C<$offset> is negative, counts from the end. If C<$length> is negative,
2075the remaining length of the C<$scalar> is used. If possible, C<$length>
2076will be reduced to fit into the C<$scalar>.
2047 2077
2048On systems that do not implement C<posix_madvise>, this function returns 2078On systems that do not implement C<posix_madvise>, this function returns
2049ENOSYS, otherwise the return value of C<posix_madvise>. 2079ENOSYS, otherwise the return value of C<posix_madvise>.
2050 2080
2051=item IO::AIO::mprotect $scalar, $offset, $len, $protect 2081=item IO::AIO::mprotect $scalar, $offset, $len, $protect
2053Simply calls the C<mprotect> function on the preferably AIO::mmap'ed 2083Simply calls the C<mprotect> function on the preferably AIO::mmap'ed
2054$scalar (see its manpage for details). The following protect 2084$scalar (see its manpage for details). The following protect
2055constants are available: C<IO::AIO::PROT_NONE>, C<IO::AIO::PROT_READ>, 2085constants are available: C<IO::AIO::PROT_NONE>, C<IO::AIO::PROT_READ>,
2056C<IO::AIO::PROT_WRITE>, C<IO::AIO::PROT_EXEC>. 2086C<IO::AIO::PROT_WRITE>, C<IO::AIO::PROT_EXEC>.
2057 2087
2088If C<$offset> is negative, counts from the end. If C<$length> is negative,
2089the remaining length of the C<$scalar> is used. If possible, C<$length>
2090will be reduced to fit into the C<$scalar>.
2091
2058On systems that do not implement C<mprotect>, this function returns 2092On systems that do not implement C<mprotect>, this function returns
2059ENOSYS, otherwise the return value of C<mprotect>. 2093ENOSYS, otherwise the return value of C<mprotect>.
2060 2094
2061=item IO::AIO::mmap $scalar, $length, $prot, $flags, $fh[, $offset] 2095=item IO::AIO::mmap $scalar, $length, $prot, $flags, $fh[, $offset]
2062 2096
2063Memory-maps a file (or anonymous memory range) and attaches it to the 2097Memory-maps a file (or anonymous memory range) and attaches it to the
2064given C<$scalar>, which will act like a string scalar. Returns true on 2098given C<$scalar>, which will act like a string scalar. Returns true on
2065success, and false otherwise. 2099success, and false otherwise.
2066 2100
2101The scalar must exist, but its contents do not matter - this means you
2102cannot use a nonexistant array or hash element. When in doubt, C<undef>
2103the scalar first.
2104
2067The only operations allowed on the scalar are C<substr>/C<vec> that don't 2105The only operations allowed on the mmapped scalar are C<substr>/C<vec>,
2068change the string length, and most read-only operations such as copying it 2106which don't change the string length, and most read-only operations such
2069or searching it with regexes and so on. 2107as copying it or searching it with regexes and so on.
2070 2108
2071Anything else is unsafe and will, at best, result in memory leaks. 2109Anything else is unsafe and will, at best, result in memory leaks.
2072 2110
2073The memory map associated with the C<$scalar> is automatically removed 2111The memory map associated with the C<$scalar> is automatically removed
2074when the C<$scalar> is destroyed, or when the C<IO::AIO::mmap> or 2112when the C<$scalar> is undef'd or destroyed, or when the C<IO::AIO::mmap>
2075C<IO::AIO::munmap> functions are called. 2113or C<IO::AIO::munmap> functions are called on it.
2076 2114
2077This calls the C<mmap>(2) function internally. See your system's manual 2115This calls the C<mmap>(2) function internally. See your system's manual
2078page for details on the C<$length>, C<$prot> and C<$flags> parameters. 2116page for details on the C<$length>, C<$prot> and C<$flags> parameters.
2079 2117
2080The C<$length> must be larger than zero and smaller than the actual 2118The C<$length> must be larger than zero and smaller than the actual
2177 2215
2178Please refer to L<pipe2(2)> for more info on the C<$flags>, but at the 2216Please refer to L<pipe2(2)> for more info on the C<$flags>, but at the
2179time of this writing, C<IO::AIO::O_CLOEXEC>, C<IO::AIO::O_NONBLOCK> and 2217time of this writing, C<IO::AIO::O_CLOEXEC>, C<IO::AIO::O_NONBLOCK> and
2180C<IO::AIO::O_DIRECT> (Linux 3.4, for packet-based pipes) were supported. 2218C<IO::AIO::O_DIRECT> (Linux 3.4, for packet-based pipes) were supported.
2181 2219
2220Example: create a pipe race-free w.r.t. threads and fork:
2221
2222 my ($rfh, $wfh) = IO::AIO::pipe2 IO::AIO::O_CLOEXEC
2223 or die "pipe2: $!\n";
2224
2225=item $fh = IO::AIO::eventfd [$initval, [$flags]]
2226
2227This is a direct interface to the Linux L<eventfd(2)> system call. The
2228(unhelpful) defaults for C<$initval> and C<$flags> are C<0> for both.
2229
2230On success, the new eventfd filehandle is returned, otherwise returns
2231C<undef>. If the eventfd syscall is missing, fails with C<ENOSYS>.
2232
2233Please refer to L<eventfd(2)> for more info on this call.
2234
2235The following symbol flag values are available: C<IO::AIO::EFD_CLOEXEC>,
2236C<IO::AIO::EFD_NONBLOCK> and C<IO::AIO::EFD_SEMAPHORE> (Linux 2.6.30).
2237
2238Example: create a new eventfd filehandle:
2239
2240 $fh = IO::AIO::eventfd 0, IO::AIO::O_CLOEXEC
2241 or die "eventfd: $!\n";
2242
2243=item $fh = IO::AIO::timerfd_create $clockid[, $flags]
2244
2245This is a direct interface to the Linux L<timerfd_create(2)> system call. The
2246(unhelpful) default for C<$flags> is C<0>.
2247
2248On success, the new timerfd filehandle is returned, otherwise returns
2249C<undef>. If the eventfd syscall is missing, fails with C<ENOSYS>.
2250
2251Please refer to L<timerfd_create(2)> for more info on this call.
2252
2253The following C<$clockid> values are
2254available: C<IO::AIO::CLOCK_REALTIME>, C<IO::AIO::CLOCK_MONOTONIC>
2255C<IO::AIO::CLOCK_CLOCK_BOOTTIME> (Linux 3.15)
2256C<IO::AIO::CLOCK_CLOCK_REALTIME_ALARM> (Linux 3.11) and
2257C<IO::AIO::CLOCK_CLOCK_BOOTTIME_ALARM> (Linux 3.11).
2258
2259The following C<$flags> values are available (Linux
22602.6.27): C<IO::AIO::TFD_NONBLOCK> and C<IO::AIO::TFD_CLOEXEC>.
2261
2262Example: create a new timerfd and set it to one-second repeated alarms,
2263then wait for two alarms:
2264
2265 my $fh = IO::AIO::timerfd_create IO::AIO::CLOCK_BOOTTIME, IO::AIO::TFD_CLOEXEC
2266 or die "timerfd_create: $!\n";
2267
2268 defined IO::AIO::timerfd_settime $fh, 0, 1, 1
2269 or die "timerfd_settime: $!\n";
2270
2271 for (1..2) {
2272 8 == sysread $fh, my $buf, 8
2273 or die "timerfd read failure\n";
2274
2275 printf "number of expirations (likely 1): %d\n",
2276 unpack "Q", $buf;
2277 }
2278
2279=item ($cur_interval, $cur_value) = IO::AIO::timerfd_settime $fh, $flags, $new_interval, $nbw_value
2280
2281This is a direct interface to the Linux L<timerfd_settime(2)> system
2282call. Please refer to its manpage for more info on this call.
2283
2284The new itimerspec is specified using two (possibly fractional) second
2285values, C<$new_interval> and C<$new_value>).
2286
2287On success, the current interval and value are returned (as per
2288C<timerfd_gettime>). On failure, the empty list is returned.
2289
2290The following C<$flags> values are
2291available: C<IO::AIO::TFD_TIMER_ABSTIME> and
2292C<IO::AIO::TFD_TIMER_CANCEL_ON_SET>.
2293
2294See C<IO::AIO::timerfd_create> for a full example.
2295
2296=item ($cur_interval, $cur_value) = IO::AIO::timerfd_gettime $fh
2297
2298This is a direct interface to the Linux L<timerfd_gettime(2)> system
2299call. Please refer to its manpage for more info on this call.
2300
2301On success, returns the current values of interval and value for the given
2302timerfd (as potentially fractional second values). On failure, the empty
2303list is returned.
2304
2182=back 2305=back
2183 2306
2184=cut 2307=cut
2185 2308
2186min_parallel 8; 2309min_parallel 8;
2251the process will result in undefined behaviour. Calling it at any time 2374the process will result in undefined behaviour. Calling it at any time
2252will also result in any undefined (by POSIX) behaviour. 2375will also result in any undefined (by POSIX) behaviour.
2253 2376
2254=back 2377=back
2255 2378
2379=head2 LINUX-SPECIFIC CALLS
2380
2381When a call is documented as "linux-specific" then this means it
2382originated on GNU/Linux. C<IO::AIO> will usually try to autodetect the
2383availability and compatibility of such calls regardless of the platform
2384it is compiled on, so platforms such as FreeBSD which often implement
2385these calls will work. When in doubt, call them and see if they fail wth
2386C<ENOSYS>.
2387
2256=head2 MEMORY USAGE 2388=head2 MEMORY USAGE
2257 2389
2258Per-request usage: 2390Per-request usage:
2259 2391
2260Each aio request uses - depending on your architecture - around 100-200 2392Each aio request uses - depending on your architecture - around 100-200

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines