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.300 by root, Sun Mar 10 12:11:46 2019 UTC vs.
Revision 1.314 by root, Sat Apr 9 19:34:05 2022 UTC

171use common::sense; 171use common::sense;
172 172
173use base 'Exporter'; 173use base 'Exporter';
174 174
175BEGIN { 175BEGIN {
176 our $VERSION = 4.71; 176 our $VERSION = 4.76;
177 177
178 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
179 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
180 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
181 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
278 IO::AIO::idle_timeout $seconds 278 IO::AIO::idle_timeout $seconds
279 IO::AIO::max_outstanding $maxreqs 279 IO::AIO::max_outstanding $maxreqs
280 IO::AIO::nreqs 280 IO::AIO::nreqs
281 IO::AIO::nready 281 IO::AIO::nready
282 IO::AIO::npending 282 IO::AIO::npending
283 IO::AIO::reinit
284
283 $nfd = IO::AIO::get_fdlimit [EXPERIMENTAL] 285 $nfd = IO::AIO::get_fdlimit
284 IO::AIO::min_fdlimit $nfd [EXPERIMENTAL] 286 IO::AIO::min_fdlimit $nfd
285 287
286 IO::AIO::sendfile $ofh, $ifh, $offset, $count 288 IO::AIO::sendfile $ofh, $ifh, $offset, $count
287 IO::AIO::fadvise $fh, $offset, $len, $advice 289 IO::AIO::fadvise $fh, $offset, $len, $advice
290
288 IO::AIO::mmap $scalar, $length, $prot, $flags[, $fh[, $offset]] 291 IO::AIO::mmap $scalar, $length, $prot, $flags[, $fh[, $offset]]
289 IO::AIO::munmap $scalar 292 IO::AIO::munmap $scalar
290 IO::AIO::mremap $scalar, $new_length, $flags[, $new_address] 293 IO::AIO::mremap $scalar, $new_length, $flags[, $new_address]
291 IO::AIO::madvise $scalar, $offset, $length, $advice 294 IO::AIO::madvise $scalar, $offset, $length, $advice
292 IO::AIO::mprotect $scalar, $offset, $length, $protect 295 IO::AIO::mprotect $scalar, $offset, $length, $protect
293 IO::AIO::munlock $scalar, $offset = 0, $length = undef 296 IO::AIO::munlock $scalar, $offset = 0, $length = undef
294 IO::AIO::munlockall 297 IO::AIO::munlockall
298
299 # stat extensions
300 $counter = IO::AIO::st_gen
301 $seconds = IO::AIO::st_atime, IO::AIO::st_mtime, IO::AIO::st_ctime, IO::AIO::st_btime
302 ($atime, $mtime, $ctime, $btime, ...) = IO::AIO::st_xtime
303 $nanoseconds = IO::AIO::st_atimensec, IO::AIO::st_mtimensec, IO::AIO::st_ctimensec, IO::AIO::st_btimensec
304 $seconds = IO::AIO::st_btimesec
305 ($atime, $mtime, $ctime, $btime, ...) = IO::AIO::st_xtimensec
306
307 # very much unportable syscalls
308 IO::AIO::accept4 $r_fh, $sockaddr, $sockaddr_len, $flags
309 IO::AIO::splice $r_fh, $r_off, $w_fh, $w_off, $length, $flags
310 IO::AIO::tee $r_fh, $w_fh, $length, $flags
311 $actual_size = IO::AIO::pipesize $r_fh[, $new_size]
312 ($rfh, $wfh) = IO::AIO::pipe2 [$flags]
313 $fh = IO::AIO::memfd_create $pathname[, $flags]
314 $fh = IO::AIO::eventfd [$initval, [$flags]]
315 $fh = IO::AIO::timerfd_create $clockid[, $flags]
316 ($cur_interval, $cur_value) = IO::AIO::timerfd_settime $fh, $flags, $new_interval, $nbw_value
317 ($cur_interval, $cur_value) = IO::AIO::timerfd_gettime $fh
295 318
296=head2 API NOTES 319=head2 API NOTES
297 320
298All the C<aio_*> calls are more or less thin wrappers around the syscall 321All the C<aio_*> calls are more or less thin wrappers around the syscall
299with the same name (sans C<aio_>). The arguments are similar or identical, 322with the same name (sans C<aio_>). The arguments are similar or identical,
1286So in general, you should only use these calls for things that do 1309So in general, you should only use these calls for things that do
1287(filesystem) I/O, not for things that wait for other events (network, 1310(filesystem) I/O, not for things that wait for other events (network,
1288other processes), although if you are careful and know what you are doing, 1311other processes), although if you are careful and know what you are doing,
1289you still can. 1312you still can.
1290 1313
1291The following constants are available (missing ones are, as usual C<0>): 1314The following constants are available and can be used for normal C<ioctl>
1315and C<fcntl> as well (missing ones are, as usual C<0>):
1292 1316
1293C<F_DUPFD_CLOEXEC>, 1317C<F_DUPFD_CLOEXEC>,
1294 1318
1295C<F_OFD_GETLK>, C<F_OFD_SETLK>, C<F_OFD_GETLKW>, 1319C<F_OFD_GETLK>, C<F_OFD_SETLK>, C<F_OFD_GETLKW>,
1296 1320
1297C<FIFREEZE>, C<FITHAW>, C<FITRIM>, C<FICLONE>, C<FICLONERANGE>, C<FIDEDUPERANGE>. 1321C<FIFREEZE>, C<FITHAW>, C<FITRIM>, C<FICLONE>, C<FICLONERANGE>, C<FIDEDUPERANGE>.
1322
1323C<F_ADD_SEALS>, C<F_GET_SEALS>, C<F_SEAL_SEAL>, C<F_SEAL_SHRINK>, C<F_SEAL_GROW> and
1324C<F_SEAL_WRITE>.
1298 1325
1299C<FS_IOC_GETFLAGS>, C<FS_IOC_SETFLAGS>, C<FS_IOC_GETVERSION>, C<FS_IOC_SETVERSION>, 1326C<FS_IOC_GETFLAGS>, C<FS_IOC_SETFLAGS>, C<FS_IOC_GETVERSION>, C<FS_IOC_SETVERSION>,
1300C<FS_IOC_FIEMAP>. 1327C<FS_IOC_FIEMAP>.
1301 1328
1302C<FS_IOC_FSGETXATTR>, C<FS_IOC_FSSETXATTR>, C<FS_IOC_SET_ENCRYPTION_POLICY>, 1329C<FS_IOC_FSGETXATTR>, C<FS_IOC_FSSETXATTR>, C<FS_IOC_SET_ENCRYPTION_POLICY>,
1652C<aio_wd> callback, as future requests using the value will fail in the 1679C<aio_wd> callback, as future requests using the value will fail in the
1653expected way. 1680expected way.
1654 1681
1655=item IO::AIO::CWD 1682=item IO::AIO::CWD
1656 1683
1657This is a compiletime constant (object) that represents the process 1684This is a compile time constant (object) that represents the process
1658current working directory. 1685current working directory.
1659 1686
1660Specifying this object as working directory object for a pathname is as if 1687Specifying this object as working directory object for a pathname is as if
1661the pathname would be specified directly, without a directory object. For 1688the pathname would be specified directly, without a directory object. For
1662example, these calls are functionally identical: 1689example, these calls are functionally identical:
2034longer exceeded. 2061longer exceeded.
2035 2062
2036In other words, this setting does not enforce a queue limit, but can be 2063In other words, this setting does not enforce a queue limit, but can be
2037used to make poll functions block if the limit is exceeded. 2064used to make poll functions block if the limit is exceeded.
2038 2065
2039This is a very bad function to use in interactive programs because it 2066This is a bad function to use in interactive programs because it blocks,
2040blocks, and a bad way to reduce concurrency because it is inexact: Better 2067and a bad way to reduce concurrency because it is inexact. If you need to
2068issue many requests without being able to call a poll function on demand,
2041use an C<aio_group> together with a feed callback. 2069it is better to use an C<aio_group> together with a feed callback.
2042 2070
2043Its main use is in scripts without an event loop - when you want to stat 2071Its main use is in scripts without an event loop - when you want to stat a
2044a lot of files, you can write something like this: 2072lot of files, you can write something like this:
2045 2073
2046 IO::AIO::max_outstanding 32; 2074 IO::AIO::max_outstanding 32;
2047 2075
2048 for my $path (...) { 2076 for my $path (...) {
2049 aio_stat $path , ...; 2077 aio_stat $path , ...;
2050 IO::AIO::poll_cb; 2078 IO::AIO::poll_cb;
2051 } 2079 }
2052 2080
2053 IO::AIO::flush; 2081 IO::AIO::flush;
2054 2082
2055The call to C<poll_cb> inside the loop will normally return instantly, but 2083The call to C<poll_cb> inside the loop will normally return instantly,
2056as soon as more thna C<32> reqeusts are in-flight, it will block until 2084allowing the loop to progress, but as soon as more than C<32> requests
2057some requests have been handled. This keeps the loop from pushing a large 2085are in-flight, it will block until some requests have been handled. This
2058number of C<aio_stat> requests onto the queue. 2086keeps the loop from pushing a large number of C<aio_stat> requests onto
2087the queue (which, with many paths to stat, can use up a lot of memory).
2059 2088
2060The default value for C<max_outstanding> is very large, so there is no 2089The default value for C<max_outstanding> is very large, so there is no
2061practical limit on the number of outstanding requests. 2090practical limit on the number of outstanding requests.
2062 2091
2063=back 2092=back
2122for times around now - see the I<nsec> function family, below, for full 2151for times around now - see the I<nsec> function family, below, for full
2123accuracy. 2152accuracy.
2124 2153
2125File birth time is only available when the OS and perl support it (on 2154File birth time is only available when the OS and perl support it (on
2126FreeBSD and NetBSD at the time of this writing, although support is 2155FreeBSD and NetBSD at the time of this writing, although support is
2127adaptive, so if your OS/perl gains support, IO::AIO can take avdantage of 2156adaptive, so if your OS/perl gains support, IO::AIO can take advantage of
2128it). On systems where it isn't available, C<0> is currently returned, but 2157it). On systems where it isn't available, C<0> is currently returned, but
2129this might change to C<undef> in a future version. 2158this might change to C<undef> in a future version.
2130 2159
2131=item ($atime, $mtime, $ctime, $btime, ...) = IO::AIO::st_xtime 2160=item ($atime, $mtime, $ctime, $btime, ...) = IO::AIO::st_xtime
2132 2161
2193 2222
2194=over 4 2223=over 4
2195 2224
2196=item $numfd = IO::AIO::get_fdlimit 2225=item $numfd = IO::AIO::get_fdlimit
2197 2226
2198This function is I<EXPERIMENTAL> and subject to change.
2199
2200Tries to find the current file descriptor limit and returns it, or 2227Tries to find the current file descriptor limit and returns it, or
2201C<undef> and sets C<$!> in case of an error. The limit is one larger than 2228C<undef> and sets C<$!> in case of an error. The limit is one larger than
2202the highest valid file descriptor number. 2229the highest valid file descriptor number.
2203 2230
2204=item IO::AIO::min_fdlimit [$numfd] 2231=item IO::AIO::min_fdlimit [$numfd]
2205
2206This function is I<EXPERIMENTAL> and subject to change.
2207 2232
2208Try to increase the current file descriptor limit(s) to at least C<$numfd> 2233Try to increase the current file descriptor limit(s) to at least C<$numfd>
2209by changing the soft or hard file descriptor resource limit. If C<$numfd> 2234by changing the soft or hard file descriptor resource limit. If C<$numfd>
2210is missing, it will try to set a very high limit, although this is not 2235is missing, it will try to set a very high limit, although this is not
2211recommended when you know the actual minimum that you require. 2236recommended when you know the actual minimum that you require.
2306C<IO::AIO::MAP_POPULATE>, 2331C<IO::AIO::MAP_POPULATE>,
2307C<IO::AIO::MAP_NONBLOCK>, 2332C<IO::AIO::MAP_NONBLOCK>,
2308C<IO::AIO::MAP_FIXED>, 2333C<IO::AIO::MAP_FIXED>,
2309C<IO::AIO::MAP_GROWSDOWN>, 2334C<IO::AIO::MAP_GROWSDOWN>,
2310C<IO::AIO::MAP_32BIT>, 2335C<IO::AIO::MAP_32BIT>,
2311C<IO::AIO::MAP_HUGETLB> or 2336C<IO::AIO::MAP_HUGETLB>,
2312C<IO::AIO::MAP_STACK>. 2337C<IO::AIO::MAP_STACK>,
2338C<IO::AIO::MAP_FIXED_NOREPLACE>,
2339C<IO::AIO::MAP_SHARED_VALIDATE>,
2340C<IO::AIO::MAP_SYNC> or
2341C<IO::AIO::MAP_UNINITIALIZED>.
2313 2342
2314If C<$fh> is C<undef>, then a file descriptor of C<-1> is passed. 2343If C<$fh> is C<undef>, then a file descriptor of C<-1> is passed.
2315 2344
2316C<$offset> is the offset from the start of the file - it generally must be 2345C<$offset> is the offset from the start of the file - it generally must be
2317a multiple of C<IO::AIO::PAGESIZE> and defaults to C<0>. 2346a multiple of C<IO::AIO::PAGESIZE> and defaults to C<0>.
2370 2399
2371Calls the C<munlockall> function. 2400Calls the C<munlockall> function.
2372 2401
2373On systems that do not implement C<munlockall>, this function returns 2402On systems that do not implement C<munlockall>, this function returns
2374ENOSYS, otherwise the return value of C<munlockall>. 2403ENOSYS, otherwise the return value of C<munlockall>.
2404
2405=item $fh = IO::AIO::accept4 $r_fh, $sockaddr, $sockaddr_maxlen, $flags
2406
2407Uses the GNU/Linux C<accept4(2)> syscall, if available, to accept a socket
2408and return the new file handle on success, or sets C<$!> and returns
2409C<undef> on error.
2410
2411The remote name of the new socket will be stored in C<$sockaddr>, which
2412will be extended to allow for at least C<$sockaddr_maxlen> octets. If the
2413socket name does not fit into C<$sockaddr_maxlen> octets, this is signaled
2414by returning a longer string in C<$sockaddr>, which might or might not be
2415truncated.
2416
2417To accept name-less sockets, use C<undef> for C<$sockaddr> and C<0> for
2418C<$sockaddr_maxlen>.
2419
2420The main reasons to use this syscall rather than portable C<accept(2)>
2421are that you can specify C<SOCK_NONBLOCK> and/or C<SOCK_CLOEXEC>
2422flags and you can accept name-less sockets by specifying C<0> for
2423C<$sockaddr_maxlen>, which is sadly not possible with perl's interface to
2424C<accept>.
2375 2425
2376=item IO::AIO::splice $r_fh, $r_off, $w_fh, $w_off, $length, $flags 2426=item IO::AIO::splice $r_fh, $r_off, $w_fh, $w_off, $length, $flags
2377 2427
2378Calls the GNU/Linux C<splice(2)> syscall, if available. If C<$r_off> or 2428Calls the GNU/Linux C<splice(2)> syscall, if available. If C<$r_off> or
2379C<$w_off> are C<undef>, then C<NULL> is passed for these, otherwise they 2429C<$w_off> are C<undef>, then C<NULL> is passed for these, otherwise they
2423Example: create a pipe race-free w.r.t. threads and fork: 2473Example: create a pipe race-free w.r.t. threads and fork:
2424 2474
2425 my ($rfh, $wfh) = IO::AIO::pipe2 IO::AIO::O_CLOEXEC 2475 my ($rfh, $wfh) = IO::AIO::pipe2 IO::AIO::O_CLOEXEC
2426 or die "pipe2: $!\n"; 2476 or die "pipe2: $!\n";
2427 2477
2478=item $fh = IO::AIO::memfd_create $pathname[, $flags]
2479
2480This is a direct interface to the Linux L<memfd_create(2)> system
2481call. The (unhelpful) default for C<$flags> is C<0>, but your default
2482should be C<IO::AIO::MFD_CLOEXEC>.
2483
2484On success, the new memfd filehandle is returned, otherwise returns
2485C<undef>. If the memfd_create syscall is missing, fails with C<ENOSYS>.
2486
2487Please refer to L<memfd_create(2)> for more info on this call.
2488
2489The following C<$flags> values are available: C<IO::AIO::MFD_CLOEXEC>,
2490C<IO::AIO::MFD_ALLOW_SEALING>, C<IO::AIO::MFD_HUGETLB>,
2491C<IO::AIO::MFD_HUGETLB_2MB> and C<IO::AIO::MFD_HUGETLB_1GB>.
2492
2493Example: create a new memfd.
2494
2495 my $fh = IO::AIO::memfd_create "somenameforprocfd", IO::AIO::MFD_CLOEXEC
2496 or die "memfd_create: $!\n";
2497
2498=item $fh = IO::AIO::pidfd_open $pid[, $flags]
2499
2500This is an interface to the Linux L<pidfd_open(2)> system call. The
2501default for C<$flags> is C<0>.
2502
2503On success, a new pidfd filehandle is returned (that is already set to
2504close-on-exec), otherwise returns C<undef>. If the syscall is missing,
2505fails with C<ENOSYS>.
2506
2507Example: open pid 6341 as pidfd.
2508
2509 my $fh = IO::AIO::pidfd_open 6341
2510 or die "pidfd_open: $!\n";
2511
2512=item $status = IO::AIO::pidfd_send_signal $pidfh, $signal[, $siginfo[, $flags]]
2513
2514This is an interface to the Linux L<pidfd_send_signal> system call. The
2515default for C<$siginfo> is C<undef> and the default for C<$flags> is C<0>.
2516
2517Returns the system call status. If the syscall is missing, fails with
2518C<ENOSYS>.
2519
2520When specified, C<$siginfo> must be a reference to a hash with one or more
2521of the following members:
2522
2523=over
2524
2525=item code - the C<si_code> member
2526
2527=item pid - the C<si_pid> member
2528
2529=item uid - the C<si_uid> member
2530
2531=item value_int - the C<si_value.sival_int> member
2532
2533=item value_ptr - the C<si_value.sival_ptr> member, specified as an integer
2534
2535=back
2536
2537Example: send a SIGKILL to the specified process.
2538
2539 my $status = IO::AIO::pidfd_send_signal $pidfh, 9, undef
2540 and die "pidfd_send_signal: $!\n";
2541
2542Example: send a SIGKILL to the specified process with extra data.
2543
2544 my $status = IO::AIO::pidfd_send_signal $pidfh, 9, { code => -1, value_int => 7 }
2545 and die "pidfd_send_signal: $!\n";
2546
2547=item $fh = IO::AIO::pidfd_getfd $pidfh, $targetfd[, $flags]
2548
2549This is an interface to the Linux L<pidfd_getfd> system call. The default
2550for C<$flags> is C<0>.
2551
2552On success, returns a dup'ed copy of the target file descriptor (specified
2553as an integer) returned (that is already set to close-on-exec), otherwise
2554returns C<undef>. If the syscall is missing, fails with C<ENOSYS>.
2555
2556Example: get a copy of standard error of another process and print soemthing to it.
2557
2558 my $errfh = IO::AIO::pidfd_getfd $pidfh, 2
2559 or die "pidfd_getfd: $!\n";
2560 print $errfh "stderr\n";
2561
2428=item $fh = IO::AIO::eventfd [$initval, [$flags]] 2562=item $fh = IO::AIO::eventfd [$initval, [$flags]]
2429 2563
2430This is a direct interface to the Linux L<eventfd(2)> system call. The 2564This is a direct interface to the Linux L<eventfd(2)> system call. The
2431(unhelpful) defaults for C<$initval> and C<$flags> are C<0> for both. 2565(unhelpful) defaults for C<$initval> and C<$flags> are C<0> for both.
2432 2566
2438The following symbol flag values are available: C<IO::AIO::EFD_CLOEXEC>, 2572The following symbol flag values are available: C<IO::AIO::EFD_CLOEXEC>,
2439C<IO::AIO::EFD_NONBLOCK> and C<IO::AIO::EFD_SEMAPHORE> (Linux 2.6.30). 2573C<IO::AIO::EFD_NONBLOCK> and C<IO::AIO::EFD_SEMAPHORE> (Linux 2.6.30).
2440 2574
2441Example: create a new eventfd filehandle: 2575Example: create a new eventfd filehandle:
2442 2576
2443 $fh = IO::AIO::eventfd 0, IO::AIO::O_CLOEXEC 2577 $fh = IO::AIO::eventfd 0, IO::AIO::EFD_CLOEXEC
2444 or die "eventfd: $!\n"; 2578 or die "eventfd: $!\n";
2445 2579
2446=item $fh = IO::AIO::timerfd_create $clockid[, $flags] 2580=item $fh = IO::AIO::timerfd_create $clockid[, $flags]
2447 2581
2448This is a direct interface to the Linux L<timerfd_create(2)> system call. The 2582This is a direct interface to the Linux L<timerfd_create(2)> system
2449(unhelpful) default for C<$flags> is C<0>. 2583call. The (unhelpful) default for C<$flags> is C<0>, but your default
2584should be C<IO::AIO::TFD_CLOEXEC>.
2450 2585
2451On success, the new timerfd filehandle is returned, otherwise returns 2586On success, the new timerfd filehandle is returned, otherwise returns
2452C<undef>. If the eventfd syscall is missing, fails with C<ENOSYS>. 2587C<undef>. If the timerfd_create syscall is missing, fails with C<ENOSYS>.
2453 2588
2454Please refer to L<timerfd_create(2)> for more info on this call. 2589Please refer to L<timerfd_create(2)> for more info on this call.
2455 2590
2456The following C<$clockid> values are 2591The following C<$clockid> values are
2457available: C<IO::AIO::CLOCK_REALTIME>, C<IO::AIO::CLOCK_MONOTONIC> 2592available: C<IO::AIO::CLOCK_REALTIME>, C<IO::AIO::CLOCK_MONOTONIC>
2623known issue, rather than a bug. 2758known issue, rather than a bug.
2624 2759
2625=head1 SEE ALSO 2760=head1 SEE ALSO
2626 2761
2627L<AnyEvent::AIO> for easy integration into event loops, L<Coro::AIO> for a 2762L<AnyEvent::AIO> for easy integration into event loops, L<Coro::AIO> for a
2628more natural syntax. 2763more natural syntax and L<IO::FDPass> for file descriptor passing.
2629 2764
2630=head1 AUTHOR 2765=head1 AUTHOR
2631 2766
2632 Marc Lehmann <schmorp@schmorp.de> 2767 Marc Lehmann <schmorp@schmorp.de>
2633 http://home.schmorp.de/ 2768 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines