2007-11-12 07:58:13 +00:00
|
|
|
=head1 NAME
|
|
|
|
|
|
|
|
libev - a high performance full-featured event loop written in C
|
|
|
|
|
|
|
|
=head1 SYNOPSIS
|
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
#include <ev.h>
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-23 03:50:10 +00:00
|
|
|
=head2 EXAMPLE PROGRAM
|
2007-11-27 20:26:50 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
// a single header file is required
|
|
|
|
#include <ev.h>
|
|
|
|
|
|
|
|
// every watcher type has its own typedef'd struct
|
2008-10-23 07:33:45 +00:00
|
|
|
// with the name ev_TYPE
|
2008-05-31 23:22:23 +00:00
|
|
|
ev_io stdin_watcher;
|
|
|
|
ev_timer timeout_watcher;
|
|
|
|
|
|
|
|
// all watcher callbacks have a similar signature
|
|
|
|
// this callback is called when data is readable on stdin
|
|
|
|
static void
|
2008-10-23 06:30:48 +00:00
|
|
|
stdin_cb (EV_P_ ev_io *w, int revents)
|
2008-05-31 23:22:23 +00:00
|
|
|
{
|
|
|
|
puts ("stdin ready");
|
|
|
|
// for one-shot events, one must manually stop the watcher
|
|
|
|
// with its corresponding stop function.
|
|
|
|
ev_io_stop (EV_A_ w);
|
|
|
|
|
|
|
|
// this causes all nested ev_loop's to stop iterating
|
|
|
|
ev_unloop (EV_A_ EVUNLOOP_ALL);
|
|
|
|
}
|
|
|
|
|
|
|
|
// another callback, this time for a time-out
|
|
|
|
static void
|
2008-10-23 06:30:48 +00:00
|
|
|
timeout_cb (EV_P_ ev_timer *w, int revents)
|
2008-05-31 23:22:23 +00:00
|
|
|
{
|
|
|
|
puts ("timeout");
|
|
|
|
// this causes the innermost ev_loop to stop iterating
|
|
|
|
ev_unloop (EV_A_ EVUNLOOP_ONE);
|
|
|
|
}
|
|
|
|
|
|
|
|
int
|
|
|
|
main (void)
|
|
|
|
{
|
|
|
|
// use the default event loop unless you have special needs
|
2008-10-23 06:30:48 +00:00
|
|
|
ev_loop *loop = ev_default_loop (0);
|
2008-05-31 23:22:23 +00:00
|
|
|
|
|
|
|
// initialise an io watcher, then start it
|
|
|
|
// this one will watch for stdin to become readable
|
|
|
|
ev_io_init (&stdin_watcher, stdin_cb, /*STDIN_FILENO*/ 0, EV_READ);
|
|
|
|
ev_io_start (loop, &stdin_watcher);
|
|
|
|
|
|
|
|
// initialise a timer watcher, then start it
|
|
|
|
// simple non-repeating 5.5 second timeout
|
|
|
|
ev_timer_init (&timeout_watcher, timeout_cb, 5.5, 0.);
|
|
|
|
ev_timer_start (loop, &timeout_watcher);
|
|
|
|
|
|
|
|
// now wait for events to arrive
|
|
|
|
ev_loop (loop, 0);
|
|
|
|
|
|
|
|
// unloop was called, so exit
|
|
|
|
return 0;
|
|
|
|
}
|
2007-11-27 20:15:01 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=head1 DESCRIPTION
|
|
|
|
|
2008-03-08 10:38:40 +00:00
|
|
|
The newest version of this document is also available as an html-formatted
|
2007-12-07 19:15:39 +00:00
|
|
|
web page you might find easier to navigate when reading it for the first
|
2008-05-11 11:47:27 +00:00
|
|
|
time: L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>.
|
2007-12-07 19:15:39 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
Libev is an event loop: you register interest in certain events (such as a
|
2007-12-21 01:26:04 +00:00
|
|
|
file descriptor being readable or a timeout occurring), and it will manage
|
2007-11-12 08:11:01 +00:00
|
|
|
these event sources and provide your program with events.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
To do this, it must take more or less complete control over your process
|
|
|
|
(or thread) by executing the I<event loop> handler, and will then
|
|
|
|
communicate events via a callback mechanism.
|
|
|
|
|
|
|
|
You register interest in certain events by registering so-called I<event
|
|
|
|
watchers>, which are relatively small C structures you initialise with the
|
|
|
|
details of the event, and then hand it over to libev by I<starting> the
|
|
|
|
watcher.
|
|
|
|
|
2007-12-23 03:50:10 +00:00
|
|
|
=head2 FEATURES
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-28 11:27:29 +00:00
|
|
|
Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the
|
|
|
|
BSD-specific C<kqueue> and the Solaris-specific event port mechanisms
|
|
|
|
for file descriptor events (C<ev_io>), the Linux C<inotify> interface
|
|
|
|
(for C<ev_stat>), relative timers (C<ev_timer>), absolute timers
|
|
|
|
with customised rescheduling (C<ev_periodic>), synchronous signals
|
|
|
|
(C<ev_signal>), process status change events (C<ev_child>), and event
|
|
|
|
watchers dealing with the event loop mechanism itself (C<ev_idle>,
|
2007-11-27 20:26:50 +00:00
|
|
|
C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as
|
|
|
|
file watchers (C<ev_stat>) and even limited support for fork events
|
|
|
|
(C<ev_fork>).
|
|
|
|
|
|
|
|
It also is quite fast (see this
|
|
|
|
L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent
|
|
|
|
for example).
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-23 03:50:10 +00:00
|
|
|
=head2 CONVENTIONS
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-03-08 10:38:40 +00:00
|
|
|
Libev is very configurable. In this manual the default (and most common)
|
|
|
|
configuration will be described, which supports multiple event loops. For
|
|
|
|
more info about various configuration options please have a look at
|
|
|
|
B<EMBED> section in this manual. If libev was configured without support
|
|
|
|
for multiple event loops, then all functions taking an initial argument of
|
2008-10-23 06:30:48 +00:00
|
|
|
name C<loop> (which is always of type C<ev_loop *>) will not have
|
2008-03-08 10:38:40 +00:00
|
|
|
this argument.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-23 03:50:10 +00:00
|
|
|
=head2 TIME REPRESENTATION
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
Libev represents time as a single floating point number, representing the
|
|
|
|
(fractional) number of seconds since the (POSIX) epoch (somewhere near
|
|
|
|
the beginning of 1970, details are complicated, don't ask). This type is
|
2007-11-12 07:58:13 +00:00
|
|
|
called C<ev_tstamp>, which is what you should use too. It usually aliases
|
2007-11-23 16:17:12 +00:00
|
|
|
to the C<double> type in C, and when you need to do any calculations on
|
2008-05-24 03:08:03 +00:00
|
|
|
it, you should treat it as some floating point value. Unlike the name
|
2007-12-18 01:20:33 +00:00
|
|
|
component C<stamp> might indicate, it is also used for time differences
|
|
|
|
throughout libev.
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2008-05-22 03:06:58 +00:00
|
|
|
=head1 ERROR HANDLING
|
|
|
|
|
|
|
|
Libev knows three classes of errors: operating system errors, usage errors
|
|
|
|
and internal errors (bugs).
|
|
|
|
|
|
|
|
When libev catches an operating system error it cannot handle (for example
|
2008-05-24 03:08:03 +00:00
|
|
|
a system call indicating a condition libev cannot fix), it calls the callback
|
2008-05-22 03:06:58 +00:00
|
|
|
set via C<ev_set_syserr_cb>, which is supposed to fix the problem or
|
|
|
|
abort. The default is to print a diagnostic message and to call C<abort
|
|
|
|
()>.
|
|
|
|
|
|
|
|
When libev detects a usage error such as a negative timer interval, then
|
|
|
|
it will print a diagnostic message and abort (via the C<assert> mechanism,
|
|
|
|
so C<NDEBUG> will disable this checking): these are programming errors in
|
|
|
|
the libev caller and need to be fixed there.
|
|
|
|
|
|
|
|
Libev also has a few internal error-checking C<assert>ions, and also has
|
|
|
|
extensive consistency checking code. These do not trigger under normal
|
|
|
|
circumstances, as they indicate either a bug in libev or worse.
|
|
|
|
|
|
|
|
|
2007-11-12 08:57:03 +00:00
|
|
|
=head1 GLOBAL FUNCTIONS
|
|
|
|
|
2007-11-12 08:57:03 +00:00
|
|
|
These functions can be called anytime, even before initialising the
|
|
|
|
library in any way.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=over 4
|
|
|
|
|
|
|
|
=item ev_tstamp ev_time ()
|
|
|
|
|
2007-11-13 03:11:57 +00:00
|
|
|
Returns the current time as libev would use it. Please note that the
|
|
|
|
C<ev_now> function is usually faster and also often returns the timestamp
|
|
|
|
you actually want to know.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-22 05:47:56 +00:00
|
|
|
=item ev_sleep (ev_tstamp interval)
|
|
|
|
|
|
|
|
Sleep for the given interval: The current thread will be blocked until
|
|
|
|
either it is interrupted or the given time interval has passed. Basically
|
2008-05-24 03:08:03 +00:00
|
|
|
this is a sub-second-resolution C<sleep ()>.
|
2007-12-22 05:47:56 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item int ev_version_major ()
|
|
|
|
|
|
|
|
=item int ev_version_minor ()
|
|
|
|
|
2007-12-09 19:42:57 +00:00
|
|
|
You can find out the major and minor ABI version numbers of the library
|
2007-11-12 07:58:13 +00:00
|
|
|
you linked against by calling the functions C<ev_version_major> and
|
|
|
|
C<ev_version_minor>. If you want, you can compare against the global
|
|
|
|
symbols C<EV_VERSION_MAJOR> and C<EV_VERSION_MINOR>, which specify the
|
|
|
|
version of the library your program was compiled against.
|
|
|
|
|
2007-12-09 19:42:57 +00:00
|
|
|
These version numbers refer to the ABI version of the library, not the
|
|
|
|
release version.
|
2007-12-09 19:42:57 +00:00
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
Usually, it's a good idea to terminate if the major versions mismatch,
|
2007-12-09 19:42:57 +00:00
|
|
|
as this indicates an incompatible change. Minor versions are usually
|
2007-11-12 07:58:13 +00:00
|
|
|
compatible to older versions, so a larger minor version alone is usually
|
|
|
|
not a problem.
|
|
|
|
|
2007-11-27 20:26:50 +00:00
|
|
|
Example: Make sure we haven't accidentally been linked against the wrong
|
|
|
|
version.
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
assert (("libev version mismatch",
|
|
|
|
ev_version_major () == EV_VERSION_MAJOR
|
|
|
|
&& ev_version_minor () >= EV_VERSION_MINOR));
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item unsigned int ev_supported_backends ()
|
|
|
|
|
|
|
|
Return the set of all backends (i.e. their corresponding C<EV_BACKEND_*>
|
|
|
|
value) compiled into this binary of libev (independent of their
|
|
|
|
availability on the system you are running on). See C<ev_default_loop> for
|
|
|
|
a description of the set values.
|
|
|
|
|
2007-11-23 16:17:12 +00:00
|
|
|
Example: make sure we have the epoll method, because yeah this is cool and
|
|
|
|
a must have and can we have a torrent of it please!!!11
|
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
assert (("sorry, no epoll, no sex",
|
|
|
|
ev_supported_backends () & EVBACKEND_EPOLL));
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item unsigned int ev_recommended_backends ()
|
|
|
|
|
|
|
|
Return the set of all backends compiled into this binary of libev and also
|
|
|
|
recommended for this platform. This set is often smaller than the one
|
|
|
|
returned by C<ev_supported_backends>, as for example kqueue is broken on
|
2008-05-24 03:08:03 +00:00
|
|
|
most BSDs and will not be auto-detected unless you explicitly request it
|
2007-11-23 05:00:44 +00:00
|
|
|
(assuming you know what you are doing). This is the set of backends that
|
2007-11-23 15:26:08 +00:00
|
|
|
libev will probe for if you specify no backends explicitly.
|
2007-11-23 05:00:44 +00:00
|
|
|
|
2007-11-23 19:35:09 +00:00
|
|
|
=item unsigned int ev_embeddable_backends ()
|
|
|
|
|
|
|
|
Returns the set of backends that are embeddable in other event loops. This
|
|
|
|
is the theoretical, all-platform, value. To find which backends
|
|
|
|
might be supported on the current system, you would need to look at
|
|
|
|
C<ev_embeddable_backends () & ev_supported_backends ()>, likewise for
|
|
|
|
recommended ones.
|
|
|
|
|
|
|
|
See the description of C<ev_embed> watchers for more info.
|
|
|
|
|
2008-09-24 07:56:14 +00:00
|
|
|
=item ev_set_allocator (void *(*cb)(void *ptr, long size)) [NOT REENTRANT]
|
2007-11-28 17:32:24 +00:00
|
|
|
|
|
|
|
Sets the allocation function to use (the prototype is similar - the
|
2008-04-09 22:07:50 +00:00
|
|
|
semantics are identical to the C<realloc> C89/SuS/POSIX function). It is
|
|
|
|
used to allocate and free memory (no surprises here). If it returns zero
|
|
|
|
when memory needs to be allocated (C<size != 0>), the library might abort
|
|
|
|
or take some potentially destructive action.
|
|
|
|
|
|
|
|
Since some systems (at least OpenBSD and Darwin) fail to implement
|
|
|
|
correct C<realloc> semantics, libev will use a wrapper around the system
|
|
|
|
C<realloc> and C<free> functions by default.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
You could override this function in high-availability programs to, say,
|
|
|
|
free some memory if it cannot allocate memory, to use a special allocator,
|
|
|
|
or even to sleep a while and retry until some memory is available.
|
|
|
|
|
2007-11-27 20:26:50 +00:00
|
|
|
Example: Replace the libev allocator with one that waits a bit and then
|
2008-04-09 22:07:50 +00:00
|
|
|
retries (example requires a standards-compliant C<realloc>).
|
2007-11-23 16:17:12 +00:00
|
|
|
|
|
|
|
static void *
|
2007-11-27 19:41:52 +00:00
|
|
|
persistent_realloc (void *ptr, size_t size)
|
2007-11-23 16:17:12 +00:00
|
|
|
{
|
|
|
|
for (;;)
|
|
|
|
{
|
|
|
|
void *newptr = realloc (ptr, size);
|
|
|
|
|
|
|
|
if (newptr)
|
|
|
|
return newptr;
|
|
|
|
|
|
|
|
sleep (60);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
...
|
|
|
|
ev_set_allocator (persistent_realloc);
|
|
|
|
|
2008-09-24 07:56:14 +00:00
|
|
|
=item ev_set_syserr_cb (void (*cb)(const char *msg)); [NOT REENTRANT]
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
Set the callback function to call on a retryable system call error (such
|
2007-11-12 07:58:13 +00:00
|
|
|
as failed select, poll, epoll_wait). The message is a printable string
|
|
|
|
indicating the system call or subsystem causing the problem. If this
|
2008-05-24 03:08:03 +00:00
|
|
|
callback is set, then libev will expect it to remedy the situation, no
|
2007-11-12 08:16:02 +00:00
|
|
|
matter what, when it returns. That is, libev will generally retry the
|
2007-11-12 07:58:13 +00:00
|
|
|
requested operation, or, if the condition doesn't go away, do bad stuff
|
|
|
|
(such as abort).
|
|
|
|
|
2007-11-27 20:26:50 +00:00
|
|
|
Example: This is basically the same thing that libev does internally, too.
|
2007-11-23 16:17:12 +00:00
|
|
|
|
|
|
|
static void
|
|
|
|
fatal_error (const char *msg)
|
|
|
|
{
|
|
|
|
perror (msg);
|
|
|
|
abort ();
|
|
|
|
}
|
|
|
|
|
|
|
|
...
|
|
|
|
ev_set_syserr_cb (fatal_error);
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=back
|
|
|
|
|
|
|
|
=head1 FUNCTIONS CONTROLLING THE EVENT LOOP
|
|
|
|
|
2008-10-23 07:33:45 +00:00
|
|
|
An event loop is described by a C<struct ev_loop *> (the C<struct>
|
|
|
|
is I<not> optional in this case, as there is also an C<ev_loop>
|
|
|
|
I<function>).
|
|
|
|
|
|
|
|
The library knows two types of such loops, the I<default> loop, which
|
|
|
|
supports signals and child events, and dynamically created loops which do
|
|
|
|
not.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
=over 4
|
|
|
|
|
|
|
|
=item struct ev_loop *ev_default_loop (unsigned int flags)
|
|
|
|
|
|
|
|
This will initialise the default event loop if it hasn't been initialised
|
|
|
|
yet and return it. If the default loop could not be initialised, returns
|
|
|
|
false. If it already was initialised it simply returns it (and ignores the
|
2007-11-23 05:00:44 +00:00
|
|
|
flags. If that is troubling you, check C<ev_backend ()> afterwards).
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
If you don't know what event loop to use, use the one returned from this
|
|
|
|
function.
|
|
|
|
|
2008-04-02 05:51:40 +00:00
|
|
|
Note that this function is I<not> thread-safe, so if you want to use it
|
|
|
|
from multiple threads, you have to lock (note also that this is unlikely,
|
2008-10-29 10:24:23 +00:00
|
|
|
as loops cannot be shared easily between threads anyway).
|
2008-04-02 05:51:40 +00:00
|
|
|
|
2008-01-10 06:00:55 +00:00
|
|
|
The default loop is the only loop that can handle C<ev_signal> and
|
|
|
|
C<ev_child> watchers, and to do this, it always registers a handler
|
2008-05-24 03:08:03 +00:00
|
|
|
for C<SIGCHLD>. If this is a problem for your application you can either
|
2008-01-10 06:00:55 +00:00
|
|
|
create a dynamic loop with C<ev_loop_new> that doesn't do that, or you
|
|
|
|
can simply overwrite the C<SIGCHLD> signal handler I<after> calling
|
|
|
|
C<ev_default_init>.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
The flags argument can be used to specify special behaviour or specific
|
2007-11-23 15:26:08 +00:00
|
|
|
backends to use, and is usually specified as C<0> (or C<EVFLAG_AUTO>).
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-23 15:26:08 +00:00
|
|
|
The following flags are supported:
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
=over 4
|
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
=item C<EVFLAG_AUTO>
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
The default flags value. Use this if you have no clue (it's the right
|
2007-11-12 07:58:13 +00:00
|
|
|
thing, believe me).
|
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
=item C<EVFLAG_NOENV>
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
If this flag bit is or'ed into the flag value (or the program runs setuid
|
2007-11-12 08:16:02 +00:00
|
|
|
or setgid) then libev will I<not> look at the environment variable
|
|
|
|
C<LIBEV_FLAGS>. Otherwise (the default), this environment variable will
|
|
|
|
override the flags completely if it is found in the environment. This is
|
|
|
|
useful to try out specific backends to test their performance, or to work
|
|
|
|
around bugs.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-29 17:28:13 +00:00
|
|
|
=item C<EVFLAG_FORKCHECK>
|
|
|
|
|
|
|
|
Instead of calling C<ev_default_fork> or C<ev_loop_fork> manually after
|
|
|
|
a fork, you can also make libev check for a fork in each iteration by
|
|
|
|
enabling this flag.
|
|
|
|
|
|
|
|
This works by calling C<getpid ()> on every iteration of the loop,
|
|
|
|
and thus this might slow down your event loop if you do a lot of loop
|
2007-12-01 15:38:54 +00:00
|
|
|
iterations and little real work, but is usually not noticeable (on my
|
2008-03-08 10:38:40 +00:00
|
|
|
GNU/Linux system for example, C<getpid> is actually a simple 5-insn sequence
|
2008-05-24 03:08:03 +00:00
|
|
|
without a system call and thus I<very> fast, but my GNU/Linux system also has
|
2007-11-29 17:28:13 +00:00
|
|
|
C<pthread_atfork> which is even faster).
|
|
|
|
|
|
|
|
The big advantage of this flag is that you can forget about fork (and
|
|
|
|
forget about forgetting to tell libev about forking) when you use this
|
|
|
|
flag.
|
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS>
|
2007-11-29 17:28:13 +00:00
|
|
|
environment variable.
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_SELECT> (value 1, portable select backend)
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-22 12:28:27 +00:00
|
|
|
This is your standard select(2) backend. Not I<completely> standard, as
|
|
|
|
libev tries to roll its own fd_set with no limits on the number of fds,
|
|
|
|
but if that fails, expect a fairly low limit on the number of fds when
|
2007-12-22 16:21:25 +00:00
|
|
|
using this backend. It doesn't scale too well (O(highest_fd)), but its
|
|
|
|
usually the fastest backend for a low number of (low-numbered :) fds.
|
|
|
|
|
|
|
|
To get good performance out of this backend you need a high amount of
|
2008-05-24 03:08:03 +00:00
|
|
|
parallelism (most of the file descriptors should be busy). If you are
|
2007-12-22 16:21:25 +00:00
|
|
|
writing a server, you should C<accept ()> in a loop to accept as many
|
|
|
|
connections as possible during one iteration. You might also want to have
|
|
|
|
a look at C<ev_set_io_collect_interval ()> to increase the amount of
|
2008-05-19 13:48:20 +00:00
|
|
|
readiness notifications you get per iteration.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-09-13 19:14:21 +00:00
|
|
|
This backend maps C<EV_READ> to the C<readfds> set and C<EV_WRITE> to the
|
|
|
|
C<writefds> set (and to work around Microsoft Windows bugs, also onto the
|
|
|
|
C<exceptfds> set on that platform).
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_POLL> (value 2, poll backend, available everywhere except on windows)
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-22 16:21:25 +00:00
|
|
|
And this is your standard poll(2) backend. It's more complicated
|
|
|
|
than select, but handles sparse fds better and has no artificial
|
|
|
|
limit on the number of fds you can use (except it will slow down
|
|
|
|
considerably with a lot of inactive fds). It scales similarly to select,
|
|
|
|
i.e. O(total_fds). See the entry for C<EVBACKEND_SELECT>, above, for
|
|
|
|
performance tips.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-09-13 19:14:21 +00:00
|
|
|
This backend maps C<EV_READ> to C<POLLIN | POLLERR | POLLHUP>, and
|
|
|
|
C<EV_WRITE> to C<POLLOUT | POLLERR | POLLHUP>.
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_EPOLL> (value 4, Linux)
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-22 12:28:27 +00:00
|
|
|
For few fds, this backend is a bit little slower than poll and select,
|
2007-12-21 04:38:45 +00:00
|
|
|
but it scales phenomenally better. While poll and select usually scale
|
|
|
|
like O(total_fds) where n is the total number of fds (or the highest fd),
|
2008-10-27 12:20:32 +00:00
|
|
|
epoll scales either O(1) or O(active_fds).
|
|
|
|
|
2008-10-30 08:09:30 +00:00
|
|
|
The epoll mechanism deserves honorable mention as the most misdesigned
|
|
|
|
of the more advanced event mechanisms: mere annoyances include silently
|
|
|
|
dropping file descriptors, requiring a system call per change per file
|
|
|
|
descriptor (and unnecessary guessing of parameters), problems with dup and
|
|
|
|
so on. The biggest issue is fork races, however - if a program forks then
|
|
|
|
I<both> parent and child process have to recreate the epoll set, which can
|
|
|
|
take considerable time (one syscall per file descriptor) and is of course
|
|
|
|
hard to detect.
|
|
|
|
|
|
|
|
Epoll is also notoriously buggy - embedding epoll fds I<should> work, but
|
|
|
|
of course I<doesn't>, and epoll just loves to report events for totally
|
2008-10-27 12:20:32 +00:00
|
|
|
I<different> file descriptors (even already closed ones, so one cannot
|
|
|
|
even remove them from the set) than registered in the set (especially
|
|
|
|
on SMP systems). Libev tries to counter these spurious notifications by
|
|
|
|
employing an additional generation counter and comparing that against the
|
2008-10-30 08:09:30 +00:00
|
|
|
events to filter out spurious ones, recreating the set when required.
|
2008-10-27 11:08:29 +00:00
|
|
|
|
2007-12-21 04:38:45 +00:00
|
|
|
While stopping, setting and starting an I/O watcher in the same iteration
|
2008-10-30 08:09:30 +00:00
|
|
|
will result in some caching, there is still a system call per such
|
|
|
|
incident (because the same I<file descriptor> could point to a different
|
|
|
|
I<file description> now), so its best to avoid that. Also, C<dup ()>'ed
|
|
|
|
file descriptors might not work very well if you register events for both
|
|
|
|
file descriptors.
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2007-12-22 16:21:25 +00:00
|
|
|
Best performance from this backend is achieved by not unregistering all
|
2008-09-23 08:37:38 +00:00
|
|
|
watchers for a file descriptor until it has been closed, if possible,
|
|
|
|
i.e. keep at least one watcher active per fd at all times. Stopping and
|
|
|
|
starting a watcher (without re-setting it) also usually doesn't cause
|
2008-10-28 12:31:38 +00:00
|
|
|
extra overhead. A fork can both result in spurious notifications as well
|
|
|
|
as in libev having to destroy and recreate the epoll object, which can
|
|
|
|
take considerable time and thus should be avoided.
|
2007-12-22 16:21:25 +00:00
|
|
|
|
2008-11-05 21:44:21 +00:00
|
|
|
All this means that, in practice, C<EVBACKEND_SELECT> can be as fast or
|
|
|
|
faster than epoll for maybe up to a hundred file descriptors, depending on
|
2008-11-05 03:52:15 +00:00
|
|
|
the usage. So sad.
|
2008-11-05 02:48:45 +00:00
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
While nominally embeddable in other event loops, this feature is broken in
|
2007-12-22 16:21:25 +00:00
|
|
|
all kernel versions tested so far.
|
|
|
|
|
2008-09-13 19:14:21 +00:00
|
|
|
This backend maps C<EV_READ> and C<EV_WRITE> in the same way as
|
|
|
|
C<EVBACKEND_POLL>.
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_KQUEUE> (value 8, most BSD clones)
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2008-10-30 08:09:30 +00:00
|
|
|
Kqueue deserves special mention, as at the time of this writing, it
|
|
|
|
was broken on all BSDs except NetBSD (usually it doesn't work reliably
|
|
|
|
with anything but sockets and pipes, except on Darwin, where of course
|
|
|
|
it's completely useless). Unlike epoll, however, whose brokenness
|
|
|
|
is by design, these kqueue bugs can (and eventually will) be fixed
|
|
|
|
without API changes to existing programs. For this reason it's not being
|
|
|
|
"auto-detected" unless you explicitly specify it in the flags (i.e. using
|
|
|
|
C<EVBACKEND_KQUEUE>) or libev was compiled on a known-to-be-good (-enough)
|
|
|
|
system like NetBSD.
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2007-12-22 11:49:17 +00:00
|
|
|
You still can embed kqueue into a normal poll or select backend and use it
|
|
|
|
only for sockets (after having made sure that sockets work with kqueue on
|
|
|
|
the target platform). See C<ev_embed> watchers for more info.
|
|
|
|
|
2007-11-22 12:28:27 +00:00
|
|
|
It scales in the same way as the epoll backend, but the interface to the
|
2007-12-22 11:49:17 +00:00
|
|
|
kernel is more efficient (which says nothing about its actual speed, of
|
|
|
|
course). While stopping, setting and starting an I/O watcher does never
|
2008-05-24 03:08:03 +00:00
|
|
|
cause an extra system call as with C<EVBACKEND_EPOLL>, it still adds up to
|
2008-10-28 12:31:38 +00:00
|
|
|
two event changes per incident. Support for C<fork ()> is very bad (but
|
|
|
|
sane, unlike epoll) and it drops fds silently in similarly hard-to-detect
|
|
|
|
cases
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2007-12-22 16:21:25 +00:00
|
|
|
This backend usually performs well under most conditions.
|
|
|
|
|
|
|
|
While nominally embeddable in other event loops, this doesn't work
|
|
|
|
everywhere, so you might need to test for this. And since it is broken
|
|
|
|
almost everywhere, you should only use it when you have a lot of sockets
|
|
|
|
(for which it usually works), by embedding it into another event loop
|
2008-09-23 08:37:38 +00:00
|
|
|
(e.g. C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>) and, did I mention it,
|
|
|
|
using it only for sockets.
|
2007-12-22 16:21:25 +00:00
|
|
|
|
2008-09-13 19:14:21 +00:00
|
|
|
This backend maps C<EV_READ> into an C<EVFILT_READ> kevent with
|
|
|
|
C<NOTE_EOF>, and C<EV_WRITE> into an C<EVFILT_WRITE> kevent with
|
|
|
|
C<NOTE_EOF>.
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_DEVPOLL> (value 16, Solaris 8)
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2007-12-22 16:21:25 +00:00
|
|
|
This is not implemented yet (and might never be, unless you send me an
|
|
|
|
implementation). According to reports, C</dev/poll> only supports sockets
|
|
|
|
and is not embeddable, which would limit the usefulness of this backend
|
|
|
|
immensely.
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_PORT> (value 32, Solaris 10)
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2007-12-21 04:38:45 +00:00
|
|
|
This uses the Solaris 10 event port mechanism. As with everything on Solaris,
|
2007-11-22 12:28:27 +00:00
|
|
|
it's really slow, but it still scales very well (O(active_fds)).
|
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
Please note that Solaris event ports can deliver a lot of spurious
|
2007-11-23 08:36:35 +00:00
|
|
|
notifications, so you need to use non-blocking I/O or other means to avoid
|
|
|
|
blocking when no data (or space) is available.
|
|
|
|
|
2007-12-22 16:21:25 +00:00
|
|
|
While this backend scales well, it requires one system call per active
|
|
|
|
file descriptor per loop iteration. For small and medium numbers of file
|
|
|
|
descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend
|
|
|
|
might perform better.
|
|
|
|
|
2008-09-23 08:37:38 +00:00
|
|
|
On the positive side, with the exception of the spurious readiness
|
|
|
|
notifications, this backend actually performed fully to specification
|
|
|
|
in all tests and is fully embeddable, which is a rare feat among the
|
2008-10-28 12:31:38 +00:00
|
|
|
OS-specific backends (I vastly prefer correctness over speed hacks).
|
2008-01-09 04:15:39 +00:00
|
|
|
|
2008-09-13 19:14:21 +00:00
|
|
|
This backend maps C<EV_READ> and C<EV_WRITE> in the same way as
|
|
|
|
C<EVBACKEND_POLL>.
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item C<EVBACKEND_ALL>
|
2007-11-22 12:28:27 +00:00
|
|
|
|
|
|
|
Try all backends (even potentially broken ones that wouldn't be tried
|
|
|
|
with C<EVFLAG_AUTO>). Since this is a mask, you can do stuff such as
|
2007-11-23 05:00:44 +00:00
|
|
|
C<EVBACKEND_ALL & ~EVBACKEND_KQUEUE>.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-22 16:21:25 +00:00
|
|
|
It is definitely not recommended to use this flag.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=back
|
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
If one or more of these are or'ed into the flags value, then only these
|
2008-01-09 04:15:39 +00:00
|
|
|
backends will be tried (in the reverse order as listed here). If none are
|
|
|
|
specified, all backends in C<ev_recommended_backends ()> will be tried.
|
2007-11-22 12:28:27 +00:00
|
|
|
|
2008-09-23 08:37:38 +00:00
|
|
|
Example: This is the most typical usage.
|
2007-11-23 15:26:08 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
if (!ev_default_loop (0))
|
|
|
|
fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
|
2007-11-23 15:26:08 +00:00
|
|
|
|
2008-09-23 08:37:38 +00:00
|
|
|
Example: Restrict libev to the select and poll backends, and do not allow
|
2007-11-23 15:26:08 +00:00
|
|
|
environment settings to be taken into account:
|
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
ev_default_loop (EVBACKEND_POLL | EVBACKEND_SELECT | EVFLAG_NOENV);
|
2007-11-23 15:26:08 +00:00
|
|
|
|
2008-09-23 08:37:38 +00:00
|
|
|
Example: Use whatever libev has to offer, but make sure that kqueue is
|
|
|
|
used if available (warning, breaks stuff, best use only with your own
|
|
|
|
private event loop and only if you know the OS supports your types of
|
|
|
|
fds):
|
2007-11-23 15:26:08 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
ev_default_loop (ev_recommended_backends () | EVBACKEND_KQUEUE);
|
2007-11-23 15:26:08 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item struct ev_loop *ev_loop_new (unsigned int flags)
|
|
|
|
|
|
|
|
Similar to C<ev_default_loop>, but always creates a new event loop that is
|
|
|
|
always distinct from the default loop. Unlike the default loop, it cannot
|
|
|
|
handle signal and child watchers, and attempts to do so will be greeted by
|
|
|
|
undefined behaviour (or a failed assertion if assertions are enabled).
|
|
|
|
|
2008-04-02 05:51:40 +00:00
|
|
|
Note that this function I<is> thread-safe, and the recommended way to use
|
|
|
|
libev with threads is indeed to create one loop per thread, and using the
|
|
|
|
default loop in the "main" or "initial" thread.
|
|
|
|
|
2007-11-27 20:26:50 +00:00
|
|
|
Example: Try to create a event loop that uses epoll and nothing else.
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
struct ev_loop *epoller = ev_loop_new (EVBACKEND_EPOLL | EVFLAG_NOENV);
|
|
|
|
if (!epoller)
|
|
|
|
fatal ("no epoll found here, maybe it hides under your chair");
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item ev_default_destroy ()
|
|
|
|
|
|
|
|
Destroys the default loop again (frees all memory and kernel state
|
2007-11-24 07:20:42 +00:00
|
|
|
etc.). None of the active event watchers will be stopped in the normal
|
|
|
|
sense, so e.g. C<ev_is_active> might still return true. It is your
|
2008-05-24 03:08:03 +00:00
|
|
|
responsibility to either stop all watchers cleanly yourself I<before>
|
2007-11-24 07:20:42 +00:00
|
|
|
calling this function, or cope with the fact afterwards (which is usually
|
2007-12-18 01:37:46 +00:00
|
|
|
the easiest thing, you can just ignore the watchers and/or C<free ()> them
|
2007-11-24 07:20:42 +00:00
|
|
|
for example).
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-10-26 00:52:51 +00:00
|
|
|
Note that certain global state, such as signal state (and installed signal
|
|
|
|
handlers), will not be freed by this function, and related watchers (such
|
|
|
|
as signal and child watchers) would need to be stopped manually.
|
2007-12-18 01:37:46 +00:00
|
|
|
|
|
|
|
In general it is not advisable to call this function except in the
|
|
|
|
rare occasion where you really need to free e.g. the signal handling
|
|
|
|
pipe fds. If you need dynamically allocated loops it is better to use
|
|
|
|
C<ev_loop_new> and C<ev_loop_destroy>).
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item ev_loop_destroy (loop)
|
|
|
|
|
|
|
|
Like C<ev_default_destroy>, but destroys an event loop created by an
|
|
|
|
earlier call to C<ev_loop_new>.
|
|
|
|
|
|
|
|
=item ev_default_fork ()
|
|
|
|
|
2008-01-15 04:07:37 +00:00
|
|
|
This function sets a flag that causes subsequent C<ev_loop> iterations
|
|
|
|
to reinitialise the kernel state for backends that have one. Despite the
|
|
|
|
name, you can call it anytime, but it makes most sense after forking, in
|
|
|
|
the child process (or both child and parent, but that again makes little
|
|
|
|
sense). You I<must> call it in the child before using any of the libev
|
|
|
|
functions, and it will only take effect at the next C<ev_loop> iteration.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-01-15 04:07:37 +00:00
|
|
|
On the other hand, you only need to call this function in the child
|
|
|
|
process if and only if you want to use the event library in the child. If
|
|
|
|
you just fork+exec, you don't have to call it at all.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
The function itself is quite fast and it's usually not a problem to call
|
2007-11-12 07:58:13 +00:00
|
|
|
it just in case after a fork. To make this easy, the function will fit in
|
|
|
|
quite nicely into a call to C<pthread_atfork>:
|
|
|
|
|
|
|
|
pthread_atfork (0, 0, ev_default_fork);
|
|
|
|
|
|
|
|
=item ev_loop_fork (loop)
|
|
|
|
|
|
|
|
Like C<ev_default_fork>, but acts on an event loop created by
|
|
|
|
C<ev_loop_new>. Yes, you have to call this on every allocated event loop
|
2008-09-23 08:37:38 +00:00
|
|
|
after fork that you want to re-use in the child, and how you do this is
|
|
|
|
entirely your own problem.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-02-19 17:09:28 +00:00
|
|
|
=item int ev_is_default_loop (loop)
|
|
|
|
|
2008-09-23 08:37:38 +00:00
|
|
|
Returns true when the given loop is, in fact, the default loop, and false
|
|
|
|
otherwise.
|
2008-02-19 17:09:28 +00:00
|
|
|
|
2007-12-03 13:41:24 +00:00
|
|
|
=item unsigned int ev_loop_count (loop)
|
|
|
|
|
|
|
|
Returns the count of loop iterations for the loop, which is identical to
|
|
|
|
the number of times libev did poll for new events. It starts at C<0> and
|
|
|
|
happily wraps around with enough iterations.
|
|
|
|
|
|
|
|
This value can sometimes be useful as a generation counter of sorts (it
|
|
|
|
"ticks" the number of loop iterations), as it roughly corresponds with
|
|
|
|
C<ev_prepare> and C<ev_check> calls.
|
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
=item unsigned int ev_backend (loop)
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-23 05:00:44 +00:00
|
|
|
Returns one of the C<EVBACKEND_*> flags indicating the event backend in
|
2007-11-12 07:58:13 +00:00
|
|
|
use.
|
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
=item ev_tstamp ev_now (loop)
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
Returns the current "event loop time", which is the time the event loop
|
2007-11-23 16:17:12 +00:00
|
|
|
received events and started processing them. This timestamp does not
|
|
|
|
change as long as callbacks are being processed, and this is also the base
|
|
|
|
time used for relative timers. You can treat it as the timestamp of the
|
2007-12-21 01:26:04 +00:00
|
|
|
event occurring (or more correctly, libev finding out about it).
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-09-08 17:24:39 +00:00
|
|
|
=item ev_now_update (loop)
|
|
|
|
|
|
|
|
Establishes the current time by querying the kernel, updating the time
|
|
|
|
returned by C<ev_now ()> in the progress. This is a costly operation and
|
|
|
|
is usually done automatically within C<ev_loop ()>.
|
|
|
|
|
|
|
|
This function is rarely useful, but when some event callback runs for a
|
|
|
|
very long time without entering the event loop, updating libev's idea of
|
|
|
|
the current time is a good idea.
|
|
|
|
|
|
|
|
See also "The special problem of time updates" in the C<ev_timer> section.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item ev_loop (loop, int flags)
|
|
|
|
|
|
|
|
Finally, this is it, the event handler. This function usually is called
|
|
|
|
after you initialised all your watchers and you want to start handling
|
|
|
|
events.
|
|
|
|
|
2007-11-23 15:26:08 +00:00
|
|
|
If the flags argument is specified as C<0>, it will not return until
|
|
|
|
either no event watchers are active anymore or C<ev_unloop> was called.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-23 16:17:12 +00:00
|
|
|
Please note that an explicit C<ev_unloop> is usually better than
|
|
|
|
relying on all watchers to be stopped when deciding when a program has
|
2008-09-23 08:37:38 +00:00
|
|
|
finished (especially in interactive programs), but having a program
|
|
|
|
that automatically loops as long as it has to and no longer by virtue
|
|
|
|
of relying on its watchers stopping correctly, that is truly a thing of
|
|
|
|
beauty.
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
A flags value of C<EVLOOP_NONBLOCK> will look for new events, will handle
|
2008-09-23 08:37:38 +00:00
|
|
|
those events and any already outstanding ones, but will not block your
|
|
|
|
process in case there are no events and will return after one iteration of
|
|
|
|
the loop.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
|
|
|
A flags value of C<EVLOOP_ONESHOT> will look for new events (waiting if
|
2008-09-23 08:37:38 +00:00
|
|
|
necessary) and will handle those and any already outstanding ones. It
|
|
|
|
will block your process until at least one new event arrives (which could
|
2008-10-29 10:24:23 +00:00
|
|
|
be an event internal to libev itself, so there is no guarantee that a
|
2008-09-23 08:37:38 +00:00
|
|
|
user-registered callback will be called), and will return after one
|
|
|
|
iteration of the loop.
|
|
|
|
|
|
|
|
This is useful if you are waiting for some external event in conjunction
|
|
|
|
with something not expressible using other libev watchers (i.e. "roll your
|
|
|
|
own C<ev_loop>"). However, a pair of C<ev_prepare>/C<ev_check> watchers is
|
2007-11-23 15:26:08 +00:00
|
|
|
usually a better approach for this kind of thing.
|
|
|
|
|
|
|
|
Here are the gory details of what C<ev_loop> does:
|
|
|
|
|
2007-12-08 22:11:14 +00:00
|
|
|
- Before the first iteration, call any pending watchers.
|
2007-12-31 01:30:53 +00:00
|
|
|
* If EVFLAG_FORKCHECK was used, check for a fork.
|
2008-07-08 09:49:15 +00:00
|
|
|
- If a fork was detected (by any means), queue and call all fork watchers.
|
2007-12-31 01:30:53 +00:00
|
|
|
- Queue and call all prepare watchers.
|
2008-07-08 09:49:15 +00:00
|
|
|
- If we have been forked, detach and recreate the kernel state
|
|
|
|
as to not disturb the other process.
|
2007-11-23 15:26:08 +00:00
|
|
|
- Update the kernel state with all outstanding changes.
|
2008-07-08 09:49:15 +00:00
|
|
|
- Update the "event loop time" (ev_now ()).
|
2007-12-31 01:30:53 +00:00
|
|
|
- Calculate for how long to sleep or block, if at all
|
|
|
|
(active idle watchers, EVLOOP_NONBLOCK or not having
|
|
|
|
any active watchers at all will result in not sleeping).
|
|
|
|
- Sleep if the I/O and timer collect interval say so.
|
2007-11-23 15:26:08 +00:00
|
|
|
- Block the process, waiting for any events.
|
|
|
|
- Queue all outstanding I/O (fd) events.
|
2008-07-08 09:49:15 +00:00
|
|
|
- Update the "event loop time" (ev_now ()), and do time jump adjustments.
|
2008-09-23 08:37:38 +00:00
|
|
|
- Queue all expired timers.
|
|
|
|
- Queue all expired periodics.
|
2008-07-08 09:49:15 +00:00
|
|
|
- Unless any events are pending now, queue all idle watchers.
|
2007-11-23 15:26:08 +00:00
|
|
|
- Queue all check watchers.
|
|
|
|
- Call all queued watchers in reverse order (i.e. check watchers first).
|
|
|
|
Signals and child watchers are implemented as I/O watchers, and will
|
|
|
|
be handled here by queueing them when their watcher gets executed.
|
2007-12-31 01:30:53 +00:00
|
|
|
- If ev_unloop has been called, or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
|
|
|
|
were used, or there are no active watchers, return, otherwise
|
|
|
|
continue with step *.
|
2007-11-14 05:02:07 +00:00
|
|
|
|
2007-12-31 01:31:30 +00:00
|
|
|
Example: Queue some jobs and then loop until no events are outstanding
|
2007-11-23 16:17:12 +00:00
|
|
|
anymore.
|
|
|
|
|
|
|
|
... queue jobs here, make sure they register event watchers as long
|
|
|
|
... as they still have work to do (even an idle watcher will do..)
|
|
|
|
ev_loop (my_loop, 0);
|
2008-07-08 09:49:15 +00:00
|
|
|
... jobs done or somebody called unloop. yeah!
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item ev_unloop (loop, how)
|
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
Can be used to make a call to C<ev_loop> return early (but only after it
|
|
|
|
has processed all outstanding events). The C<how> argument must be either
|
2007-11-12 21:51:14 +00:00
|
|
|
C<EVUNLOOP_ONE>, which will make the innermost C<ev_loop> call return, or
|
2007-11-12 08:29:11 +00:00
|
|
|
C<EVUNLOOP_ALL>, which will make all nested C<ev_loop> calls return.
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-12-31 01:32:59 +00:00
|
|
|
This "unloop state" will be cleared when entering C<ev_loop> again.
|
|
|
|
|
2008-10-20 16:08:36 +00:00
|
|
|
It is safe to call C<ev_unloop> from otuside any C<ev_loop> calls.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=item ev_ref (loop)
|
|
|
|
|
|
|
|
=item ev_unref (loop)
|
|
|
|
|
2007-11-12 08:29:11 +00:00
|
|
|
Ref/unref can be used to add or remove a reference count on the event
|
|
|
|
loop: Every watcher keeps one reference, and as long as the reference
|
2008-09-23 08:37:38 +00:00
|
|
|
count is nonzero, C<ev_loop> will not return on its own.
|
|
|
|
|
|
|
|
If you have a watcher you never unregister that should not keep C<ev_loop>
|
|
|
|
from returning, call ev_unref() after starting, and ev_ref() before
|
|
|
|
stopping it.
|
|
|
|
|
|
|
|
As an example, libev itself uses this for its internal signal pipe: It is
|
|
|
|
not visible to the libev user and should not keep C<ev_loop> from exiting
|
|
|
|
if no event watchers registered by it are active. It is also an excellent
|
2007-11-12 08:29:11 +00:00
|
|
|
way to do this for generic recurring timers or from within third-party
|
2007-12-31 01:34:09 +00:00
|
|
|
libraries. Just remember to I<unref after start> and I<ref before stop>
|
|
|
|
(but only if the watcher wasn't active before, or was active before,
|
|
|
|
respectively).
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2007-11-27 20:26:50 +00:00
|
|
|
Example: Create a signal watcher, but keep it from keeping C<ev_loop>
|
2007-11-23 16:17:12 +00:00
|
|
|
running when nothing else is active.
|
|
|
|
|
2008-10-23 06:30:48 +00:00
|
|
|
ev_signal exitsig;
|
2008-05-31 23:22:23 +00:00
|
|
|
ev_signal_init (&exitsig, sig_cb, SIGINT);
|
|
|
|
ev_signal_start (loop, &exitsig);
|
|
|
|
evf_unref (loop);
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-11-27 20:26:50 +00:00
|
|
|
Example: For some weird reason, unregister the above signal handler again.
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
ev_ref (loop);
|
|
|
|
ev_signal_stop (loop, &exitsig);
|
2007-11-23 16:17:12 +00:00
|
|
|
|
2007-12-22 05:47:56 +00:00
|
|
|
=item ev_set_io_collect_interval (loop, ev_tstamp interval)
|
|
|
|
|
|
|
|
=item ev_set_timeout_collect_interval (loop, ev_tstamp interval)
|
|
|
|
|
|
|
|
These advanced functions influence the time that libev will spend waiting
|
2008-07-08 09:49:15 +00:00
|
|
|
for events. Both time intervals are by default C<0>, meaning that libev
|
|
|
|
will try to invoke timer/periodic callbacks and I/O callbacks with minimum
|
|
|
|
latency.
|
2007-12-22 05:47:56 +00:00
|
|
|
|
|
|
|
Setting these to a higher value (the C<interval> I<must> be >= C<0>)
|
2008-07-08 09:49:15 +00:00
|
|
|
allows libev to delay invocation of I/O and timer/periodic callbacks
|
|
|
|
to increase efficiency of loop iterations (or to increase power-saving
|
|
|
|
opportunities).
|
2007-12-22 05:47:56 +00:00
|
|
|
|
2008-09-23 08:37:38 +00:00
|
|
|
The idea is that sometimes your program runs just fast enough to handle
|
|
|
|
one (or very few) event(s) per loop iteration. While this makes the
|
|
|
|
program responsive, it also wastes a lot of CPU time to poll for new
|
2007-12-22 05:47:56 +00:00
|
|
|
events, especially with backends like C<select ()> which have a high
|
|
|
|
overhead for the actual polling but can deliver many events at once.
|
|
|
|
|
|
|
|
By setting a higher I<io collect interval> you allow libev to spend more
|
|
|
|
time collecting I/O events, so you can handle more events per iteration,
|
|
|
|
at the cost of increasing latency. Timeouts (both C<ev_periodic> and
|
2007-12-22 14:11:25 +00:00
|
|
|
C<ev_timer>) will be not affected. Setting this to a non-null value will
|
2007-12-22 06:16:36 +00:00
|
|
|
introduce an additional C<ev_sleep ()> call into most loop iterations.
|
2007-12-22 05:47:56 +00:00
|
|
|
|
|
|
|
Likewise, by setting a higher I<timeout collect interval> you allow libev
|
|
|
|
to spend more time collecting timeouts, at the expense of increased
|
2008-09-23 08:37:38 +00:00
|
|
|
latency/jitter/inexactness (the watcher callback will be called
|
|
|
|
later). C<ev_io> watchers will not be affected. Setting this to a non-null
|
|
|
|
value will not introduce any overhead in libev.
|
2007-12-22 05:47:56 +00:00
|
|
|
|
2008-05-24 03:08:03 +00:00
|
|
|
Many (busy) programs can usually benefit by setting the I/O collect
|
2007-12-22 06:10:25 +00:00
|
|
|
interval to a value near C<0.1> or so, which is often enough for
|
|
|
|
interactive servers (of course not for games), likewise for timeouts. It
|
|
|
|
usually doesn't make much sense to set it to a lower value than C<0.01>,
|
2008-05-24 03:08:03 +00:00
|
|
|
as this approaches the timing granularity of most systems.
|
2007-12-22 05:47:56 +00:00
|
|
|
|
2008-07-08 09:49:15 +00:00
|
|
|
Setting the I<timeout collect interval> can improve the opportunity for
|
|
|
|
saving power, as the program will "bundle" timer callback invocations that
|
|
|
|
are "near" in time together, by delaying some, thus reducing the number of
|
|
|
|
times the process sleeps and wakes up again. Another useful technique to
|
|
|
|
reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure
|
|
|
|
they fire on, say, one-second boundaries only.
|
|
|
|
|
2008-05-22 02:44:57 +00:00
|
|
|
=item ev_loop_verify (loop)
|
|
|
|
|
|
|
|
This function only does something when C<EV_VERIFY> support has been
|
2008-10-23 07:33:45 +00:00
|
|
|
compiled in, which is the default for non-minimal builds. It tries to go
|
2008-09-23 08:37:38 +00:00
|
|
|
through all internal structures and checks them for validity. If anything
|
|
|
|
is found to be inconsistent, it will print an error message to standard
|
|
|
|
error and call C<abort ()>.
|
2008-05-22 02:44:57 +00:00
|
|
|
|
|
|
|
This can be used to catch bugs inside libev itself: under normal
|
|
|
|
circumstances, this function will never abort as of course libev keeps its
|
|
|
|
data structures consistent.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=back
|
|
|
|
|
2007-11-24 16:31:45 +00:00
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
=head1 ANATOMY OF A WATCHER
|
|
|
|
|
2008-10-23 07:33:45 +00:00
|
|
|
In the following description, uppercase C<TYPE> in names stands for the
|
|
|
|
watcher type, e.g. C<ev_TYPE_start> can mean C<ev_timer_start> for timer
|
|
|
|
watchers and C<ev_io_start> for I/O watchers.
|
|
|
|
|
2007-11-12 07:58:13 +00:00
|
|
|
A watcher is a structure that you create and register to record your
|
|
|
|
interest in some event. For instance, if you want to wait for STDIN to
|
2007-11-12 08:29:11 +00:00
|
|
|
become readable, you would create an C<ev_io> watcher for that:
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-10-23 06:30:48 +00:00
|
|
|
static void my_cb (struct ev_loop *loop, ev_io *w, int revents)
|
2008-05-31 23:22:23 +00:00
|
|
|
{
|
|
|
|
ev_io_stop (w);
|
|
|
|
ev_unloop (loop, EVUNLOOP_ALL);
|
|
|
|
}
|
2007-11-12 07:58:13 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
struct ev_loop *loop = ev_default_loop (0);
|
2008-10-23 07:33:45 +00:00
|
|
|
|
2008-10-23 06:30:48 +00:00
|
|
|
ev_io stdin_watcher;
|
2008-10-23 07:33:45 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|
|
ev_init (&stdin_watcher, my_cb);
|
|
|
|
ev_io_set (&stdin_watcher, STDIN_FILENO, EV_READ);
|
|
|
|
ev_io_start (loop, &stdin_watcher);
|
2008-10-23 07:33:45 +00:00
|
|
|
|
2008-05-31 23:22:23 +00:00
|
|