ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libeio/eio.pod
Revision: 1.10
Committed: Sun Jun 5 23:22:04 2011 UTC (12 years, 11 months ago) by root
Branch: MAIN
Changes since 1.9: +37 -16 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 root 1.1 =head1 NAME
2    
3     libeio - truly asynchronous POSIX I/O
4    
5     =head1 SYNOPSIS
6    
7     #include <eio.h>
8    
9     =head1 DESCRIPTION
10    
11     The newest version of this document is also available as an html-formatted
12     web page you might find easier to navigate when reading it for the first
13     time: L<http://pod.tst.eu/http://cvs.schmorp.de/libeio/eio.pod>.
14    
15     Note that this library is a by-product of the C<IO::AIO> perl
16 sf-exg 1.6 module, and many of the subtler points regarding requests lifetime
17 root 1.1 and so on are only documented in its documentation at the
18     moment: L<http://pod.tst.eu/http://cvs.schmorp.de/IO-AIO/AIO.pm>.
19    
20     =head2 FEATURES
21    
22     This library provides fully asynchronous versions of most POSIX functions
23 sf-exg 1.6 dealing with I/O. Unlike most asynchronous libraries, this not only
24 root 1.1 includes C<read> and C<write>, but also C<open>, C<stat>, C<unlink> and
25     similar functions, as well as less rarely ones such as C<mknod>, C<futime>
26     or C<readlink>.
27    
28     It also offers wrappers around C<sendfile> (Solaris, Linux, HP-UX and
29     FreeBSD, with emulation on other platforms) and C<readahead> (Linux, with
30     emulation elsewhere>).
31    
32 root 1.5 The goal is to enable you to write fully non-blocking programs. For
33 root 1.1 example, in a game server, you would not want to freeze for a few seconds
34     just because the server is running a backup and you happen to call
35     C<readdir>.
36    
37     =head2 TIME REPRESENTATION
38    
39     Libeio represents time as a single floating point number, representing the
40     (fractional) number of seconds since the (POSIX) epoch (somewhere near
41     the beginning of 1970, details are complicated, don't ask). This type is
42 sf-exg 1.6 called C<eio_tstamp>, but it is guaranteed to be of type C<double> (or
43 root 1.1 better), so you can freely use C<double> yourself.
44    
45     Unlike the name component C<stamp> might indicate, it is also used for
46     time differences throughout libeio.
47    
48     =head2 FORK SUPPORT
49    
50     Calling C<fork ()> is fully supported by this module. It is implemented in these steps:
51    
52     1. wait till all requests in "execute" state have been handled
53     (basically requests that are already handed over to the kernel).
54     2. fork
55     3. in the parent, continue business as usual, done
56     4. in the child, destroy all ready and pending requests and free the
57     memory used by the worker threads. This gives you a fully empty
58     libeio queue.
59    
60 root 1.7 Note, however, since libeio does use threads, thr above guarantee doesn't
61     cover your libc, for example, malloc and other libc functions are not
62     fork-safe, so there is very little you can do after a fork, and in fatc,
63     the above might crash, and thus change.
64    
65 root 1.1 =head1 INITIALISATION/INTEGRATION
66    
67     Before you can call any eio functions you first have to initialise the
68     library. The library integrates into any event loop, but can also be used
69     without one, including in polling mode.
70    
71     You have to provide the necessary glue yourself, however.
72    
73     =over 4
74    
75     =item int eio_init (void (*want_poll)(void), void (*done_poll)(void))
76    
77     This function initialises the library. On success it returns C<0>, on
78     failure it returns C<-1> and sets C<errno> appropriately.
79    
80     It accepts two function pointers specifying callbacks as argument, both of
81     which can be C<0>, in which case the callback isn't called.
82    
83     =item want_poll callback
84    
85     The C<want_poll> callback is invoked whenever libeio wants attention (i.e.
86     it wants to be polled by calling C<eio_poll>). It is "edge-triggered",
87     that is, it will only be called once when eio wants attention, until all
88     pending requests have been handled.
89    
90     This callback is called while locks are being held, so I<you must
91     not call any libeio functions inside this callback>. That includes
92     C<eio_poll>. What you should do is notify some other thread, or wake up
93     your event loop, and then call C<eio_poll>.
94    
95     =item done_poll callback
96    
97     This callback is invoked when libeio detects that all pending requests
98     have been handled. It is "edge-triggered", that is, it will only be
99     called once after C<want_poll>. To put it differently, C<want_poll> and
100     C<done_poll> are invoked in pairs: after C<want_poll> you have to call
101     C<eio_poll ()> until either C<eio_poll> indicates that everything has been
102     handled or C<done_poll> has been called, which signals the same.
103    
104     Note that C<eio_poll> might return after C<done_poll> and C<want_poll>
105     have been called again, so watch out for races in your code.
106    
107 sf-exg 1.6 As with C<want_poll>, this callback is called while locks are being held,
108 root 1.1 so you I<must not call any libeio functions form within this callback>.
109    
110     =item int eio_poll ()
111    
112     This function has to be called whenever there are pending requests that
113     need finishing. You usually call this after C<want_poll> has indicated
114     that you should do so, but you can also call this function regularly to
115     poll for new results.
116    
117     If any request invocation returns a non-zero value, then C<eio_poll ()>
118     immediately returns with that value as return value.
119    
120     Otherwise, if all requests could be handled, it returns C<0>. If for some
121     reason not all requests have been handled, i.e. some are still pending, it
122     returns C<-1>.
123    
124     =back
125    
126     For libev, you would typically use an C<ev_async> watcher: the
127     C<want_poll> callback would invoke C<ev_async_send> to wake up the event
128     loop. Inside the callback set for the watcher, one would call C<eio_poll
129     ()> (followed by C<ev_async_send> again if C<eio_poll> indicates that not
130     all requests have been handled yet). The race is taken care of because
131     libev resets/rearms the async watcher before calling your callback,
132     and therefore, before calling C<eio_poll>. This might result in (some)
133     spurious wake-ups, but is generally harmless.
134    
135     For most other event loops, you would typically use a pipe - the event
136 sf-exg 1.6 loop should be told to wait for read readiness on the read end. In
137 root 1.1 C<want_poll> you would write a single byte, in C<done_poll> you would try
138     to read that byte, and in the callback for the read end, you would call
139     C<eio_poll>. The race is avoided here because the event loop should invoke
140     your callback again and again until the byte has been read (as the pipe
141     read callback does not read it, only C<done_poll>).
142    
143    
144 root 1.7 =head1 HIGH LEVEL REQUEST API
145    
146     Libeio has both a high-level API, which consists of calling a request
147     function with a callback to be called on completion, and a low-level API
148     where you fill out request structures and submit them.
149    
150     This section describes the high-level API.
151    
152     =head2 REQUEST SUBMISSION AND RESULT PROCESSING
153    
154     You submit a request by calling the relevant C<eio_TYPE> function with the
155     required parameters, a callback of type C<int (*eio_cb)(eio_req *req)>
156     (called C<eio_cb> below) and a freely usable C<void *data> argument.
157    
158     The return value will either be 0
159    
160     The callback will be called with an C<eio_req *> which contains the
161     results of the request. The members you can access inside that structure
162     vary from request to request, except for:
163    
164     =over 4
165    
166     =item C<ssize_t result>
167    
168     This contains the result value from the call (usually the same as the
169     syscall of the same name).
170    
171     =item C<int errorno>
172    
173     This contains the value of C<errno> after the call.
174    
175     =item C<void *data>
176    
177     The C<void *data> member simply stores the value of the C<data> argument.
178    
179     =back
180    
181     The return value of the callback is normally C<0>, which tells libeio to
182     continue normally. If a callback returns a nonzero value, libeio will
183     stop processing results (in C<eio_poll>) and will return the value to its
184     caller.
185    
186     Memory areas passed to libeio must stay valid as long as a request
187     executes, with the exception of paths, which are being copied
188     internally. Any memory libeio itself allocates will be freed after the
189     finish callback has been called. If you want to manage all memory passed
190     to libeio yourself you can use the low-level API.
191    
192     For example, to open a file, you could do this:
193    
194     static int
195     file_open_done (eio_req *req)
196     {
197     if (req->result < 0)
198     {
199     /* open() returned -1 */
200     errno = req->errorno;
201     perror ("open");
202     }
203     else
204     {
205     int fd = req->result;
206     /* now we have the new fd in fd */
207     }
208    
209     return 0;
210     }
211    
212     /* the first three arguments are passed to open(2) */
213     /* the remaining are priority, callback and data */
214     if (!eio_open ("/etc/passwd", O_RDONLY, 0, 0, file_open_done, 0))
215     abort (); /* something ent wrong, we will all die!!! */
216    
217     Note that you additionally need to call C<eio_poll> when the C<want_cb>
218     indicates that requests are ready to be processed.
219    
220     =head2 AVAILABLE REQUESTS
221    
222     The following request functions are available. I<All> of them return the
223     C<eio_req *> on success and C<0> on failure, and I<all> of them have the
224     same three trailing arguments: C<pri>, C<cb> and C<data>. The C<cb> is
225     mandatory, but in most cases, you pass in C<0> as C<pri> and C<0> or some
226     custom data value as C<data>.
227    
228     =head3 POSIX API WRAPPERS
229    
230     These requests simply wrap the POSIX call of the same name, with the same
231 root 1.10 arguments. If a function is not implemented by the OS and cnanot be emulated
232     in some way, then all of these return C<-1> and set C<errorno> to C<ENOSYS>.
233 root 1.7
234     =over 4
235    
236     =item eio_open (const char *path, int flags, mode_t mode, int pri, eio_cb cb, void *data)
237    
238     =item eio_truncate (const char *path, off_t offset, int pri, eio_cb cb, void *data)
239    
240     =item eio_chown (const char *path, uid_t uid, gid_t gid, int pri, eio_cb cb, void *data)
241    
242     =item eio_chmod (const char *path, mode_t mode, int pri, eio_cb cb, void *data)
243    
244     =item eio_mkdir (const char *path, mode_t mode, int pri, eio_cb cb, void *data)
245    
246     =item eio_rmdir (const char *path, int pri, eio_cb cb, void *data)
247    
248     =item eio_unlink (const char *path, int pri, eio_cb cb, void *data)
249    
250 root 1.10 =item eio_utime (const char *path, eio_tstamp atime, eio_tstamp mtime, int pri, eio_cb cb, void *data)
251 root 1.7
252     =item eio_mknod (const char *path, mode_t mode, dev_t dev, int pri, eio_cb cb, void *data)
253    
254     =item eio_link (const char *path, const char *new_path, int pri, eio_cb cb, void *data)
255    
256     =item eio_symlink (const char *path, const char *new_path, int pri, eio_cb cb, void *data)
257    
258     =item eio_rename (const char *path, const char *new_path, int pri, eio_cb cb, void *data)
259    
260     =item eio_mlock (void *addr, size_t length, int pri, eio_cb cb, void *data)
261    
262     =item eio_close (int fd, int pri, eio_cb cb, void *data)
263    
264     =item eio_sync (int pri, eio_cb cb, void *data)
265    
266     =item eio_fsync (int fd, int pri, eio_cb cb, void *data)
267    
268     =item eio_fdatasync (int fd, int pri, eio_cb cb, void *data)
269    
270     =item eio_futime (int fd, eio_tstamp atime, eio_tstamp mtime, int pri, eio_cb cb, void *data)
271    
272     =item eio_ftruncate (int fd, off_t offset, int pri, eio_cb cb, void *data)
273    
274     =item eio_fchmod (int fd, mode_t mode, int pri, eio_cb cb, void *data)
275    
276     =item eio_fchown (int fd, uid_t uid, gid_t gid, int pri, eio_cb cb, void *data)
277    
278     =item eio_dup2 (int fd, int fd2, int pri, eio_cb cb, void *data)
279    
280     These have the same semantics as the syscall of the same name, their
281     return value is available as C<< req->result >> later.
282    
283     =item eio_read (int fd, void *buf, size_t length, off_t offset, int pri, eio_cb cb, void *data)
284    
285     =item eio_write (int fd, void *buf, size_t length, off_t offset, int pri, eio_cb cb, void *data)
286    
287     These two requests are called C<read> and C<write>, but actually wrap
288     C<pread> and C<pwrite>. On systems that lack these calls (such as cygwin),
289     libeio uses lseek/read_or_write/lseek and a mutex to serialise the
290     requests, so all these requests run serially and do not disturb each
291     other. However, they still disturb the file offset while they run, so it's
292     not safe to call these functions concurrently with non-libeio functions on
293     the same fd on these systems.
294    
295     Not surprisingly, pread and pwrite are not thread-safe on Darwin (OS/X),
296     so it is advised not to submit multiple requests on the same fd on this
297     horrible pile of garbage.
298    
299 root 1.10 =item eio_mlockall (int flags, int pri, eio_cb cb, void *data)
300    
301     Like C<mlockall>, but the flag value constants are called
302     C<EIO_MCL_CURRENT> and C<EIO_MCL_FUTURE>.
303    
304     =item eio_msync (void *addr, size_t length, int flags, int pri, eio_cb cb, void *data)
305    
306     Just like msync, except that the flag values are called C<EIO_MS_ASYNC>,
307     C<EIO_MS_INVALIDATE> and C<EIO_MS_SYNC>.
308    
309     =item eio_readlink (const char *path, int pri, eio_cb cb, void *data)
310    
311     If successful, the path read by C<readlink(2)> can be accessed via C<<
312     req->ptr2 >> and is I<NOT> null-terminated, with the length specified as
313     C<< req->result >>.
314    
315     if (req->result >= 0)
316     {
317     char *target = strndup ((char *)req->ptr2, req->result);
318    
319     free (target);
320     }
321    
322     =item eio_stat (const char *path, int pri, eio_cb cb, void *data)
323    
324     =item eio_lstat (const char *path, int pri, eio_cb cb, void *data)
325    
326 root 1.7 =item eio_fstat (int fd, int pri, eio_cb cb, void *data)
327    
328     Stats a file - if C<< req->result >> indicates success, then you can
329     access the C<struct stat>-like structure via C<< req->ptr2 >>:
330    
331     EIO_STRUCT_STAT *statdata = (EIO_STRUCT_STAT *)req->ptr2;
332    
333 root 1.10 =item eio_statvfs (const char *path, int pri, eio_cb cb, void *data)
334    
335     =item eio_fstatvfs (int fd, int pri, eio_cb cb, void *data)
336 root 1.7
337     Stats a filesystem - if C<< req->result >> indicates success, then you can
338     access the C<struct statvfs>-like structure via C<< req->ptr2 >>:
339    
340     EIO_STRUCT_STATVFS *statdata = (EIO_STRUCT_STATVFS *)req->ptr2;
341    
342     =back
343    
344     =head3 READING DIRECTORIES
345    
346     Reading directories sounds simple, but can be rather demanding, especially
347     if you want to do stuff such as traversing a diretcory hierarchy or
348     processing all files in a directory. Libeio can assist thess complex tasks
349     with it's C<eio_readdir> call.
350    
351     =over 4
352    
353     =item eio_readdir (const char *path, int flags, int pri, eio_cb cb, void *data)
354    
355     This is a very complex call. It basically reads through a whole directory
356     (via the C<opendir>, C<readdir> and C<closedir> calls) and returns either
357     the names or an array of C<struct eio_dirent>, depending on the C<flags>
358     argument.
359    
360     The C<< req->result >> indicates either the number of files found, or
361 root 1.10 C<-1> on error. On success, null-terminated names can be found as C<< req->ptr2 >>,
362 root 1.7 and C<struct eio_dirents>, if requested by C<flags>, can be found via C<<
363     req->ptr1 >>.
364    
365     Here is an example that prints all the names:
366    
367     int i;
368     char *names = (char *)req->ptr2;
369    
370     for (i = 0; i < req->result; ++i)
371     {
372     printf ("name #%d: %s\n", i, names);
373    
374     /* move to next name */
375     names += strlen (names) + 1;
376     }
377    
378     Pseudo-entries such as F<.> and F<..> are never returned by C<eio_readdir>.
379    
380     C<flags> can be any combination of:
381    
382     =over 4
383    
384     =item EIO_READDIR_DENTS
385    
386     If this flag is specified, then, in addition to the names in C<ptr2>,
387     also an array of C<struct eio_dirent> is returned, in C<ptr1>. A C<struct
388     eio_dirent> looks like this:
389    
390     struct eio_dirent
391     {
392     int nameofs; /* offset of null-terminated name string in (char *)req->ptr2 */
393     unsigned short namelen; /* size of filename without trailing 0 */
394     unsigned char type; /* one of EIO_DT_* */
395     signed char score; /* internal use */
396     ino_t inode; /* the inode number, if available, otherwise unspecified */
397     };
398    
399     The only members you normally would access are C<nameofs>, which is the
400     byte-offset from C<ptr2> to the start of the name, C<namelen> and C<type>.
401    
402     C<type> can be one of:
403    
404     C<EIO_DT_UNKNOWN> - if the type is not known (very common) and you have to C<stat>
405     the name yourself if you need to know,
406     one of the "standard" POSIX file types (C<EIO_DT_REG>, C<EIO_DT_DIR>, C<EIO_DT_LNK>,
407     C<EIO_DT_FIFO>, C<EIO_DT_SOCK>, C<EIO_DT_CHR>, C<EIO_DT_BLK>)
408     or some OS-specific type (currently
409     C<EIO_DT_MPC> - multiplexed char device (v7+coherent),
410     C<EIO_DT_NAM> - xenix special named file,
411     C<EIO_DT_MPB> - multiplexed block device (v7+coherent),
412     C<EIO_DT_NWK> - HP-UX network special,
413     C<EIO_DT_CMP> - VxFS compressed,
414     C<EIO_DT_DOOR> - solaris door, or
415     C<EIO_DT_WHT>).
416    
417     This example prints all names and their type:
418    
419     int i;
420     struct eio_dirent *ents = (struct eio_dirent *)req->ptr1;
421     char *names = (char *)req->ptr2;
422    
423     for (i = 0; i < req->result; ++i)
424     {
425     struct eio_dirent *ent = ents + i;
426     char *name = names + ent->nameofs;
427    
428     printf ("name #%d: %s (type %d)\n", i, name, ent->type);
429     }
430    
431     =item EIO_READDIR_DIRS_FIRST
432    
433     When this flag is specified, then the names will be returned in an order
434     where likely directories come first, in optimal C<stat> order. This is
435     useful when you need to quickly find directories, or you want to find all
436     directories while avoiding to stat() each entry.
437    
438     If the system returns type information in readdir, then this is used
439     to find directories directly. Otherwise, likely directories are names
440     beginning with ".", or otherwise names with no dots, of which names with
441     short names are tried first.
442    
443     =item EIO_READDIR_STAT_ORDER
444    
445     When this flag is specified, then the names will be returned in an order
446     suitable for stat()'ing each one. That is, when you plan to stat()
447     all files in the given directory, then the returned order will likely
448     be fastest.
449    
450     If both this flag and C<EIO_READDIR_DIRS_FIRST> are specified, then
451     the likely dirs come first, resulting in a less optimal stat order.
452    
453     =item EIO_READDIR_FOUND_UNKNOWN
454    
455     This flag should not be specified when calling C<eio_readdir>. Instead,
456     it is being set by C<eio_readdir> (you can access the C<flags> via C<<
457     req->int1 >>, when any of the C<type>'s found were C<EIO_DT_UNKNOWN>. The
458     absense of this flag therefore indicates that all C<type>'s are known,
459     which can be used to speed up some algorithms.
460    
461     A typical use case would be to identify all subdirectories within a
462     directory - you would ask C<eio_readdir> for C<EIO_READDIR_DIRS_FIRST>. If
463     then this flag is I<NOT> set, then all the entries at the beginning of the
464     returned array of type C<EIO_DT_DIR> are the directories. Otherwise, you
465     should start C<stat()>'ing the entries starting at the beginning of the
466     array, stopping as soon as you found all directories (the count can be
467     deduced by the link count of the directory).
468    
469     =back
470    
471     =back
472    
473     =head3 OS-SPECIFIC CALL WRAPPERS
474    
475     These wrap OS-specific calls (usually Linux ones), and might or might not
476     be emulated on other operating systems. Calls that are not emulated will
477     return C<-1> and set C<errno> to C<ENOSYS>.
478    
479     =over 4
480    
481     =item eio_sendfile (int out_fd, int in_fd, off_t in_offset, size_t length, int pri, eio_cb cb, void *data)
482    
483     Wraps the C<sendfile> syscall. The arguments follow the Linux version, but
484     libeio supports and will use similar calls on FreeBSD, HP/UX, Solaris and
485     Darwin.
486    
487     If the OS doesn't support some sendfile-like call, or the call fails,
488     indicating support for the given file descriptor type (for example,
489     Linux's sendfile might not support file to file copies), then libeio will
490     emulate the call in userspace, so there are almost no limitations on its
491     use.
492    
493     =item eio_readahead (int fd, off_t offset, size_t length, int pri, eio_cb cb, void *data)
494    
495     Calls C<readahead(2)>. If the syscall is missing, then the call is
496     emulated by simply reading the data (currently in 64kiB chunks).
497    
498     =item eio_sync_file_range (int fd, off_t offset, size_t nbytes, unsigned int flags, int pri, eio_cb cb, void *data)
499    
500     Calls C<sync_file_range>. If the syscall is missing, then this is the same
501     as calling C<fdatasync>.
502    
503 root 1.10 Flags can be any combination of C<EIO_SYNC_FILE_RANGE_WAIT_BEFORE>,
504     C<EIO_SYNC_FILE_RANGE_WRITE> and C<EIO_SYNC_FILE_RANGE_WAIT_AFTER>.
505    
506 root 1.7 =back
507    
508     =head3 LIBEIO-SPECIFIC REQUESTS
509    
510     These requests are specific to libeio and do not correspond to any OS call.
511    
512     =over 4
513    
514 root 1.9 =item eio_mtouch (void *addr, size_t length, int flags, int pri, eio_cb cb, void *data)
515 root 1.7
516 root 1.9 Reads (C<flags == 0>) or modifies (C<flags == EIO_MT_MODIFY) the given
517     memory area, page-wise, that is, it reads (or reads and writes back) the
518     first octet of every page that spans the memory area.
519    
520     This can be used to page in some mmapped file, or dirty some pages. Note
521     that dirtying is an unlocked read-write access, so races can ensue when
522     the some other thread modifies the data stored in that memory area.
523    
524     =item eio_custom (void (*)(eio_req *) execute, int pri, eio_cb cb, void *data)
525 root 1.7
526     Executes a custom request, i.e., a user-specified callback.
527    
528     The callback gets the C<eio_req *> as parameter and is expected to read
529     and modify any request-specific members. Specifically, it should set C<<
530     req->result >> to the result value, just like other requests.
531    
532     Here is an example that simply calls C<open>, like C<eio_open>, but it
533     uses the C<data> member as filename and uses a hardcoded C<O_RDONLY>. If
534     you want to pass more/other parameters, you either need to pass some
535     struct or so via C<data> or provide your own wrapper using the low-level
536     API.
537    
538     static int
539     my_open_done (eio_req *req)
540     {
541     int fd = req->result;
542    
543     return 0;
544     }
545    
546     static void
547     my_open (eio_req *req)
548     {
549     req->result = open (req->data, O_RDONLY);
550     }
551    
552     eio_custom (my_open, 0, my_open_done, "/etc/passwd");
553    
554 root 1.9 =item eio_busy (eio_tstamp delay, int pri, eio_cb cb, void *data)
555 root 1.7
556     This is a a request that takes C<delay> seconds to execute, but otherwise
557     does nothing - it simply puts one of the worker threads to sleep for this
558     long.
559    
560     This request can be used to artificially increase load, e.g. for debugging
561     or benchmarking reasons.
562    
563 root 1.9 =item eio_nop (int pri, eio_cb cb, void *data)
564 root 1.7
565     This request does nothing, except go through the whole request cycle. This
566     can be used to measure latency or in some cases to simplify code, but is
567     not really of much use.
568    
569     =back
570    
571     =head3 GROUPING AND LIMITING REQUESTS
572 root 1.1
573     #TODO
574    
575 root 1.7 /*****************************************************************************/
576     /* groups */
577 root 1.1
578 root 1.7 eio_req *eio_grp (eio_cb cb, void *data);
579     void eio_grp_feed (eio_req *grp, void (*feed)(eio_req *req), int limit);
580     void eio_grp_limit (eio_req *grp, int limit);
581     void eio_grp_add (eio_req *grp, eio_req *req);
582     void eio_grp_cancel (eio_req *grp); /* cancels all sub requests but not the group */
583 root 1.1
584    
585     =back
586    
587    
588     =head1 LOW LEVEL REQUEST API
589    
590     #TODO
591    
592 root 1.7
593     =head1 ANATOMY AND LIFETIME OF AN EIO REQUEST
594    
595     A request is represented by a structure of type C<eio_req>. To initialise
596     it, clear it to all zero bytes:
597    
598     eio_req req;
599    
600     memset (&req, 0, sizeof (req));
601    
602     A more common way to initialise a new C<eio_req> is to use C<calloc>:
603    
604     eio_req *req = calloc (1, sizeof (*req));
605    
606     In either case, libeio neither allocates, initialises or frees the
607     C<eio_req> structure for you - it merely uses it.
608    
609     zero
610    
611     #TODO
612    
613 root 1.8 =head2 CONFIGURATION
614    
615     The functions in this section can sometimes be useful, but the default
616     configuration will do in most case, so you should skip this section on
617     first reading.
618    
619     =over 4
620    
621     =item eio_set_max_poll_time (eio_tstamp nseconds)
622    
623     This causes C<eio_poll ()> to return after it has detected that it was
624     running for C<nsecond> seconds or longer (this number can be fractional).
625    
626     This can be used to limit the amount of time spent handling eio requests,
627     for example, in interactive programs, you might want to limit this time to
628     C<0.01> seconds or so.
629    
630     Note that:
631    
632     a) libeio doesn't know how long your request callbacks take, so the time
633     spent in C<eio_poll> is up to one callback invocation longer then this
634     interval.
635    
636     b) this is implemented by calling C<gettimeofday> after each request,
637     which can be costly.
638    
639     c) at least one request will be handled.
640    
641     =item eio_set_max_poll_reqs (unsigned int nreqs)
642    
643     When C<nreqs> is non-zero, then C<eio_poll> will not handle more than
644     C<nreqs> requests per invocation. This is a less costly way to limit the
645     amount of work done by C<eio_poll> then setting a time limit.
646    
647     If you know your callbacks are generally fast, you could use this to
648     encourage interactiveness in your programs by setting it to C<10>, C<100>
649     or even C<1000>.
650    
651     =item eio_set_min_parallel (unsigned int nthreads)
652    
653     Make sure libeio can handle at least this many requests in parallel. It
654     might be able handle more.
655    
656     =item eio_set_max_parallel (unsigned int nthreads)
657    
658     Set the maximum number of threads that libeio will spawn.
659    
660     =item eio_set_max_idle (unsigned int nthreads)
661    
662     Libeio uses threads internally to handle most requests, and will start and stop threads on demand.
663    
664     This call can be used to limit the number of idle threads (threads without
665     work to do): libeio will keep some threads idle in preparation for more
666     requests, but never longer than C<nthreads> threads.
667    
668     In addition to this, libeio will also stop threads when they are idle for
669     a few seconds, regardless of this setting.
670    
671     =item unsigned int eio_nthreads ()
672    
673     Return the number of worker threads currently running.
674    
675     =item unsigned int eio_nreqs ()
676    
677     Return the number of requests currently handled by libeio. This is the
678     total number of requests that have been submitted to libeio, but not yet
679     destroyed.
680    
681     =item unsigned int eio_nready ()
682    
683     Returns the number of ready requests, i.e. requests that have been
684     submitted but have not yet entered the execution phase.
685    
686     =item unsigned int eio_npending ()
687    
688     Returns the number of pending requests, i.e. requests that have been
689     executed and have results, but have not been finished yet by a call to
690     C<eio_poll>).
691    
692     =back
693    
694 root 1.1 =head1 EMBEDDING
695    
696     Libeio can be embedded directly into programs. This functionality is not
697     documented and not (yet) officially supported.
698    
699 root 1.3 Note that, when including C<libeio.m4>, you are responsible for defining
700     the compilation environment (C<_LARGEFILE_SOURCE>, C<_GNU_SOURCE> etc.).
701    
702 root 1.2 If you need to know how, check the C<IO::AIO> perl module, which does
703 root 1.1 exactly that.
704    
705    
706 root 1.4 =head1 COMPILETIME CONFIGURATION
707    
708     These symbols, if used, must be defined when compiling F<eio.c>.
709    
710     =over 4
711    
712     =item EIO_STACKSIZE
713    
714     This symbol governs the stack size for each eio thread. Libeio itself
715     was written to use very little stackspace, but when using C<EIO_CUSTOM>
716     requests, you might want to increase this.
717    
718     If this symbol is undefined (the default) then libeio will use its default
719     stack size (C<sizeof (long) * 4096> currently). If it is defined, but
720     C<0>, then the default operating system stack size will be used. In all
721     other cases, the value must be an expression that evaluates to the desired
722     stack size.
723    
724     =back
725    
726    
727 root 1.1 =head1 PORTABILITY REQUIREMENTS
728    
729     In addition to a working ISO-C implementation, libeio relies on a few
730     additional extensions:
731    
732     =over 4
733    
734     =item POSIX threads
735    
736     To be portable, this module uses threads, specifically, the POSIX threads
737     library must be available (and working, which partially excludes many xBSD
738     systems, where C<fork ()> is buggy).
739    
740     =item POSIX-compatible filesystem API
741    
742     This is actually a harder portability requirement: The libeio API is quite
743     demanding regarding POSIX API calls (symlinks, user/group management
744     etc.).
745    
746     =item C<double> must hold a time value in seconds with enough accuracy
747    
748     The type C<double> is used to represent timestamps. It is required to
749     have at least 51 bits of mantissa (and 9 bits of exponent), which is good
750     enough for at least into the year 4000. This requirement is fulfilled by
751     implementations implementing IEEE 754 (basically all existing ones).
752    
753     =back
754    
755     If you know of other additional requirements drop me a note.
756    
757    
758     =head1 AUTHOR
759    
760     Marc Lehmann <libeio@schmorp.de>.
761