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

Comparing libev/ev.pod (file contents):
Revision 1.111 by root, Tue Dec 25 18:01:20 2007 UTC vs.
Revision 1.121 by root, Mon Jan 28 12:13:54 2008 UTC

260flags. If that is troubling you, check C<ev_backend ()> afterwards). 260flags. If that is troubling you, check C<ev_backend ()> afterwards).
261 261
262If you don't know what event loop to use, use the one returned from this 262If you don't know what event loop to use, use the one returned from this
263function. 263function.
264 264
265The default loop is the only loop that can handle C<ev_signal> and
266C<ev_child> watchers, and to do this, it always registers a handler
267for C<SIGCHLD>. If this is a problem for your app you can either
268create a dynamic loop with C<ev_loop_new> that doesn't do that, or you
269can simply overwrite the C<SIGCHLD> signal handler I<after> calling
270C<ev_default_init>.
271
265The flags argument can be used to specify special behaviour or specific 272The flags argument can be used to specify special behaviour or specific
266backends to use, and is usually specified as C<0> (or C<EVFLAG_AUTO>). 273backends to use, and is usually specified as C<0> (or C<EVFLAG_AUTO>).
267 274
268The following flags are supported: 275The following flags are supported:
269 276
403While this backend scales well, it requires one system call per active 410While this backend scales well, it requires one system call per active
404file descriptor per loop iteration. For small and medium numbers of file 411file descriptor per loop iteration. For small and medium numbers of file
405descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend 412descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend
406might perform better. 413might perform better.
407 414
415On the positive side, ignoring the spurious readyness notifications, this
416backend actually performed to specification in all tests and is fully
417embeddable, which is a rare feat among the OS-specific backends.
418
408=item C<EVBACKEND_ALL> 419=item C<EVBACKEND_ALL>
409 420
410Try all backends (even potentially broken ones that wouldn't be tried 421Try all backends (even potentially broken ones that wouldn't be tried
411with C<EVFLAG_AUTO>). Since this is a mask, you can do stuff such as 422with C<EVFLAG_AUTO>). Since this is a mask, you can do stuff such as
412C<EVBACKEND_ALL & ~EVBACKEND_KQUEUE>. 423C<EVBACKEND_ALL & ~EVBACKEND_KQUEUE>.
414It is definitely not recommended to use this flag. 425It is definitely not recommended to use this flag.
415 426
416=back 427=back
417 428
418If one or more of these are ored into the flags value, then only these 429If one or more of these are ored into the flags value, then only these
419backends will be tried (in the reverse order as given here). If none are 430backends will be tried (in the reverse order as listed here). If none are
420specified, most compiled-in backend will be tried, usually in reverse 431specified, all backends in C<ev_recommended_backends ()> will be tried.
421order of their flag values :)
422 432
423The most typical usage is like this: 433The most typical usage is like this:
424 434
425 if (!ev_default_loop (0)) 435 if (!ev_default_loop (0))
426 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?"); 436 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
473Like C<ev_default_destroy>, but destroys an event loop created by an 483Like C<ev_default_destroy>, but destroys an event loop created by an
474earlier call to C<ev_loop_new>. 484earlier call to C<ev_loop_new>.
475 485
476=item ev_default_fork () 486=item ev_default_fork ()
477 487
488This function sets a flag that causes subsequent C<ev_loop> iterations
478This function reinitialises the kernel state for backends that have 489to reinitialise the kernel state for backends that have one. Despite the
479one. Despite the name, you can call it anytime, but it makes most sense 490name, you can call it anytime, but it makes most sense after forking, in
480after forking, in either the parent or child process (or both, but that 491the child process (or both child and parent, but that again makes little
481again makes little sense). 492sense). You I<must> call it in the child before using any of the libev
493functions, and it will only take effect at the next C<ev_loop> iteration.
482 494
483You I<must> call this function in the child process after forking if and 495On the other hand, you only need to call this function in the child
484only if you want to use the event library in both processes. If you just 496process if and only if you want to use the event library in the child. If
485fork+exec, you don't have to call it. 497you just fork+exec, you don't have to call it at all.
486 498
487The function itself is quite fast and it's usually not a problem to call 499The function itself is quite fast and it's usually not a problem to call
488it just in case after a fork. To make this easy, the function will fit in 500it just in case after a fork. To make this easy, the function will fit in
489quite nicely into a call to C<pthread_atfork>: 501quite nicely into a call to C<pthread_atfork>:
490 502
491 pthread_atfork (0, 0, ev_default_fork); 503 pthread_atfork (0, 0, ev_default_fork);
492
493At the moment, C<EVBACKEND_SELECT> and C<EVBACKEND_POLL> are safe to use
494without calling this function, so if you force one of those backends you
495do not need to care.
496 504
497=item ev_loop_fork (loop) 505=item ev_loop_fork (loop)
498 506
499Like C<ev_default_fork>, but acts on an event loop created by 507Like C<ev_default_fork>, but acts on an event loop created by
500C<ev_loop_new>. Yes, you have to call this on every allocated event loop 508C<ev_loop_new>. Yes, you have to call this on every allocated event loop
551usually a better approach for this kind of thing. 559usually a better approach for this kind of thing.
552 560
553Here are the gory details of what C<ev_loop> does: 561Here are the gory details of what C<ev_loop> does:
554 562
555 - Before the first iteration, call any pending watchers. 563 - Before the first iteration, call any pending watchers.
556 * If there are no active watchers (reference count is zero), return. 564 * If EVFLAG_FORKCHECK was used, check for a fork.
557 - Queue all prepare watchers and then call all outstanding watchers. 565 - If a fork was detected, queue and call all fork watchers.
566 - Queue and call all prepare watchers.
558 - If we have been forked, recreate the kernel state. 567 - If we have been forked, recreate the kernel state.
559 - Update the kernel state with all outstanding changes. 568 - Update the kernel state with all outstanding changes.
560 - Update the "event loop time". 569 - Update the "event loop time".
561 - Calculate for how long to block. 570 - Calculate for how long to sleep or block, if at all
571 (active idle watchers, EVLOOP_NONBLOCK or not having
572 any active watchers at all will result in not sleeping).
573 - Sleep if the I/O and timer collect interval say so.
562 - Block the process, waiting for any events. 574 - Block the process, waiting for any events.
563 - Queue all outstanding I/O (fd) events. 575 - Queue all outstanding I/O (fd) events.
564 - Update the "event loop time" and do time jump handling. 576 - Update the "event loop time" and do time jump handling.
565 - Queue all outstanding timers. 577 - Queue all outstanding timers.
566 - Queue all outstanding periodics. 578 - Queue all outstanding periodics.
567 - If no events are pending now, queue all idle watchers. 579 - If no events are pending now, queue all idle watchers.
568 - Queue all check watchers. 580 - Queue all check watchers.
569 - Call all queued watchers in reverse order (i.e. check watchers first). 581 - Call all queued watchers in reverse order (i.e. check watchers first).
570 Signals and child watchers are implemented as I/O watchers, and will 582 Signals and child watchers are implemented as I/O watchers, and will
571 be handled here by queueing them when their watcher gets executed. 583 be handled here by queueing them when their watcher gets executed.
572 - If ev_unloop has been called or EVLOOP_ONESHOT or EVLOOP_NONBLOCK 584 - If ev_unloop has been called, or EVLOOP_ONESHOT or EVLOOP_NONBLOCK
573 were used, return, otherwise continue with step *. 585 were used, or there are no active watchers, return, otherwise
586 continue with step *.
574 587
575Example: Queue some jobs and then loop until no events are outsanding 588Example: Queue some jobs and then loop until no events are outstanding
576anymore. 589anymore.
577 590
578 ... queue jobs here, make sure they register event watchers as long 591 ... queue jobs here, make sure they register event watchers as long
579 ... as they still have work to do (even an idle watcher will do..) 592 ... as they still have work to do (even an idle watcher will do..)
580 ev_loop (my_loop, 0); 593 ev_loop (my_loop, 0);
584 597
585Can be used to make a call to C<ev_loop> return early (but only after it 598Can be used to make a call to C<ev_loop> return early (but only after it
586has processed all outstanding events). The C<how> argument must be either 599has processed all outstanding events). The C<how> argument must be either
587C<EVUNLOOP_ONE>, which will make the innermost C<ev_loop> call return, or 600C<EVUNLOOP_ONE>, which will make the innermost C<ev_loop> call return, or
588C<EVUNLOOP_ALL>, which will make all nested C<ev_loop> calls return. 601C<EVUNLOOP_ALL>, which will make all nested C<ev_loop> calls return.
602
603This "unloop state" will be cleared when entering C<ev_loop> again.
589 604
590=item ev_ref (loop) 605=item ev_ref (loop)
591 606
592=item ev_unref (loop) 607=item ev_unref (loop)
593 608
598returning, ev_unref() after starting, and ev_ref() before stopping it. For 613returning, ev_unref() after starting, and ev_ref() before stopping it. For
599example, libev itself uses this for its internal signal pipe: It is not 614example, libev itself uses this for its internal signal pipe: It is not
600visible to the libev user and should not keep C<ev_loop> from exiting if 615visible to the libev user and should not keep C<ev_loop> from exiting if
601no event watchers registered by it are active. It is also an excellent 616no event watchers registered by it are active. It is also an excellent
602way to do this for generic recurring timers or from within third-party 617way to do this for generic recurring timers or from within third-party
603libraries. Just remember to I<unref after start> and I<ref before stop>. 618libraries. Just remember to I<unref after start> and I<ref before stop>
619(but only if the watcher wasn't active before, or was active before,
620respectively).
604 621
605Example: Create a signal watcher, but keep it from keeping C<ev_loop> 622Example: Create a signal watcher, but keep it from keeping C<ev_loop>
606running when nothing else is active. 623running when nothing else is active.
607 624
608 struct ev_signal exitsig; 625 struct ev_signal exitsig;
1421 1438
1422=head3 Watcher-Specific Functions and Data Members 1439=head3 Watcher-Specific Functions and Data Members
1423 1440
1424=over 4 1441=over 4
1425 1442
1426=item ev_child_init (ev_child *, callback, int pid) 1443=item ev_child_init (ev_child *, callback, int pid, int trace)
1427 1444
1428=item ev_child_set (ev_child *, int pid) 1445=item ev_child_set (ev_child *, int pid, int trace)
1429 1446
1430Configures the watcher to wait for status changes of process C<pid> (or 1447Configures the watcher to wait for status changes of process C<pid> (or
1431I<any> process if C<pid> is specified as C<0>). The callback can look 1448I<any> process if C<pid> is specified as C<0>). The callback can look
1432at the C<rstatus> member of the C<ev_child> watcher structure to see 1449at the C<rstatus> member of the C<ev_child> watcher structure to see
1433the status word (use the macros from C<sys/wait.h> and see your systems 1450the status word (use the macros from C<sys/wait.h> and see your systems
1434C<waitpid> documentation). The C<rpid> member contains the pid of the 1451C<waitpid> documentation). The C<rpid> member contains the pid of the
1435process causing the status change. 1452process causing the status change. C<trace> must be either C<0> (only
1453activate the watcher when the process terminates) or C<1> (additionally
1454activate the watcher when the process is stopped or continued).
1436 1455
1437=item int pid [read-only] 1456=item int pid [read-only]
1438 1457
1439The process id this watcher watches out for, or C<0>, meaning any process id. 1458The process id this watcher watches out for, or C<0>, meaning any process id.
1440 1459
1676 static void 1695 static void
1677 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents) 1696 idle_cb (struct ev_loop *loop, struct ev_idle *w, int revents)
1678 { 1697 {
1679 free (w); 1698 free (w);
1680 // now do something you wanted to do when the program has 1699 // now do something you wanted to do when the program has
1681 // no longer asnything immediate to do. 1700 // no longer anything immediate to do.
1682 } 1701 }
1683 1702
1684 struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle)); 1703 struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle));
1685 ev_idle_init (idle_watcher, idle_cb); 1704 ev_idle_init (idle_watcher, idle_cb);
1686 ev_idle_start (loop, idle_cb); 1705 ev_idle_start (loop, idle_cb);
2263Example: Define a class with an IO and idle watcher, start one of them in 2282Example: Define a class with an IO and idle watcher, start one of them in
2264the constructor. 2283the constructor.
2265 2284
2266 class myclass 2285 class myclass
2267 { 2286 {
2268 ev_io io; void io_cb (ev::io &w, int revents); 2287 ev::io io; void io_cb (ev::io &w, int revents);
2269 ev_idle idle void idle_cb (ev::idle &w, int revents); 2288 ev:idle idle void idle_cb (ev::idle &w, int revents);
2270 2289
2271 myclass (); 2290 myclass (int fd)
2272 }
2273
2274 myclass::myclass (int fd)
2275 { 2291 {
2276 io .set <myclass, &myclass::io_cb > (this); 2292 io .set <myclass, &myclass::io_cb > (this);
2277 idle.set <myclass, &myclass::idle_cb> (this); 2293 idle.set <myclass, &myclass::idle_cb> (this);
2278 2294
2279 io.start (fd, ev::READ); 2295 io.start (fd, ev::READ);
2296 }
2280 } 2297 };
2281 2298
2282 2299
2283=head1 MACRO MAGIC 2300=head1 MACRO MAGIC
2284 2301
2285Libev can be compiled with a variety of options, the most fundamantal 2302Libev can be compiled with a variety of options, the most fundamantal
2490wants osf handles on win32 (this is the case when the select to 2507wants osf handles on win32 (this is the case when the select to
2491be used is the winsock select). This means that it will call 2508be used is the winsock select). This means that it will call
2492C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise, 2509C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise,
2493it is assumed that all these functions actually work on fds, even 2510it is assumed that all these functions actually work on fds, even
2494on win32. Should not be defined on non-win32 platforms. 2511on win32. Should not be defined on non-win32 platforms.
2512
2513=item EV_FD_TO_WIN32_HANDLE
2514
2515If C<EV_SELECT_IS_WINSOCKET> is enabled, then libev needs a way to map
2516file descriptors to socket handles. When not defining this symbol (the
2517default), then libev will call C<_get_osfhandle>, which is usually
2518correct. In some cases, programs use their own file descriptor management,
2519in which case they can provide this function to map fds to socket handles.
2495 2520
2496=item EV_USE_POLL 2521=item EV_USE_POLL
2497 2522
2498If defined to be C<1>, libev will compile in support for the C<poll>(2) 2523If defined to be C<1>, libev will compile in support for the C<poll>(2)
2499backend. Otherwise it will be enabled on non-win32 platforms. It 2524backend. Otherwise it will be enabled on non-win32 platforms. It
2536be detected at runtime. 2561be detected at runtime.
2537 2562
2538=item EV_H 2563=item EV_H
2539 2564
2540The name of the F<ev.h> header file used to include it. The default if 2565The name of the F<ev.h> header file used to include it. The default if
2541undefined is C<"ev.h"> in F<event.h> and F<ev.c>. This can be used to 2566undefined is C<"ev.h"> in F<event.h>, F<ev.c> and F<ev++.h>. This can be
2542virtually rename the F<ev.h> header file in case of conflicts. 2567used to virtually rename the F<ev.h> header file in case of conflicts.
2543 2568
2544=item EV_CONFIG_H 2569=item EV_CONFIG_H
2545 2570
2546If C<EV_STANDALONE> isn't C<1>, this variable can be used to override 2571If C<EV_STANDALONE> isn't C<1>, this variable can be used to override
2547F<ev.c>'s idea of where to find the F<config.h> file, similarly to 2572F<ev.c>'s idea of where to find the F<config.h> file, similarly to
2548C<EV_H>, above. 2573C<EV_H>, above.
2549 2574
2550=item EV_EVENT_H 2575=item EV_EVENT_H
2551 2576
2552Similarly to C<EV_H>, this macro can be used to override F<event.c>'s idea 2577Similarly to C<EV_H>, this macro can be used to override F<event.c>'s idea
2553of how the F<event.h> header can be found, the dfeault is C<"event.h">. 2578of how the F<event.h> header can be found, the default is C<"event.h">.
2554 2579
2555=item EV_PROTOTYPES 2580=item EV_PROTOTYPES
2556 2581
2557If defined to be C<0>, then F<ev.h> will not define any function 2582If defined to be C<0>, then F<ev.h> will not define any function
2558prototypes, but still define all the structs and other symbols. This is 2583prototypes, but still define all the structs and other symbols. This is
2772watchers becomes O(1) w.r.t. prioritiy handling. 2797watchers becomes O(1) w.r.t. prioritiy handling.
2773 2798
2774=back 2799=back
2775 2800
2776 2801
2802=head1 Win32 platform limitations and workarounds
2803
2804Win32 doesn't support any of the standards (e.g. POSIX) that libev
2805requires, and its I/O model is fundamentally incompatible with the POSIX
2806model. Libev still offers limited functionality on this platform in
2807the form of the C<EVBACKEND_SELECT> backend, and only supports socket
2808descriptors. This only applies when using Win32 natively, not when using
2809e.g. cygwin.
2810
2811There is no supported compilation method available on windows except
2812embedding it into other applications.
2813
2814Due to the many, low, and arbitrary limits on the win32 platform and the
2815abysmal performance of winsockets, using a large number of sockets is not
2816recommended (and not reasonable). If your program needs to use more than
2817a hundred or so sockets, then likely it needs to use a totally different
2818implementation for windows, as libev offers the POSIX model, which cannot
2819be implemented efficiently on windows (microsoft monopoly games).
2820
2821=over 4
2822
2823=item The winsocket select function
2824
2825The winsocket C<select> function doesn't follow POSIX in that it requires
2826socket I<handles> and not socket I<file descriptors>. This makes select
2827very inefficient, and also requires a mapping from file descriptors
2828to socket handles. See the discussion of the C<EV_SELECT_USE_FD_SET>,
2829C<EV_SELECT_IS_WINSOCKET> and C<EV_FD_TO_WIN32_HANDLE> preprocessor
2830symbols for more info.
2831
2832The configuration for a "naked" win32 using the microsoft runtime
2833libraries and raw winsocket select is:
2834
2835 #define EV_USE_SELECT 1
2836 #define EV_SELECT_IS_WINSOCKET 1 /* forces EV_SELECT_USE_FD_SET, too */
2837
2838Note that winsockets handling of fd sets is O(n), so you can easily get a
2839complexity in the O(n²) range when using win32.
2840
2841=item Limited number of file descriptors
2842
2843Windows has numerous arbitrary (and low) limits on things. Early versions
2844of winsocket's select only supported waiting for a max. of C<64> handles
2845(probably owning to the fact that all windows kernels can only wait for
2846C<64> things at the same time internally; microsoft recommends spawning a
2847chain of threads and wait for 63 handles and the previous thread in each).
2848
2849Newer versions support more handles, but you need to define C<FD_SETSIZE>
2850to some high number (e.g. C<2048>) before compiling the winsocket select
2851call (which might be in libev or elsewhere, for example, perl does its own
2852select emulation on windows).
2853
2854Another limit is the number of file descriptors in the microsoft runtime
2855libraries, which by default is C<64> (there must be a hidden I<64> fetish
2856or something like this inside microsoft). You can increase this by calling
2857C<_setmaxstdio>, which can increase this limit to C<2048> (another
2858arbitrary limit), but is broken in many versions of the microsoft runtime
2859libraries.
2860
2861This might get you to about C<512> or C<2048> sockets (depending on
2862windows version and/or the phase of the moon). To get more, you need to
2863wrap all I/O functions and provide your own fd management, but the cost of
2864calling select (O(n²)) will likely make this unworkable.
2865
2866=back
2867
2868
2777=head1 AUTHOR 2869=head1 AUTHOR
2778 2870
2779Marc Lehmann <libev@schmorp.de>. 2871Marc Lehmann <libev@schmorp.de>.
2780 2872

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines