ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Linux-AIO/AIO.pm
(Generate patch)

Comparing Linux-AIO/AIO.pm (file contents):
Revision 1.3 by root, Tue Aug 14 23:25:39 2001 UTC vs.
Revision 1.10 by root, Mon Apr 1 20:30:08 2002 UTC

… …
21package Linux::AIO; 21package Linux::AIO;
22 22
23use base 'Exporter'; 23use base 'Exporter';
24 24
25BEGIN { 25BEGIN {
26 $VERSION = 0.001; 26 $VERSION = 0.011;
27 27
28 @EXPORT = qw(aio_read aio_write); 28 @EXPORT = qw(aio_read aio_write aio_open aio_close aio_stat aio_lstat);
29 @EXPORT_OK = qw(poll_fileno poll_cb min_parallel max_parallel nreqs); 29 @EXPORT_OK = qw(poll_fileno poll_cb min_parallel max_parallel nreqs);
30 30
31 require XSLoader; 31 require XSLoader;
32 XSLoader::load Linux::AIO, $VERSION; 32 XSLoader::load Linux::AIO, $VERSION;
33} 33}
… …
35=item Linux::AIO::min_parallel($nthreads) 35=item Linux::AIO::min_parallel($nthreads)
36 36
37Set the minimum number of AIO threads to $nthreads. You I<have> to call 37Set the minimum number of AIO threads to $nthreads. You I<have> to call
38this function with a positive number at leats once, otherwise no threads 38this function with a positive number at leats once, otherwise no threads
39will be started and you aio-operations will seem to hang. 39will be started and you aio-operations will seem to hang.
40
41=cut
42
43=item aio_read($fh,$offset,$length, $data,$dataoffset,$callback)
44aio_write($fh,$offset,$length, $data,$dataoffset,$callback)
45
46Reads or writes C<length> bytes from the specified C<fh> and C<offset>
47into the scalar given by C<data> and offset C<dataoffset> and calls the
48callback without the actual number of bytes read (or undef on error).
49 40
50=item $fileno = Linux::AIO::poll_fileno 41=item $fileno = Linux::AIO::poll_fileno
51 42
52Return the request result pipe filehandle. This filehandle must be polled 43Return the request result pipe filehandle. This filehandle must be polled
53for reading. If the pipe becomes readable you have to call C<poll_cb>. 44for reading. If the pipe becomes readable you have to call C<poll_cb>.
… …
66 57
67=item Linux::AIO::nreqs 58=item Linux::AIO::nreqs
68 59
69Returns the number of requests currently outstanding. 60Returns the number of requests currently outstanding.
70 61
62=item aio_open($pathname, $flags, $mode, $callback)
63
64Asynchronously open or create a file and call the callback with the
65filedescriptor.
66
67=item aio_close($fh, $callback)
68
69Asynchronously close a file and call the callback with the result code.
70
71=item aio_read($fh,$offset,$length, $data,$dataoffset,$callback)
72
73=item aio_write($fh,$offset,$length, $data,$dataoffset,$callback)
74
75Reads or writes C<length> bytes from the specified C<fh> and C<offset>
76into the scalar given by C<data> and offset C<dataoffset> and calls the
77callback without the actual number of bytes read (or undef on error).
78
79=item aio_stat($fh_or_path,$callback)
80
81=item aio_lstat($fh,$callback)
82
83Works like perl's C<stat> or C<lstat> in void context, i.e. the callback
84will be called after the stat and the results will be available using
85C<stat _> or C<-s _> etc...
86
87Currently, the stats are always 64-bit-stats, i.e. instead of returning an
88error when stat'ing a large file, the results will be silently truncated
89unless perl itself is compiled with large file support.
90
71=cut 91=cut
72 92
73END { 93END {
74 max_parallel 0; 94 max_parallel 0;
75} 95}
… …
80 100
81=head1 BUGS 101=head1 BUGS
82 102
83This module has not yet been extensively tested. Watch out! 103This module has not yet been extensively tested. Watch out!
84 104
105 - aio_stat/lstat are seriously missing here.
106
85=head1 SEE ALSO 107=head1 SEE ALSO
86 108
87L<Coro>. 109L<Coro>.
88 110
89=head1 AUTHOR 111=head1 AUTHOR

Diff Legend

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