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.187 by root, Fri Feb 11 00:05:17 2011 UTC vs.
Revision 1.193 by root, Thu May 26 04:15:37 2011 UTC

168use common::sense; 168use common::sense;
169 169
170use base 'Exporter'; 170use base 'Exporter';
171 171
172BEGIN { 172BEGIN {
173 our $VERSION = '3.72'; 173 our $VERSION = '3.8';
174 174
175 our @AIO_REQ = qw(aio_sendfile aio_read aio_write aio_open aio_close 175 our @AIO_REQ = qw(aio_sendfile aio_read aio_write aio_open aio_close
176 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir aio_readdirx 176 aio_stat aio_lstat aio_unlink aio_rmdir aio_readdir aio_readdirx
177 aio_scandir aio_symlink aio_readlink aio_sync aio_fsync 177 aio_scandir aio_symlink aio_readlink aio_sync aio_fsync
178 aio_fdatasync aio_sync_file_range aio_pathsync aio_readahead 178 aio_fdatasync aio_sync_file_range aio_pathsync aio_readahead
182 aio_msync aio_mtouch aio_mlock aio_mlockall 182 aio_msync aio_mtouch aio_mlock aio_mlockall
183 aio_statvfs); 183 aio_statvfs);
184 184
185 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice)); 185 our @EXPORT = (@AIO_REQ, qw(aioreq_pri aioreq_nice));
186 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush 186 our @EXPORT_OK = qw(poll_fileno poll_cb poll_wait flush
187 min_parallel max_parallel max_idle 187 min_parallel max_parallel max_idle idle_timeout
188 nreqs nready npending nthreads 188 nreqs nready npending nthreads
189 max_poll_time max_poll_reqs 189 max_poll_time max_poll_reqs
190 sendfile fadvise madvise 190 sendfile fadvise madvise
191 mmap munmap munlock munlockall); 191 mmap munmap munlock munlockall);
192 192
258 IO::AIO::max_poll_reqs $nreqs 258 IO::AIO::max_poll_reqs $nreqs
259 IO::AIO::max_poll_time $seconds 259 IO::AIO::max_poll_time $seconds
260 IO::AIO::min_parallel $nthreads 260 IO::AIO::min_parallel $nthreads
261 IO::AIO::max_parallel $nthreads 261 IO::AIO::max_parallel $nthreads
262 IO::AIO::max_idle $nthreads 262 IO::AIO::max_idle $nthreads
263 IO::AIO::idle_timeout $seconds
263 IO::AIO::max_outstanding $maxreqs 264 IO::AIO::max_outstanding $maxreqs
264 IO::AIO::nreqs 265 IO::AIO::nreqs
265 IO::AIO::nready 266 IO::AIO::nready
266 IO::AIO::npending 267 IO::AIO::npending
267 268
667 668
668=over 4 669=over 4
669 670
670=item IO::AIO::READDIR_DENTS 671=item IO::AIO::READDIR_DENTS
671 672
672When this flag is off, then the callback gets an arrayref with of names 673When this flag is off, then the callback gets an arrayref consisting of
673only (as with C<aio_readdir>), otherwise it gets an arrayref with 674names only (as with C<aio_readdir>), otherwise it gets an arrayref with
674C<[$name, $type, $inode]> arrayrefs, each describing a single directory 675C<[$name, $type, $inode]> arrayrefs, each describing a single directory
675entry in more detail. 676entry in more detail.
676 677
677C<$name> is the name of the entry. 678C<$name> is the name of the entry.
678 679
691systems that do not deliver the inode information. 692systems that do not deliver the inode information.
692 693
693=item IO::AIO::READDIR_DIRS_FIRST 694=item IO::AIO::READDIR_DIRS_FIRST
694 695
695When this flag is set, then the names will be returned in an order where 696When this flag is set, then the names will be returned in an order where
696likely directories come first. This is useful when you need to quickly 697likely directories come first, in optimal stat order. This is useful when
697find directories, or you want to find all directories while avoiding to 698you need to quickly find directories, or you want to find all directories
698stat() each entry. 699while avoiding to stat() each entry.
699 700
700If the system returns type information in readdir, then this is used 701If the system returns type information in readdir, then this is used
701to find directories directly. Otherwise, likely directories are files 702to find directories directly. Otherwise, likely directories are names
702beginning with ".", or otherwise files with no dots, of which files with 703beginning with ".", or otherwise names with no dots, of which names with
703short names are tried first. 704short names are tried first.
704 705
705=item IO::AIO::READDIR_STAT_ORDER 706=item IO::AIO::READDIR_STAT_ORDER
706 707
707When this flag is set, then the names will be returned in an order 708When this flag is set, then the names will be returned in an order
1405 1406
1406See C<poll_cb> for an example. 1407See C<poll_cb> for an example.
1407 1408
1408=item IO::AIO::poll_cb 1409=item IO::AIO::poll_cb
1409 1410
1410Process some outstanding events on the result pipe. You have to call this 1411Process some outstanding events on the result pipe. You have to call
1411regularly. Returns C<0> if all events could be processed, or C<-1> if it 1412this regularly. Returns C<0> if all events could be processed (or there
1412returned earlier for whatever reason. Returns immediately when no events 1413were no events to process), or C<-1> if it returned earlier for whatever
1413are outstanding. The amount of events processed depends on the settings of 1414reason. Returns immediately when no events are outstanding. The amount of
1414C<IO::AIO::max_poll_req> and C<IO::AIO::max_poll_time>. 1415events processed depends on the settings of C<IO::AIO::max_poll_req> and
1416C<IO::AIO::max_poll_time>.
1415 1417
1416If not all requests were processed for whatever reason, the filehandle 1418If not all requests were processed for whatever reason, the filehandle
1417will still be ready when C<poll_cb> returns, so normally you don't have to 1419will still be ready when C<poll_cb> returns, so normally you don't have to
1418do anything special to have it called later. 1420do anything special to have it called later.
1421
1422Apart from calling C<IO::AIO::poll_cb> when the event filehandle becomes
1423ready, it can be beneficial to call this function from loops which submit
1424a lot of requests, to make sure the results get processed when they become
1425available and not just when the loop is finished and the event loop takes
1426over again. This function returns very fast when there are no outstanding
1427requests.
1419 1428
1420Example: Install an Event watcher that automatically calls 1429Example: Install an Event watcher that automatically calls
1421IO::AIO::poll_cb with high priority (more examples can be found in the 1430IO::AIO::poll_cb with high priority (more examples can be found in the
1422SYNOPSIS section, at the top of this document): 1431SYNOPSIS section, at the top of this document):
1423 1432
1525 1534
1526Under normal circumstances you don't need to call this function. 1535Under normal circumstances you don't need to call this function.
1527 1536
1528=item IO::AIO::max_idle $nthreads 1537=item IO::AIO::max_idle $nthreads
1529 1538
1530Limit the number of threads (default: 4) that are allowed to idle (i.e., 1539Limit the number of threads (default: 4) that are allowed to idle
1531threads that did not get a request to process within 10 seconds). That 1540(i.e., threads that did not get a request to process within the idle
1532means if a thread becomes idle while C<$nthreads> other threads are also 1541timeout (default: 10 seconds). That means if a thread becomes idle while
1533idle, it will free its resources and exit. 1542C<$nthreads> other threads are also idle, it will free its resources and
1543exit.
1534 1544
1535This is useful when you allow a large number of threads (e.g. 100 or 1000) 1545This is useful when you allow a large number of threads (e.g. 100 or 1000)
1536to allow for extremely high load situations, but want to free resources 1546to allow for extremely high load situations, but want to free resources
1537under normal circumstances (1000 threads can easily consume 30MB of RAM). 1547under normal circumstances (1000 threads can easily consume 30MB of RAM).
1538 1548
1539The default is probably ok in most situations, especially if thread 1549The default is probably ok in most situations, especially if thread
1540creation is fast. If thread creation is very slow on your system you might 1550creation is fast. If thread creation is very slow on your system you might
1541want to use larger values. 1551want to use larger values.
1552
1553=item IO::AIO::idle_timeout $seconds
1554
1555Sets the minimum idle timeout (default 10) after which worker threads are
1556allowed to exit. SEe C<IO::AIO::max_idle>.
1542 1557
1543=item IO::AIO::max_outstanding $maxreqs 1558=item IO::AIO::max_outstanding $maxreqs
1544 1559
1545This is a very bad function to use in interactive programs because it 1560This is a very bad function to use in interactive programs because it
1546blocks, and a bad way to reduce concurrency because it is inexact: Better 1561blocks, and a bad way to reduce concurrency because it is inexact: Better

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines