ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev.pod
(Generate patch)

Comparing libev/ev.pod (file contents):
Revision 1.143 by root, Sun Apr 6 14:34:52 2008 UTC vs.
Revision 1.157 by root, Tue May 20 23:49:41 2008 UTC

64 64
65=head1 DESCRIPTION 65=head1 DESCRIPTION
66 66
67The newest version of this document is also available as an html-formatted 67The newest version of this document is also available as an html-formatted
68web page you might find easier to navigate when reading it for the first 68web page you might find easier to navigate when reading it for the first
69time: L<http://cvs.schmorp.de/libev/ev.html>. 69time: L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>.
70 70
71Libev is an event loop: you register interest in certain events (such as a 71Libev is an event loop: you register interest in certain events (such as a
72file descriptor being readable or a timeout occurring), and it will manage 72file descriptor being readable or a timeout occurring), and it will manage
73these event sources and provide your program with events. 73these event sources and provide your program with events.
74 74
196See the description of C<ev_embed> watchers for more info. 196See the description of C<ev_embed> watchers for more info.
197 197
198=item ev_set_allocator (void *(*cb)(void *ptr, long size)) 198=item ev_set_allocator (void *(*cb)(void *ptr, long size))
199 199
200Sets the allocation function to use (the prototype is similar - the 200Sets the allocation function to use (the prototype is similar - the
201semantics is identical - to the realloc C function). It is used to 201semantics are identical to the C<realloc> C89/SuS/POSIX function). It is
202allocate and free memory (no surprises here). If it returns zero when 202used to allocate and free memory (no surprises here). If it returns zero
203memory needs to be allocated, the library might abort or take some 203when memory needs to be allocated (C<size != 0>), the library might abort
204potentially destructive action. The default is your system realloc 204or take some potentially destructive action.
205function. 205
206Since some systems (at least OpenBSD and Darwin) fail to implement
207correct C<realloc> semantics, libev will use a wrapper around the system
208C<realloc> and C<free> functions by default.
206 209
207You could override this function in high-availability programs to, say, 210You could override this function in high-availability programs to, say,
208free some memory if it cannot allocate memory, to use a special allocator, 211free some memory if it cannot allocate memory, to use a special allocator,
209or even to sleep a while and retry until some memory is available. 212or even to sleep a while and retry until some memory is available.
210 213
211Example: Replace the libev allocator with one that waits a bit and then 214Example: Replace the libev allocator with one that waits a bit and then
212retries). 215retries (example requires a standards-compliant C<realloc>).
213 216
214 static void * 217 static void *
215 persistent_realloc (void *ptr, size_t size) 218 persistent_realloc (void *ptr, size_t size)
216 { 219 {
217 for (;;) 220 for (;;)
256 259
257An event loop is described by a C<struct ev_loop *>. The library knows two 260An event loop is described by a C<struct ev_loop *>. The library knows two
258types of such loops, the I<default> loop, which supports signals and child 261types of such loops, the I<default> loop, which supports signals and child
259events, and dynamically created loops which do not. 262events, and dynamically created loops which do not.
260 263
261If you use threads, a common model is to run the default event loop
262in your main thread (or in a separate thread) and for each thread you
263create, you also create another event loop. Libev itself does no locking
264whatsoever, so if you mix calls to the same event loop in different
265threads, make sure you lock (this is usually a bad idea, though, even if
266done correctly, because it's hideous and inefficient).
267
268=over 4 264=over 4
269 265
270=item struct ev_loop *ev_default_loop (unsigned int flags) 266=item struct ev_loop *ev_default_loop (unsigned int flags)
271 267
272This will initialise the default event loop if it hasn't been initialised 268This will initialise the default event loop if it hasn't been initialised
340To get good performance out of this backend you need a high amount of 336To get good performance out of this backend you need a high amount of
341parallelity (most of the file descriptors should be busy). If you are 337parallelity (most of the file descriptors should be busy). If you are
342writing a server, you should C<accept ()> in a loop to accept as many 338writing a server, you should C<accept ()> in a loop to accept as many
343connections as possible during one iteration. You might also want to have 339connections as possible during one iteration. You might also want to have
344a look at C<ev_set_io_collect_interval ()> to increase the amount of 340a look at C<ev_set_io_collect_interval ()> to increase the amount of
345readyness notifications you get per iteration. 341readiness notifications you get per iteration.
346 342
347=item C<EVBACKEND_POLL> (value 2, poll backend, available everywhere except on windows) 343=item C<EVBACKEND_POLL> (value 2, poll backend, available everywhere except on windows)
348 344
349And this is your standard poll(2) backend. It's more complicated 345And this is your standard poll(2) backend. It's more complicated
350than select, but handles sparse fds better and has no artificial 346than select, but handles sparse fds better and has no artificial
429While this backend scales well, it requires one system call per active 425While this backend scales well, it requires one system call per active
430file descriptor per loop iteration. For small and medium numbers of file 426file descriptor per loop iteration. For small and medium numbers of file
431descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend 427descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend
432might perform better. 428might perform better.
433 429
434On the positive side, ignoring the spurious readyness notifications, this 430On the positive side, ignoring the spurious readiness notifications, this
435backend actually performed to specification in all tests and is fully 431backend actually performed to specification in all tests and is fully
436embeddable, which is a rare feat among the OS-specific backends. 432embeddable, which is a rare feat among the OS-specific backends.
437 433
438=item C<EVBACKEND_ALL> 434=item C<EVBACKEND_ALL>
439 435
1036If you must do this, then force the use of a known-to-be-good backend 1032If you must do this, then force the use of a known-to-be-good backend
1037(at the time of this writing, this includes only C<EVBACKEND_SELECT> and 1033(at the time of this writing, this includes only C<EVBACKEND_SELECT> and
1038C<EVBACKEND_POLL>). 1034C<EVBACKEND_POLL>).
1039 1035
1040Another thing you have to watch out for is that it is quite easy to 1036Another thing you have to watch out for is that it is quite easy to
1041receive "spurious" readyness notifications, that is your callback might 1037receive "spurious" readiness notifications, that is your callback might
1042be called with C<EV_READ> but a subsequent C<read>(2) will actually block 1038be called with C<EV_READ> but a subsequent C<read>(2) will actually block
1043because there is no data. Not only are some backends known to create a 1039because there is no data. Not only are some backends known to create a
1044lot of those (for example solaris ports), it is very easy to get into 1040lot of those (for example solaris ports), it is very easy to get into
1045this situation even with a relatively standard program structure. Thus 1041this situation even with a relatively standard program structure. Thus
1046it is best to always use non-blocking I/O: An extra C<read>(2) returning 1042it is best to always use non-blocking I/O: An extra C<read>(2) returning
1155 1151
1156Timer watchers are simple relative timers that generate an event after a 1152Timer watchers are simple relative timers that generate an event after a
1157given time, and optionally repeating in regular intervals after that. 1153given time, and optionally repeating in regular intervals after that.
1158 1154
1159The timers are based on real time, that is, if you register an event that 1155The timers are based on real time, that is, if you register an event that
1160times out after an hour and you reset your system clock to last years 1156times out after an hour and you reset your system clock to january last
1161time, it will still time out after (roughly) and hour. "Roughly" because 1157year, it will still time out after (roughly) and hour. "Roughly" because
1162detecting time jumps is hard, and some inaccuracies are unavoidable (the 1158detecting time jumps is hard, and some inaccuracies are unavoidable (the
1163monotonic clock option helps a lot here). 1159monotonic clock option helps a lot here).
1164 1160
1165The relative timeouts are calculated relative to the C<ev_now ()> 1161The relative timeouts are calculated relative to the C<ev_now ()>
1166time. This is usually the right thing as this timestamp refers to the time 1162time. This is usually the right thing as this timestamp refers to the time
1168you suspect event processing to be delayed and you I<need> to base the timeout 1164you suspect event processing to be delayed and you I<need> to base the timeout
1169on the current time, use something like this to adjust for this: 1165on the current time, use something like this to adjust for this:
1170 1166
1171 ev_timer_set (&timer, after + ev_now () - ev_time (), 0.); 1167 ev_timer_set (&timer, after + ev_now () - ev_time (), 0.);
1172 1168
1173The callback is guarenteed to be invoked only when its timeout has passed, 1169The callback is guarenteed to be invoked only after its timeout has passed,
1174but if multiple timers become ready during the same loop iteration then 1170but if multiple timers become ready during the same loop iteration then
1175order of execution is undefined. 1171order of execution is undefined.
1176 1172
1177=head3 Watcher-Specific Functions and Data Members 1173=head3 Watcher-Specific Functions and Data Members
1178 1174
1180 1176
1181=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 1177=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
1182 1178
1183=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat) 1179=item ev_timer_set (ev_timer *, ev_tstamp after, ev_tstamp repeat)
1184 1180
1185Configure the timer to trigger after C<after> seconds. If C<repeat> is 1181Configure the timer to trigger after C<after> seconds. If C<repeat>
1186C<0.>, then it will automatically be stopped. If it is positive, then the 1182is C<0.>, then it will automatically be stopped once the timeout is
1187timer will automatically be configured to trigger again C<repeat> seconds 1183reached. If it is positive, then the timer will automatically be
1188later, again, and again, until stopped manually. 1184configured to trigger again C<repeat> seconds later, again, and again,
1185until stopped manually.
1189 1186
1190The timer itself will do a best-effort at avoiding drift, that is, if you 1187The timer itself will do a best-effort at avoiding drift, that is, if
1191configure a timer to trigger every 10 seconds, then it will trigger at 1188you configure a timer to trigger every 10 seconds, then it will normally
1192exactly 10 second intervals. If, however, your program cannot keep up with 1189trigger at exactly 10 second intervals. If, however, your program cannot
1193the timer (because it takes longer than those 10 seconds to do stuff) the 1190keep up with the timer (because it takes longer than those 10 seconds to
1194timer will not fire more than once per event loop iteration. 1191do stuff) the timer will not fire more than once per event loop iteration.
1195 1192
1196=item ev_timer_again (loop, ev_timer *) 1193=item ev_timer_again (loop, ev_timer *)
1197 1194
1198This will act as if the timer timed out and restart it again if it is 1195This will act as if the timer timed out and restart it again if it is
1199repeating. The exact semantics are: 1196repeating. The exact semantics are:
1276Periodic watchers are also timers of a kind, but they are very versatile 1273Periodic watchers are also timers of a kind, but they are very versatile
1277(and unfortunately a bit complex). 1274(and unfortunately a bit complex).
1278 1275
1279Unlike C<ev_timer>'s, they are not based on real time (or relative time) 1276Unlike C<ev_timer>'s, they are not based on real time (or relative time)
1280but on wallclock time (absolute time). You can tell a periodic watcher 1277but on wallclock time (absolute time). You can tell a periodic watcher
1281to trigger "at" some specific point in time. For example, if you tell a 1278to trigger after some specific point in time. For example, if you tell a
1282periodic watcher to trigger in 10 seconds (by specifiying e.g. C<ev_now () 1279periodic watcher to trigger in 10 seconds (by specifiying e.g. C<ev_now ()
1283+ 10.>) and then reset your system clock to the last year, then it will 1280+ 10.>, that is, an absolute time not a delay) and then reset your system
1281clock to january of the previous year, then it will take more than year
1284take a year to trigger the event (unlike an C<ev_timer>, which would trigger 1282to trigger the event (unlike an C<ev_timer>, which would still trigger
1285roughly 10 seconds later). 1283roughly 10 seconds later as it uses a relative timeout).
1286 1284
1287They can also be used to implement vastly more complex timers, such as 1285C<ev_periodic>s can also be used to implement vastly more complex timers,
1288triggering an event on each midnight, local time or other, complicated, 1286such as triggering an event on each "midnight, local time", or other
1289rules. 1287complicated, rules.
1290 1288
1291As with timers, the callback is guarenteed to be invoked only when the 1289As with timers, the callback is guarenteed to be invoked only when the
1292time (C<at>) has been passed, but if multiple periodic timers become ready 1290time (C<at>) has passed, but if multiple periodic timers become ready
1293during the same loop iteration then order of execution is undefined. 1291during the same loop iteration then order of execution is undefined.
1294 1292
1295=head3 Watcher-Specific Functions and Data Members 1293=head3 Watcher-Specific Functions and Data Members
1296 1294
1297=over 4 1295=over 4
1305 1303
1306=over 4 1304=over 4
1307 1305
1308=item * absolute timer (at = time, interval = reschedule_cb = 0) 1306=item * absolute timer (at = time, interval = reschedule_cb = 0)
1309 1307
1310In this configuration the watcher triggers an event at the wallclock time 1308In this configuration the watcher triggers an event after the wallclock
1311C<at> and doesn't repeat. It will not adjust when a time jump occurs, 1309time C<at> has passed and doesn't repeat. It will not adjust when a time
1312that is, if it is to be run at January 1st 2011 then it will run when the 1310jump occurs, that is, if it is to be run at January 1st 2011 then it will
1313system time reaches or surpasses this time. 1311run when the system time reaches or surpasses this time.
1314 1312
1315=item * repeating interval timer (at = offset, interval > 0, reschedule_cb = 0) 1313=item * repeating interval timer (at = offset, interval > 0, reschedule_cb = 0)
1316 1314
1317In this mode the watcher will always be scheduled to time out at the next 1315In this mode the watcher will always be scheduled to time out at the next
1318C<at + N * interval> time (for some integer N, which can also be negative) 1316C<at + N * interval> time (for some integer N, which can also be negative)
1319and then repeat, regardless of any time jumps. 1317and then repeat, regardless of any time jumps.
1320 1318
1321This can be used to create timers that do not drift with respect to system 1319This can be used to create timers that do not drift with respect to system
1322time: 1320time, for example, here is a C<ev_periodic> that triggers each hour, on
1321the hour:
1323 1322
1324 ev_periodic_set (&periodic, 0., 3600., 0); 1323 ev_periodic_set (&periodic, 0., 3600., 0);
1325 1324
1326This doesn't mean there will always be 3600 seconds in between triggers, 1325This doesn't mean there will always be 3600 seconds in between triggers,
1327but only that the the callback will be called when the system time shows a 1326but only that the the callback will be called when the system time shows a
1332C<ev_periodic> will try to run the callback in this mode at the next possible 1331C<ev_periodic> will try to run the callback in this mode at the next possible
1333time where C<time = at (mod interval)>, regardless of any time jumps. 1332time where C<time = at (mod interval)>, regardless of any time jumps.
1334 1333
1335For numerical stability it is preferable that the C<at> value is near 1334For numerical stability it is preferable that the C<at> value is near
1336C<ev_now ()> (the current time), but there is no range requirement for 1335C<ev_now ()> (the current time), but there is no range requirement for
1337this value. 1336this value, and in fact is often specified as zero.
1338 1337
1339=item * manual reschedule mode (at and interval ignored, reschedule_cb = callback) 1338=item * manual reschedule mode (at and interval ignored, reschedule_cb = callback)
1340 1339
1341In this mode the values for C<interval> and C<at> are both being 1340In this mode the values for C<interval> and C<at> are both being
1342ignored. Instead, each time the periodic watcher gets scheduled, the 1341ignored. Instead, each time the periodic watcher gets scheduled, the
1343reschedule callback will be called with the watcher as first, and the 1342reschedule callback will be called with the watcher as first, and the
1344current time as second argument. 1343current time as second argument.
1345 1344
1346NOTE: I<This callback MUST NOT stop or destroy any periodic watcher, 1345NOTE: I<This callback MUST NOT stop or destroy any periodic watcher,
1347ever, or make any event loop modifications>. If you need to stop it, 1346ever, or make ANY event loop modifications whatsoever>.
1348return C<now + 1e30> (or so, fudge fudge) and stop it afterwards (e.g. by
1349starting an C<ev_prepare> watcher, which is legal).
1350 1347
1348If you need to stop it, return C<now + 1e30> (or so, fudge fudge) and stop
1349it afterwards (e.g. by starting an C<ev_prepare> watcher, which is the
1350only event loop modification you are allowed to do).
1351
1351Its prototype is C<ev_tstamp (*reschedule_cb)(struct ev_periodic *w, 1352The callback prototype is C<ev_tstamp (*reschedule_cb)(struct ev_periodic
1352ev_tstamp now)>, e.g.: 1353*w, ev_tstamp now)>, e.g.:
1353 1354
1354 static ev_tstamp my_rescheduler (struct ev_periodic *w, ev_tstamp now) 1355 static ev_tstamp my_rescheduler (struct ev_periodic *w, ev_tstamp now)
1355 { 1356 {
1356 return now + 60.; 1357 return now + 60.;
1357 } 1358 }
1359It must return the next time to trigger, based on the passed time value 1360It must return the next time to trigger, based on the passed time value
1360(that is, the lowest time value larger than to the second argument). It 1361(that is, the lowest time value larger than to the second argument). It
1361will usually be called just before the callback will be triggered, but 1362will usually be called just before the callback will be triggered, but
1362might be called at other times, too. 1363might be called at other times, too.
1363 1364
1364NOTE: I<< This callback must always return a time that is later than the 1365NOTE: I<< This callback must always return a time that is higher than or
1365passed C<now> value >>. Not even C<now> itself will do, it I<must> be larger. 1366equal to the passed C<now> value >>.
1366 1367
1367This can be used to create very complex timers, such as a timer that 1368This can be used to create very complex timers, such as a timer that
1368triggers on each midnight, local time. To do this, you would calculate the 1369triggers on "next midnight, local time". To do this, you would calculate the
1369next midnight after C<now> and return the timestamp value for this. How 1370next midnight after C<now> and return the timestamp value for this. How
1370you do this is, again, up to you (but it is not trivial, which is the main 1371you do this is, again, up to you (but it is not trivial, which is the main
1371reason I omitted it as an example). 1372reason I omitted it as an example).
1372 1373
1373=back 1374=back
1377Simply stops and restarts the periodic watcher again. This is only useful 1378Simply stops and restarts the periodic watcher again. This is only useful
1378when you changed some parameters or the reschedule callback would return 1379when you changed some parameters or the reschedule callback would return
1379a different time than the last time it was called (e.g. in a crond like 1380a different time than the last time it was called (e.g. in a crond like
1380program when the crontabs have changed). 1381program when the crontabs have changed).
1381 1382
1383=item ev_tstamp ev_periodic_at (ev_periodic *)
1384
1385When active, returns the absolute time that the watcher is supposed to
1386trigger next.
1387
1382=item ev_tstamp offset [read-write] 1388=item ev_tstamp offset [read-write]
1383 1389
1384When repeating, this contains the offset value, otherwise this is the 1390When repeating, this contains the offset value, otherwise this is the
1385absolute point in time (the C<at> value passed to C<ev_periodic_set>). 1391absolute point in time (the C<at> value passed to C<ev_periodic_set>).
1386 1392
1396=item ev_tstamp (*reschedule_cb)(struct ev_periodic *w, ev_tstamp now) [read-write] 1402=item ev_tstamp (*reschedule_cb)(struct ev_periodic *w, ev_tstamp now) [read-write]
1397 1403
1398The current reschedule callback, or C<0>, if this functionality is 1404The current reschedule callback, or C<0>, if this functionality is
1399switched off. Can be changed any time, but changes only take effect when 1405switched off. Can be changed any time, but changes only take effect when
1400the periodic timer fires or C<ev_periodic_again> is being called. 1406the periodic timer fires or C<ev_periodic_again> is being called.
1401
1402=item ev_tstamp at [read-only]
1403
1404When active, contains the absolute time that the watcher is supposed to
1405trigger next.
1406 1407
1407=back 1408=back
1408 1409
1409=head3 Examples 1410=head3 Examples
1410 1411
1614as even with OS-supported change notifications, this can be 1615as even with OS-supported change notifications, this can be
1615resource-intensive. 1616resource-intensive.
1616 1617
1617At the time of this writing, only the Linux inotify interface is 1618At the time of this writing, only the Linux inotify interface is
1618implemented (implementing kqueue support is left as an exercise for the 1619implemented (implementing kqueue support is left as an exercise for the
1620reader, note, however, that the author sees no way of implementing ev_stat
1619reader). Inotify will be used to give hints only and should not change the 1621semantics with kqueue). Inotify will be used to give hints only and should
1620semantics of C<ev_stat> watchers, which means that libev sometimes needs 1622not change the semantics of C<ev_stat> watchers, which means that libev
1621to fall back to regular polling again even with inotify, but changes are 1623sometimes needs to fall back to regular polling again even with inotify,
1622usually detected immediately, and if the file exists there will be no 1624but changes are usually detected immediately, and if the file exists there
1623polling. 1625will be no polling.
1624 1626
1625=head3 ABI Issues (Largefile Support) 1627=head3 ABI Issues (Largefile Support)
1626 1628
1627Libev by default (unless the user overrides this) uses the default 1629Libev by default (unless the user overrides this) uses the default
1628compilation environment, which means that on systems with optionally 1630compilation environment, which means that on systems with optionally
1638When C<inotify (7)> support has been compiled into libev (generally only 1640When C<inotify (7)> support has been compiled into libev (generally only
1639available on Linux) and present at runtime, it will be used to speed up 1641available on Linux) and present at runtime, it will be used to speed up
1640change detection where possible. The inotify descriptor will be created lazily 1642change detection where possible. The inotify descriptor will be created lazily
1641when the first C<ev_stat> watcher is being started. 1643when the first C<ev_stat> watcher is being started.
1642 1644
1643Inotify presense does not change the semantics of C<ev_stat> watchers 1645Inotify presence does not change the semantics of C<ev_stat> watchers
1644except that changes might be detected earlier, and in some cases, to avoid 1646except that changes might be detected earlier, and in some cases, to avoid
1645making regular C<stat> calls. Even in the presense of inotify support 1647making regular C<stat> calls. Even in the presence of inotify support
1646there are many cases where libev has to resort to regular C<stat> polling. 1648there are many cases where libev has to resort to regular C<stat> polling.
1647 1649
1648(There is no support for kqueue, as apparently it cannot be used to 1650(There is no support for kqueue, as apparently it cannot be used to
1649implement this functionality, due to the requirement of having a file 1651implement this functionality, due to the requirement of having a file
1650descriptor open on the object at all times). 1652descriptor open on the object at all times).
1653 1655
1654The C<stat ()> syscall only supports full-second resolution portably, and 1656The C<stat ()> syscall only supports full-second resolution portably, and
1655even on systems where the resolution is higher, many filesystems still 1657even on systems where the resolution is higher, many filesystems still
1656only support whole seconds. 1658only support whole seconds.
1657 1659
1658That means that, if the time is the only thing that changes, you might 1660That means that, if the time is the only thing that changes, you can
1659miss updates: on the first update, C<ev_stat> detects a change and calls 1661easily miss updates: on the first update, C<ev_stat> detects a change and
1660your callback, which does something. When there is another update within 1662calls your callback, which does something. When there is another update
1661the same second, C<ev_stat> will be unable to detect it. 1663within the same second, C<ev_stat> will be unable to detect it as the stat
1664data does not change.
1662 1665
1663The solution to this is to delay acting on a change for a second (or till 1666The solution to this is to delay acting on a change for slightly more
1664the next second boundary), using a roughly one-second delay C<ev_timer> 1667than a second (or till slightly after the next full second boundary), using
1665(C<ev_timer_set (w, 0., 1.01); ev_timer_again (loop, w)>). The C<.01> 1668a roughly one-second-delay C<ev_timer> (e.g. C<ev_timer_set (w, 0., 1.02);
1666is added to work around small timing inconsistencies of some operating 1669ev_timer_again (loop, w)>).
1667systems. 1670
1671The C<.02> offset is added to work around small timing inconsistencies
1672of some operating systems (where the second counter of the current time
1673might be be delayed. One such system is the Linux kernel, where a call to
1674C<gettimeofday> might return a timestamp with a full second later than
1675a subsequent C<time> call - if the equivalent of C<time ()> is used to
1676update file times then there will be a small window where the kernel uses
1677the previous second to update file times but libev might already execute
1678the timer callback).
1668 1679
1669=head3 Watcher-Specific Functions and Data Members 1680=head3 Watcher-Specific Functions and Data Members
1670 1681
1671=over 4 1682=over 4
1672 1683
1678C<path>. The C<interval> is a hint on how quickly a change is expected to 1689C<path>. The C<interval> is a hint on how quickly a change is expected to
1679be detected and should normally be specified as C<0> to let libev choose 1690be detected and should normally be specified as C<0> to let libev choose
1680a suitable value. The memory pointed to by C<path> must point to the same 1691a suitable value. The memory pointed to by C<path> must point to the same
1681path for as long as the watcher is active. 1692path for as long as the watcher is active.
1682 1693
1683The callback will be receive C<EV_STAT> when a change was detected, 1694The callback will receive C<EV_STAT> when a change was detected, relative
1684relative to the attributes at the time the watcher was started (or the 1695to the attributes at the time the watcher was started (or the last change
1685last change was detected). 1696was detected).
1686 1697
1687=item ev_stat_stat (loop, ev_stat *) 1698=item ev_stat_stat (loop, ev_stat *)
1688 1699
1689Updates the stat buffer immediately with new values. If you change the 1700Updates the stat buffer immediately with new values. If you change the
1690watched path in your callback, you could call this fucntion to avoid 1701watched path in your callback, you could call this function to avoid
1691detecting this change (while introducing a race condition). Can also be 1702detecting this change (while introducing a race condition if you are not
1692useful simply to find out the new values. 1703the only one changing the path). Can also be useful simply to find out the
1704new values.
1693 1705
1694=item ev_statdata attr [read-only] 1706=item ev_statdata attr [read-only]
1695 1707
1696The most-recently detected attributes of the file. Although the type is of 1708The most-recently detected attributes of the file. Although the type is
1697C<ev_statdata>, this is usually the (or one of the) C<struct stat> types 1709C<ev_statdata>, this is usually the (or one of the) C<struct stat> types
1698suitable for your system. If the C<st_nlink> member is C<0>, then there 1710suitable for your system, but you can only rely on the POSIX-standardised
1711members to be present. If the C<st_nlink> member is C<0>, then there was
1699was some error while C<stat>ing the file. 1712some error while C<stat>ing the file.
1700 1713
1701=item ev_statdata prev [read-only] 1714=item ev_statdata prev [read-only]
1702 1715
1703The previous attributes of the file. The callback gets invoked whenever 1716The previous attributes of the file. The callback gets invoked whenever
1704C<prev> != C<attr>. 1717C<prev> != C<attr>, or, more precisely, one or more of these members
1718differ: C<st_dev>, C<st_ino>, C<st_mode>, C<st_nlink>, C<st_uid>,
1719C<st_gid>, C<st_rdev>, C<st_size>, C<st_atime>, C<st_mtime>, C<st_ctime>.
1705 1720
1706=item ev_tstamp interval [read-only] 1721=item ev_tstamp interval [read-only]
1707 1722
1708The specified interval. 1723The specified interval.
1709 1724
1763 } 1778 }
1764 1779
1765 ... 1780 ...
1766 ev_stat_init (&passwd, stat_cb, "/etc/passwd", 0.); 1781 ev_stat_init (&passwd, stat_cb, "/etc/passwd", 0.);
1767 ev_stat_start (loop, &passwd); 1782 ev_stat_start (loop, &passwd);
1768 ev_timer_init (&timer, timer_cb, 0., 1.01); 1783 ev_timer_init (&timer, timer_cb, 0., 1.02);
1769 1784
1770 1785
1771=head2 C<ev_idle> - when you've got nothing better to do... 1786=head2 C<ev_idle> - when you've got nothing better to do...
1772 1787
1773Idle watchers trigger events when no other events of the same or higher 1788Idle watchers trigger events when no other events of the same or higher
1861 1876
1862It is recommended to give C<ev_check> watchers highest (C<EV_MAXPRI>) 1877It is recommended to give C<ev_check> watchers highest (C<EV_MAXPRI>)
1863priority, to ensure that they are being run before any other watchers 1878priority, to ensure that they are being run before any other watchers
1864after the poll. Also, C<ev_check> watchers (and C<ev_prepare> watchers, 1879after the poll. Also, C<ev_check> watchers (and C<ev_prepare> watchers,
1865too) should not activate ("feed") events into libev. While libev fully 1880too) should not activate ("feed") events into libev. While libev fully
1866supports this, they will be called before other C<ev_check> watchers 1881supports this, they might get executed before other C<ev_check> watchers
1867did their job. As C<ev_check> watchers are often used to embed other 1882did their job. As C<ev_check> watchers are often used to embed other
1868(non-libev) event loops those other event loops might be in an unusable 1883(non-libev) event loops those other event loops might be in an unusable
1869state until their C<ev_check> watcher ran (always remind yourself to 1884state until their C<ev_check> watcher ran (always remind yourself to
1870coexist peacefully with others). 1885coexist peacefully with others).
1871 1886
1886=head3 Examples 1901=head3 Examples
1887 1902
1888There are a number of principal ways to embed other event loops or modules 1903There are a number of principal ways to embed other event loops or modules
1889into libev. Here are some ideas on how to include libadns into libev 1904into libev. Here are some ideas on how to include libadns into libev
1890(there is a Perl module named C<EV::ADNS> that does this, which you could 1905(there is a Perl module named C<EV::ADNS> that does this, which you could
1891use for an actually working example. Another Perl module named C<EV::Glib> 1906use as a working example. Another Perl module named C<EV::Glib> embeds a
1892embeds a Glib main context into libev, and finally, C<Glib::EV> embeds EV 1907Glib main context into libev, and finally, C<Glib::EV> embeds EV into the
1893into the Glib event loop). 1908Glib event loop).
1894 1909
1895Method 1: Add IO watchers and a timeout watcher in a prepare handler, 1910Method 1: Add IO watchers and a timeout watcher in a prepare handler,
1896and in a check watcher, destroy them and call into libadns. What follows 1911and in a check watcher, destroy them and call into libadns. What follows
1897is pseudo-code only of course. This requires you to either use a low 1912is pseudo-code only of course. This requires you to either use a low
1898priority for the check watcher or use C<ev_clear_pending> explicitly, as 1913priority for the check watcher or use C<ev_clear_pending> explicitly, as
2382 2397
2383=item * Priorities are not currently supported. Initialising priorities 2398=item * Priorities are not currently supported. Initialising priorities
2384will fail and all watchers will have the same priority, even though there 2399will fail and all watchers will have the same priority, even though there
2385is an ev_pri field. 2400is an ev_pri field.
2386 2401
2402=item * In libevent, the last base created gets the signals, in libev, the
2403first base created (== the default loop) gets the signals.
2404
2387=item * Other members are not supported. 2405=item * Other members are not supported.
2388 2406
2389=item * The libev emulation is I<not> ABI compatible to libevent, you need 2407=item * The libev emulation is I<not> ABI compatible to libevent, you need
2390to use the libev header file and library. 2408to use the libev header file and library.
2391 2409
2967defined to be C<0>, then they are not. 2985defined to be C<0>, then they are not.
2968 2986
2969=item EV_MINIMAL 2987=item EV_MINIMAL
2970 2988
2971If you need to shave off some kilobytes of code at the expense of some 2989If you need to shave off some kilobytes of code at the expense of some
2972speed, define this symbol to C<1>. Currently only used for gcc to override 2990speed, define this symbol to C<1>. Currently this is used to override some
2973some inlining decisions, saves roughly 30% codesize of amd64. 2991inlining decisions, saves roughly 30% codesize of amd64. It also selects a
2992much smaller 2-heap for timer management over the default 4-heap.
2974 2993
2975=item EV_PID_HASHSIZE 2994=item EV_PID_HASHSIZE
2976 2995
2977C<ev_child> watchers use a small hash table to distribute workload by 2996C<ev_child> watchers use a small hash table to distribute workload by
2978pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more 2997pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
2984C<ev_stat> watchers use a small hash table to distribute workload by 3003C<ev_stat> watchers use a small hash table to distribute workload by
2985inotify watch id. The default size is C<16> (or C<1> with C<EV_MINIMAL>), 3004inotify watch id. The default size is C<16> (or C<1> with C<EV_MINIMAL>),
2986usually more than enough. If you need to manage thousands of C<ev_stat> 3005usually more than enough. If you need to manage thousands of C<ev_stat>
2987watchers you might want to increase this value (I<must> be a power of 3006watchers you might want to increase this value (I<must> be a power of
2988two). 3007two).
3008
3009=item EV_USE_4HEAP
3010
3011Heaps are not very cache-efficient. To improve the cache-efficiency of the
3012timer and periodics heap, libev uses a 4-heap when this symbol is defined
3013to C<1>. The 4-heap uses more complicated (longer) code but has
3014noticably faster performance with many (thousands) of watchers.
3015
3016The default is C<1> unless C<EV_MINIMAL> is set in which case it is C<0>
3017(disabled).
3018
3019=item EV_HEAP_CACHE_AT
3020
3021Heaps are not very cache-efficient. To improve the cache-efficiency of the
3022timer and periodics heap, libev can cache the timestamp (I<at>) within
3023the heap structure (selected by defining C<EV_HEAP_CACHE_AT> to C<1>),
3024which uses 8-12 bytes more per watcher and a few hundred bytes more code,
3025but avoids random read accesses on heap changes. This improves performance
3026noticably with with many (hundreds) of watchers.
3027
3028The default is C<1> unless C<EV_MINIMAL> is set in which case it is C<0>
3029(disabled).
2989 3030
2990=item EV_COMMON 3031=item EV_COMMON
2991 3032
2992By default, all watchers have a C<void *data> member. By redefining 3033By default, all watchers have a C<void *data> member. By redefining
2993this macro to a something else you can include more and other types of 3034this macro to a something else you can include more and other types of
3067 3108
3068 #include "ev_cpp.h" 3109 #include "ev_cpp.h"
3069 #include "ev.c" 3110 #include "ev.c"
3070 3111
3071 3112
3113=head1 THREADS AND COROUTINES
3114
3115=head2 THREADS
3116
3117Libev itself is completely threadsafe, but it uses no locking. This
3118means that you can use as many loops as you want in parallel, as long as
3119only one thread ever calls into one libev function with the same loop
3120parameter.
3121
3122Or put differently: calls with different loop parameters can be done in
3123parallel from multiple threads, calls with the same loop parameter must be
3124done serially (but can be done from different threads, as long as only one
3125thread ever is inside a call at any point in time, e.g. by using a mutex
3126per loop).
3127
3128If you want to know which design is best for your problem, then I cannot
3129help you but by giving some generic advice:
3130
3131=over 4
3132
3133=item * most applications have a main thread: use the default libev loop
3134in that thread, or create a seperate thread running only the default loop.
3135
3136This helps integrating other libraries or software modules that use libev
3137themselves and don't care/know about threading.
3138
3139=item * one loop per thread is usually a good model.
3140
3141Doing this is almost never wrong, sometimes a better-performance model
3142exists, but it is always a good start.
3143
3144=item * other models exist, such as the leader/follower pattern, where one
3145loop is handed through multiple threads in a kind of round-robbin fashion.
3146
3147Chosing a model is hard - look around, learn, know that usually you cna do
3148better than you currently do :-)
3149
3150=item * often you need to talk to some other thread which blocks in the
3151event loop - C<ev_async> watchers can be used to wake them up from other
3152threads safely (or from signal contexts...).
3153
3154=back
3155
3156=head2 COROUTINES
3157
3158Libev is much more accomodating to coroutines ("cooperative threads"):
3159libev fully supports nesting calls to it's functions from different
3160coroutines (e.g. you can call C<ev_loop> on the same loop from two
3161different coroutines and switch freely between both coroutines running the
3162loop, as long as you don't confuse yourself). The only exception is that
3163you must not do this from C<ev_periodic> reschedule callbacks.
3164
3165Care has been invested into making sure that libev does not keep local
3166state inside C<ev_loop>, and other calls do not usually allow coroutine
3167switches.
3168
3169
3072=head1 COMPLEXITIES 3170=head1 COMPLEXITIES
3073 3171
3074In this section the complexities of (many of) the algorithms used inside 3172In this section the complexities of (many of) the algorithms used inside
3075libev will be explained. For complexity discussions about backends see the 3173libev will be explained. For complexity discussions about backends see the
3076documentation for C<ev_default_init>. 3174documentation for C<ev_default_init>.
3106correct watcher to remove. The lists are usually short (you don't usually 3204correct watcher to remove. The lists are usually short (you don't usually
3107have many watchers waiting for the same fd or signal). 3205have many watchers waiting for the same fd or signal).
3108 3206
3109=item Finding the next timer in each loop iteration: O(1) 3207=item Finding the next timer in each loop iteration: O(1)
3110 3208
3111By virtue of using a binary heap, the next timer is always found at the 3209By virtue of using a binary or 4-heap, the next timer is always found at a
3112beginning of the storage array. 3210fixed position in the storage array.
3113 3211
3114=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd) 3212=item Each change on a file descriptor per loop iteration: O(number_of_watchers_for_this_fd)
3115 3213
3116A change means an I/O watcher gets started or stopped, which requires 3214A change means an I/O watcher gets started or stopped, which requires
3117libev to recalculate its status (and possibly tell the kernel, depending 3215libev to recalculate its status (and possibly tell the kernel, depending
3146model. Libev still offers limited functionality on this platform in 3244model. Libev still offers limited functionality on this platform in
3147the form of the C<EVBACKEND_SELECT> backend, and only supports socket 3245the form of the C<EVBACKEND_SELECT> backend, and only supports socket
3148descriptors. This only applies when using Win32 natively, not when using 3246descriptors. This only applies when using Win32 natively, not when using
3149e.g. cygwin. 3247e.g. cygwin.
3150 3248
3249Lifting these limitations would basically require the full
3250re-implementation of the I/O system. If you are into these kinds of
3251things, then note that glib does exactly that for you in a very portable
3252way (note also that glib is the slowest event library known to man).
3253
3151There is no supported compilation method available on windows except 3254There is no supported compilation method available on windows except
3152embedding it into other applications. 3255embedding it into other applications.
3153 3256
3154Due to the many, low, and arbitrary limits on the win32 platform and the 3257Due to the many, low, and arbitrary limits on the win32 platform and
3155abysmal performance of winsockets, using a large number of sockets is not 3258the abysmal performance of winsockets, using a large number of sockets
3156recommended (and not reasonable). If your program needs to use more than 3259is not recommended (and not reasonable). If your program needs to use
3157a hundred or so sockets, then likely it needs to use a totally different 3260more than a hundred or so sockets, then likely it needs to use a totally
3158implementation for windows, as libev offers the POSIX model, which cannot 3261different implementation for windows, as libev offers the POSIX readiness
3159be implemented efficiently on windows (microsoft monopoly games). 3262notification model, which cannot be implemented efficiently on windows
3263(microsoft monopoly games).
3160 3264
3161=over 4 3265=over 4
3162 3266
3163=item The winsocket select function 3267=item The winsocket select function
3164 3268
3178Note that winsockets handling of fd sets is O(n), so you can easily get a 3282Note that winsockets handling of fd sets is O(n), so you can easily get a
3179complexity in the O(n²) range when using win32. 3283complexity in the O(n²) range when using win32.
3180 3284
3181=item Limited number of file descriptors 3285=item Limited number of file descriptors
3182 3286
3183Windows has numerous arbitrary (and low) limits on things. Early versions 3287Windows has numerous arbitrary (and low) limits on things.
3184of winsocket's select only supported waiting for a max. of C<64> handles 3288
3289Early versions of winsocket's select only supported waiting for a maximum
3185(probably owning to the fact that all windows kernels can only wait for 3290of C<64> handles (probably owning to the fact that all windows kernels
3186C<64> things at the same time internally; microsoft recommends spawning a 3291can only wait for C<64> things at the same time internally; microsoft
3187chain of threads and wait for 63 handles and the previous thread in each). 3292recommends spawning a chain of threads and wait for 63 handles and the
3293previous thread in each. Great).
3188 3294
3189Newer versions support more handles, but you need to define C<FD_SETSIZE> 3295Newer versions support more handles, but you need to define C<FD_SETSIZE>
3190to some high number (e.g. C<2048>) before compiling the winsocket select 3296to some high number (e.g. C<2048>) before compiling the winsocket select
3191call (which might be in libev or elsewhere, for example, perl does its own 3297call (which might be in libev or elsewhere, for example, perl does its own
3192select emulation on windows). 3298select emulation on windows).
3204calling select (O(n²)) will likely make this unworkable. 3310calling select (O(n²)) will likely make this unworkable.
3205 3311
3206=back 3312=back
3207 3313
3208 3314
3315=head1 PORTABILITY REQUIREMENTS
3316
3317In addition to a working ISO-C implementation, libev relies on a few
3318additional extensions:
3319
3320=over 4
3321
3322=item C<sig_atomic_t volatile> must be thread-atomic as well
3323
3324The type C<sig_atomic_t volatile> (or whatever is defined as
3325C<EV_ATOMIC_T>) must be atomic w.r.t. accesses from different
3326threads. This is not part of the specification for C<sig_atomic_t>, but is
3327believed to be sufficiently portable.
3328
3329=item C<sigprocmask> must work in a threaded environment
3330
3331Libev uses C<sigprocmask> to temporarily block signals. This is not
3332allowed in a threaded program (C<pthread_sigmask> has to be used). Typical
3333pthread implementations will either allow C<sigprocmask> in the "main
3334thread" or will block signals process-wide, both behaviours would
3335be compatible with libev. Interaction between C<sigprocmask> and
3336C<pthread_sigmask> could complicate things, however.
3337
3338The most portable way to handle signals is to block signals in all threads
3339except the initial one, and run the default loop in the initial thread as
3340well.
3341
3342=item C<long> must be large enough for common memory allocation sizes
3343
3344To improve portability and simplify using libev, libev uses C<long>
3345internally instead of C<size_t> when allocating its data structures. On
3346non-POSIX systems (Microsoft...) this might be unexpectedly low, but
3347is still at least 31 bits everywhere, which is enough for hundreds of
3348millions of watchers.
3349
3350=item C<double> must hold a time value in seconds with enough accuracy
3351
3352The type C<double> is used to represent timestamps. It is required to
3353have at least 51 bits of mantissa (and 9 bits of exponent), which is good
3354enough for at least into the year 4000. This requirement is fulfilled by
3355implementations implementing IEEE 754 (basically all existing ones).
3356
3357=back
3358
3359If you know of other additional requirements drop me a note.
3360
3361
3362=head1 VALGRIND
3363
3364Valgrind has a special section here because it is a popular tool that is
3365highly useful, but valgrind reports are very hard to interpret.
3366
3367If you think you found a bug (memory leak, uninitialised data access etc.)
3368in libev, then check twice: If valgrind reports something like:
3369
3370 ==2274== definitely lost: 0 bytes in 0 blocks.
3371 ==2274== possibly lost: 0 bytes in 0 blocks.
3372 ==2274== still reachable: 256 bytes in 1 blocks.
3373
3374then there is no memory leak. Similarly, under some circumstances,
3375valgrind might report kernel bugs as if it were a bug in libev, or it
3376might be confused (it is a very good tool, but only a tool).
3377
3378If you are unsure about something, feel free to contact the mailing list
3379with the full valgrind report and an explanation on why you think this is
3380a bug in libev. However, don't be annoyed when you get a brisk "this is
3381no bug" answer and take the chance of learning how to interpret valgrind
3382properly.
3383
3384If you need, for some reason, empty reports from valgrind for your project
3385I suggest using suppression lists.
3386
3387
3209=head1 AUTHOR 3388=head1 AUTHOR
3210 3389
3211Marc Lehmann <libev@schmorp.de>. 3390Marc Lehmann <libev@schmorp.de>.
3212 3391

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines