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

Comparing libev/ev.pod (file contents):
Revision 1.231 by root, Wed Apr 15 19:35:53 2009 UTC vs.
Revision 1.277 by root, Thu Dec 31 06:50:17 2009 UTC

62 62
63 // unloop was called, so exit 63 // unloop was called, so exit
64 return 0; 64 return 0;
65 } 65 }
66 66
67=head1 DESCRIPTION 67=head1 ABOUT THIS DOCUMENT
68
69This document documents the libev software package.
68 70
69The newest version of this document is also available as an html-formatted 71The newest version of this document is also available as an html-formatted
70web page you might find easier to navigate when reading it for the first 72web page you might find easier to navigate when reading it for the first
71time: L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>. 73time: L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod>.
74
75While this document tries to be as complete as possible in documenting
76libev, its usage and the rationale behind its design, it is not a tutorial
77on event-based programming, nor will it introduce event-based programming
78with libev.
79
80Familarity with event based programming techniques in general is assumed
81throughout this document.
82
83=head1 ABOUT LIBEV
72 84
73Libev is an event loop: you register interest in certain events (such as a 85Libev is an event loop: you register interest in certain events (such as a
74file descriptor being readable or a timeout occurring), and it will manage 86file descriptor being readable or a timeout occurring), and it will manage
75these event sources and provide your program with events. 87these event sources and provide your program with events.
76 88
86=head2 FEATURES 98=head2 FEATURES
87 99
88Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the 100Libev supports C<select>, C<poll>, the Linux-specific C<epoll>, the
89BSD-specific C<kqueue> and the Solaris-specific event port mechanisms 101BSD-specific C<kqueue> and the Solaris-specific event port mechanisms
90for file descriptor events (C<ev_io>), the Linux C<inotify> interface 102for file descriptor events (C<ev_io>), the Linux C<inotify> interface
91(for C<ev_stat>), relative timers (C<ev_timer>), absolute timers 103(for C<ev_stat>), Linux eventfd/signalfd (for faster and cleaner
92with customised rescheduling (C<ev_periodic>), synchronous signals 104inter-thread wakeup (C<ev_async>)/signal handling (C<ev_signal>)) relative
93(C<ev_signal>), process status change events (C<ev_child>), and event 105timers (C<ev_timer>), absolute timers with customised rescheduling
94watchers dealing with the event loop mechanism itself (C<ev_idle>, 106(C<ev_periodic>), synchronous signals (C<ev_signal>), process status
95C<ev_embed>, C<ev_prepare> and C<ev_check> watchers) as well as 107change events (C<ev_child>), and event watchers dealing with the event
96file watchers (C<ev_stat>) and even limited support for fork events 108loop mechanism itself (C<ev_idle>, C<ev_embed>, C<ev_prepare> and
97(C<ev_fork>). 109C<ev_check> watchers) as well as file watchers (C<ev_stat>) and even
110limited support for fork events (C<ev_fork>).
98 111
99It also is quite fast (see this 112It also is quite fast (see this
100L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent 113L<benchmark|http://libev.schmorp.de/bench.html> comparing it to libevent
101for example). 114for example).
102 115
105Libev is very configurable. In this manual the default (and most common) 118Libev is very configurable. In this manual the default (and most common)
106configuration will be described, which supports multiple event loops. For 119configuration will be described, which supports multiple event loops. For
107more info about various configuration options please have a look at 120more info about various configuration options please have a look at
108B<EMBED> section in this manual. If libev was configured without support 121B<EMBED> section in this manual. If libev was configured without support
109for multiple event loops, then all functions taking an initial argument of 122for multiple event loops, then all functions taking an initial argument of
110name C<loop> (which is always of type C<ev_loop *>) will not have 123name C<loop> (which is always of type C<struct ev_loop *>) will not have
111this argument. 124this argument.
112 125
113=head2 TIME REPRESENTATION 126=head2 TIME REPRESENTATION
114 127
115Libev represents time as a single floating point number, representing the 128Libev represents time as a single floating point number, representing
116(fractional) number of seconds since the (POSIX) epoch (somewhere near 129the (fractional) number of seconds since the (POSIX) epoch (somewhere
117the beginning of 1970, details are complicated, don't ask). This type is 130near the beginning of 1970, details are complicated, don't ask). This
118called C<ev_tstamp>, which is what you should use too. It usually aliases 131type is called C<ev_tstamp>, which is what you should use too. It usually
119to the C<double> type in C, and when you need to do any calculations on 132aliases to the C<double> type in C. When you need to do any calculations
120it, you should treat it as some floating point value. Unlike the name 133on it, you should treat it as some floating point value. Unlike the name
121component C<stamp> might indicate, it is also used for time differences 134component C<stamp> might indicate, it is also used for time differences
122throughout libev. 135throughout libev.
123 136
124=head1 ERROR HANDLING 137=head1 ERROR HANDLING
125 138
350flag. 363flag.
351 364
352This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS> 365This flag setting cannot be overridden or specified in the C<LIBEV_FLAGS>
353environment variable. 366environment variable.
354 367
368=item C<EVFLAG_NOINOTIFY>
369
370When this flag is specified, then libev will not attempt to use the
371I<inotify> API for it's C<ev_stat> watchers. Apart from debugging and
372testing, this flag can be useful to conserve inotify file descriptors, as
373otherwise each loop using C<ev_stat> watchers consumes one inotify handle.
374
375=item C<EVFLAG_SIGNALFD>
376
377When this flag is specified, then libev will attempt to use the
378I<signalfd> API for it's C<ev_signal> (and C<ev_child>) watchers. This API
379delivers signals synchronously, which makes is both faster and might make
380it possible to get the queued signal data.
381
382Signalfd will not be used by default as this changes your signal mask, and
383there are a lot of shoddy libraries and programs (glib's threadpool for
384example) that can't properly initialise their signal masks.
385
355=item C<EVBACKEND_SELECT> (value 1, portable select backend) 386=item C<EVBACKEND_SELECT> (value 1, portable select backend)
356 387
357This is your standard select(2) backend. Not I<completely> standard, as 388This is your standard select(2) backend. Not I<completely> standard, as
358libev tries to roll its own fd_set with no limits on the number of fds, 389libev tries to roll its own fd_set with no limits on the number of fds,
359but if that fails, expect a fairly low limit on the number of fds when 390but if that fails, expect a fairly low limit on the number of fds when
382 413
383This backend maps C<EV_READ> to C<POLLIN | POLLERR | POLLHUP>, and 414This backend maps C<EV_READ> to C<POLLIN | POLLERR | POLLHUP>, and
384C<EV_WRITE> to C<POLLOUT | POLLERR | POLLHUP>. 415C<EV_WRITE> to C<POLLOUT | POLLERR | POLLHUP>.
385 416
386=item C<EVBACKEND_EPOLL> (value 4, Linux) 417=item C<EVBACKEND_EPOLL> (value 4, Linux)
418
419Use the linux-specific epoll(7) interface (for both pre- and post-2.6.9
420kernels).
387 421
388For few fds, this backend is a bit little slower than poll and select, 422For few fds, this backend is a bit little slower than poll and select,
389but it scales phenomenally better. While poll and select usually scale 423but it scales phenomenally better. While poll and select usually scale
390like O(total_fds) where n is the total number of fds (or the highest fd), 424like O(total_fds) where n is the total number of fds (or the highest fd),
391epoll scales either O(1) or O(active_fds). 425epoll scales either O(1) or O(active_fds).
506 540
507It is definitely not recommended to use this flag. 541It is definitely not recommended to use this flag.
508 542
509=back 543=back
510 544
511If one or more of these are or'ed into the flags value, then only these 545If one or more of the backend flags are or'ed into the flags value,
512backends will be tried (in the reverse order as listed here). If none are 546then only these backends will be tried (in the reverse order as listed
513specified, all backends in C<ev_recommended_backends ()> will be tried. 547here). If none are specified, all backends in C<ev_recommended_backends
548()> will be tried.
514 549
515Example: This is the most typical usage. 550Example: This is the most typical usage.
516 551
517 if (!ev_default_loop (0)) 552 if (!ev_default_loop (0))
518 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?"); 553 fatal ("could not initialise libev, bad $LIBEV_FLAGS in environment?");
561as signal and child watchers) would need to be stopped manually. 596as signal and child watchers) would need to be stopped manually.
562 597
563In general it is not advisable to call this function except in the 598In general it is not advisable to call this function except in the
564rare occasion where you really need to free e.g. the signal handling 599rare occasion where you really need to free e.g. the signal handling
565pipe fds. If you need dynamically allocated loops it is better to use 600pipe fds. If you need dynamically allocated loops it is better to use
566C<ev_loop_new> and C<ev_loop_destroy>). 601C<ev_loop_new> and C<ev_loop_destroy>.
567 602
568=item ev_loop_destroy (loop) 603=item ev_loop_destroy (loop)
569 604
570Like C<ev_default_destroy>, but destroys an event loop created by an 605Like C<ev_default_destroy>, but destroys an event loop created by an
571earlier call to C<ev_loop_new>. 606earlier call to C<ev_loop_new>.
609 644
610This value can sometimes be useful as a generation counter of sorts (it 645This value can sometimes be useful as a generation counter of sorts (it
611"ticks" the number of loop iterations), as it roughly corresponds with 646"ticks" the number of loop iterations), as it roughly corresponds with
612C<ev_prepare> and C<ev_check> calls. 647C<ev_prepare> and C<ev_check> calls.
613 648
649=item unsigned int ev_loop_depth (loop)
650
651Returns the number of times C<ev_loop> was entered minus the number of
652times C<ev_loop> was exited, in other words, the recursion depth.
653
654Outside C<ev_loop>, this number is zero. In a callback, this number is
655C<1>, unless C<ev_loop> was invoked recursively (or from another thread),
656in which case it is higher.
657
658Leaving C<ev_loop> abnormally (setjmp/longjmp, cancelling the thread
659etc.), doesn't count as exit.
660
614=item unsigned int ev_backend (loop) 661=item unsigned int ev_backend (loop)
615 662
616Returns one of the C<EVBACKEND_*> flags indicating the event backend in 663Returns one of the C<EVBACKEND_*> flags indicating the event backend in
617use. 664use.
618 665
632 679
633This function is rarely useful, but when some event callback runs for a 680This function is rarely useful, but when some event callback runs for a
634very long time without entering the event loop, updating libev's idea of 681very long time without entering the event loop, updating libev's idea of
635the current time is a good idea. 682the current time is a good idea.
636 683
637See also "The special problem of time updates" in the C<ev_timer> section. 684See also L<The special problem of time updates> in the C<ev_timer> section.
638 685
639=item ev_suspend (loop) 686=item ev_suspend (loop)
640 687
641=item ev_resume (loop) 688=item ev_resume (loop)
642 689
663event loop time (see C<ev_now_update>). 710event loop time (see C<ev_now_update>).
664 711
665=item ev_loop (loop, int flags) 712=item ev_loop (loop, int flags)
666 713
667Finally, this is it, the event handler. This function usually is called 714Finally, this is it, the event handler. This function usually is called
668after you initialised all your watchers and you want to start handling 715after you have initialised all your watchers and you want to start
669events. 716handling events.
670 717
671If the flags argument is specified as C<0>, it will not return until 718If the flags argument is specified as C<0>, it will not return until
672either no event watchers are active anymore or C<ev_unloop> was called. 719either no event watchers are active anymore or C<ev_unloop> was called.
673 720
674Please note that an explicit C<ev_unloop> is usually better than 721Please note that an explicit C<ev_unloop> is usually better than
748 795
749Ref/unref can be used to add or remove a reference count on the event 796Ref/unref can be used to add or remove a reference count on the event
750loop: Every watcher keeps one reference, and as long as the reference 797loop: Every watcher keeps one reference, and as long as the reference
751count is nonzero, C<ev_loop> will not return on its own. 798count is nonzero, C<ev_loop> will not return on its own.
752 799
753If you have a watcher you never unregister that should not keep C<ev_loop> 800This is useful when you have a watcher that you never intend to
754from returning, call ev_unref() after starting, and ev_ref() before 801unregister, but that nevertheless should not keep C<ev_loop> from
802returning. In such a case, call C<ev_unref> after starting, and C<ev_ref>
755stopping it. 803before stopping it.
756 804
757As an example, libev itself uses this for its internal signal pipe: It 805As an example, libev itself uses this for its internal signal pipe: It
758is not visible to the libev user and should not keep C<ev_loop> from 806is not visible to the libev user and should not keep C<ev_loop> from
759exiting if no event watchers registered by it are active. It is also an 807exiting if no event watchers registered by it are active. It is also an
760excellent way to do this for generic recurring timers or from within 808excellent way to do this for generic recurring timers or from within
799 847
800By setting a higher I<io collect interval> you allow libev to spend more 848By setting a higher I<io collect interval> you allow libev to spend more
801time collecting I/O events, so you can handle more events per iteration, 849time collecting I/O events, so you can handle more events per iteration,
802at the cost of increasing latency. Timeouts (both C<ev_periodic> and 850at the cost of increasing latency. Timeouts (both C<ev_periodic> and
803C<ev_timer>) will be not affected. Setting this to a non-null value will 851C<ev_timer>) will be not affected. Setting this to a non-null value will
804introduce an additional C<ev_sleep ()> call into most loop iterations. 852introduce an additional C<ev_sleep ()> call into most loop iterations. The
853sleep time ensures that libev will not poll for I/O events more often then
854once per this interval, on average.
805 855
806Likewise, by setting a higher I<timeout collect interval> you allow libev 856Likewise, by setting a higher I<timeout collect interval> you allow libev
807to spend more time collecting timeouts, at the expense of increased 857to spend more time collecting timeouts, at the expense of increased
808latency/jitter/inexactness (the watcher callback will be called 858latency/jitter/inexactness (the watcher callback will be called
809later). C<ev_io> watchers will not be affected. Setting this to a non-null 859later). C<ev_io> watchers will not be affected. Setting this to a non-null
811 861
812Many (busy) programs can usually benefit by setting the I/O collect 862Many (busy) programs can usually benefit by setting the I/O collect
813interval to a value near C<0.1> or so, which is often enough for 863interval to a value near C<0.1> or so, which is often enough for
814interactive servers (of course not for games), likewise for timeouts. It 864interactive servers (of course not for games), likewise for timeouts. It
815usually doesn't make much sense to set it to a lower value than C<0.01>, 865usually doesn't make much sense to set it to a lower value than C<0.01>,
816as this approaches the timing granularity of most systems. 866as this approaches the timing granularity of most systems. Note that if
867you do transactions with the outside world and you can't increase the
868parallelity, then this setting will limit your transaction rate (if you
869need to poll once per transaction and the I/O collect interval is 0.01,
870then you can't do more than 100 transations per second).
817 871
818Setting the I<timeout collect interval> can improve the opportunity for 872Setting the I<timeout collect interval> can improve the opportunity for
819saving power, as the program will "bundle" timer callback invocations that 873saving power, as the program will "bundle" timer callback invocations that
820are "near" in time together, by delaying some, thus reducing the number of 874are "near" in time together, by delaying some, thus reducing the number of
821times the process sleeps and wakes up again. Another useful technique to 875times the process sleeps and wakes up again. Another useful technique to
822reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure 876reduce iterations/wake-ups is to use C<ev_periodic> watchers and make sure
823they fire on, say, one-second boundaries only. 877they fire on, say, one-second boundaries only.
878
879Example: we only need 0.1s timeout granularity, and we wish not to poll
880more often than 100 times per second:
881
882 ev_set_timeout_collect_interval (EV_DEFAULT_UC_ 0.1);
883 ev_set_io_collect_interval (EV_DEFAULT_UC_ 0.01);
884
885=item ev_invoke_pending (loop)
886
887This call will simply invoke all pending watchers while resetting their
888pending state. Normally, C<ev_loop> does this automatically when required,
889but when overriding the invoke callback this call comes handy.
890
891=item int ev_pending_count (loop)
892
893Returns the number of pending watchers - zero indicates that no watchers
894are pending.
895
896=item ev_set_invoke_pending_cb (loop, void (*invoke_pending_cb)(EV_P))
897
898This overrides the invoke pending functionality of the loop: Instead of
899invoking all pending watchers when there are any, C<ev_loop> will call
900this callback instead. This is useful, for example, when you want to
901invoke the actual watchers inside another context (another thread etc.).
902
903If you want to reset the callback, use C<ev_invoke_pending> as new
904callback.
905
906=item ev_set_loop_release_cb (loop, void (*release)(EV_P), void (*acquire)(EV_P))
907
908Sometimes you want to share the same loop between multiple threads. This
909can be done relatively simply by putting mutex_lock/unlock calls around
910each call to a libev function.
911
912However, C<ev_loop> can run an indefinite time, so it is not feasible to
913wait for it to return. One way around this is to wake up the loop via
914C<ev_unloop> and C<av_async_send>, another way is to set these I<release>
915and I<acquire> callbacks on the loop.
916
917When set, then C<release> will be called just before the thread is
918suspended waiting for new events, and C<acquire> is called just
919afterwards.
920
921Ideally, C<release> will just call your mutex_unlock function, and
922C<acquire> will just call the mutex_lock function again.
923
924While event loop modifications are allowed between invocations of
925C<release> and C<acquire> (that's their only purpose after all), no
926modifications done will affect the event loop, i.e. adding watchers will
927have no effect on the set of file descriptors being watched, or the time
928waited. Use an C<ev_async> watcher to wake up C<ev_loop> when you want it
929to take note of any changes you made.
930
931In theory, threads executing C<ev_loop> will be async-cancel safe between
932invocations of C<release> and C<acquire>.
933
934See also the locking example in the C<THREADS> section later in this
935document.
936
937=item ev_set_userdata (loop, void *data)
938
939=item ev_userdata (loop)
940
941Set and retrieve a single C<void *> associated with a loop. When
942C<ev_set_userdata> has never been called, then C<ev_userdata> returns
943C<0.>
944
945These two functions can be used to associate arbitrary data with a loop,
946and are intended solely for the C<invoke_pending_cb>, C<release> and
947C<acquire> callbacks described above, but of course can be (ab-)used for
948any other purpose as well.
824 949
825=item ev_loop_verify (loop) 950=item ev_loop_verify (loop)
826 951
827This function only does something when C<EV_VERIFY> support has been 952This function only does something when C<EV_VERIFY> support has been
828compiled in, which is the default for non-minimal builds. It tries to go 953compiled in, which is the default for non-minimal builds. It tries to go
1005 1130
1006 ev_io w; 1131 ev_io w;
1007 ev_init (&w, my_cb); 1132 ev_init (&w, my_cb);
1008 ev_io_set (&w, STDIN_FILENO, EV_READ); 1133 ev_io_set (&w, STDIN_FILENO, EV_READ);
1009 1134
1010=item C<ev_TYPE_set> (ev_TYPE *, [args]) 1135=item C<ev_TYPE_set> (ev_TYPE *watcher, [args])
1011 1136
1012This macro initialises the type-specific parts of a watcher. You need to 1137This macro initialises the type-specific parts of a watcher. You need to
1013call C<ev_init> at least once before you call this macro, but you can 1138call C<ev_init> at least once before you call this macro, but you can
1014call C<ev_TYPE_set> any number of times. You must not, however, call this 1139call C<ev_TYPE_set> any number of times. You must not, however, call this
1015macro on a watcher that is active (it can be pending, however, which is a 1140macro on a watcher that is active (it can be pending, however, which is a
1028 1153
1029Example: Initialise and set an C<ev_io> watcher in one step. 1154Example: Initialise and set an C<ev_io> watcher in one step.
1030 1155
1031 ev_io_init (&w, my_cb, STDIN_FILENO, EV_READ); 1156 ev_io_init (&w, my_cb, STDIN_FILENO, EV_READ);
1032 1157
1033=item C<ev_TYPE_start> (loop *, ev_TYPE *watcher) 1158=item C<ev_TYPE_start> (loop, ev_TYPE *watcher)
1034 1159
1035Starts (activates) the given watcher. Only active watchers will receive 1160Starts (activates) the given watcher. Only active watchers will receive
1036events. If the watcher is already active nothing will happen. 1161events. If the watcher is already active nothing will happen.
1037 1162
1038Example: Start the C<ev_io> watcher that is being abused as example in this 1163Example: Start the C<ev_io> watcher that is being abused as example in this
1039whole section. 1164whole section.
1040 1165
1041 ev_io_start (EV_DEFAULT_UC, &w); 1166 ev_io_start (EV_DEFAULT_UC, &w);
1042 1167
1043=item C<ev_TYPE_stop> (loop *, ev_TYPE *watcher) 1168=item C<ev_TYPE_stop> (loop, ev_TYPE *watcher)
1044 1169
1045Stops the given watcher if active, and clears the pending status (whether 1170Stops the given watcher if active, and clears the pending status (whether
1046the watcher was active or not). 1171the watcher was active or not).
1047 1172
1048It is possible that stopped watchers are pending - for example, 1173It is possible that stopped watchers are pending - for example,
1073=item ev_cb_set (ev_TYPE *watcher, callback) 1198=item ev_cb_set (ev_TYPE *watcher, callback)
1074 1199
1075Change the callback. You can change the callback at virtually any time 1200Change the callback. You can change the callback at virtually any time
1076(modulo threads). 1201(modulo threads).
1077 1202
1078=item ev_set_priority (ev_TYPE *watcher, priority) 1203=item ev_set_priority (ev_TYPE *watcher, int priority)
1079 1204
1080=item int ev_priority (ev_TYPE *watcher) 1205=item int ev_priority (ev_TYPE *watcher)
1081 1206
1082Set and query the priority of the watcher. The priority is a small 1207Set and query the priority of the watcher. The priority is a small
1083integer between C<EV_MAXPRI> (default: C<2>) and C<EV_MINPRI> 1208integer between C<EV_MAXPRI> (default: C<2>) and C<EV_MINPRI>
1084(default: C<-2>). Pending watchers with higher priority will be invoked 1209(default: C<-2>). Pending watchers with higher priority will be invoked
1085before watchers with lower priority, but priority will not keep watchers 1210before watchers with lower priority, but priority will not keep watchers
1086from being executed (except for C<ev_idle> watchers). 1211from being executed (except for C<ev_idle> watchers).
1087 1212
1088This means that priorities are I<only> used for ordering callback
1089invocation after new events have been received. This is useful, for
1090example, to reduce latency after idling, or more often, to bind two
1091watchers on the same event and make sure one is called first.
1092
1093If you need to suppress invocation when higher priority events are pending 1213If you need to suppress invocation when higher priority events are pending
1094you need to look at C<ev_idle> watchers, which provide this functionality. 1214you need to look at C<ev_idle> watchers, which provide this functionality.
1095 1215
1096You I<must not> change the priority of a watcher as long as it is active or 1216You I<must not> change the priority of a watcher as long as it is active or
1097pending. 1217pending.
1098
1099The default priority used by watchers when no priority has been set is
1100always C<0>, which is supposed to not be too high and not be too low :).
1101 1218
1102Setting a priority outside the range of C<EV_MINPRI> to C<EV_MAXPRI> is 1219Setting a priority outside the range of C<EV_MINPRI> to C<EV_MAXPRI> is
1103fine, as long as you do not mind that the priority value you query might 1220fine, as long as you do not mind that the priority value you query might
1104or might not have been clamped to the valid range. 1221or might not have been clamped to the valid range.
1222
1223The default priority used by watchers when no priority has been set is
1224always C<0>, which is supposed to not be too high and not be too low :).
1225
1226See L<WATCHER PRIORITY MODELS>, below, for a more thorough treatment of
1227priorities.
1105 1228
1106=item ev_invoke (loop, ev_TYPE *watcher, int revents) 1229=item ev_invoke (loop, ev_TYPE *watcher, int revents)
1107 1230
1108Invoke the C<watcher> with the given C<loop> and C<revents>. Neither 1231Invoke the C<watcher> with the given C<loop> and C<revents>. Neither
1109C<loop> nor C<revents> need to be valid as long as the watcher callback 1232C<loop> nor C<revents> need to be valid as long as the watcher callback
1116returns its C<revents> bitset (as if its callback was invoked). If the 1239returns its C<revents> bitset (as if its callback was invoked). If the
1117watcher isn't pending it does nothing and returns C<0>. 1240watcher isn't pending it does nothing and returns C<0>.
1118 1241
1119Sometimes it can be useful to "poll" a watcher instead of waiting for its 1242Sometimes it can be useful to "poll" a watcher instead of waiting for its
1120callback to be invoked, which can be accomplished with this function. 1243callback to be invoked, which can be accomplished with this function.
1244
1245=item ev_feed_event (loop, ev_TYPE *watcher, int revents)
1246
1247Feeds the given event set into the event loop, as if the specified event
1248had happened for the specified watcher (which must be a pointer to an
1249initialised but not necessarily started event watcher). Obviously you must
1250not free the watcher as long as it has pending events.
1251
1252Stopping the watcher, letting libev invoke it, or calling
1253C<ev_clear_pending> will clear the pending event, even if the watcher was
1254not started in the first place.
1255
1256See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related
1257functions that do not need a watcher.
1121 1258
1122=back 1259=back
1123 1260
1124 1261
1125=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER 1262=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER
1174 #include <stddef.h> 1311 #include <stddef.h>
1175 1312
1176 static void 1313 static void
1177 t1_cb (EV_P_ ev_timer *w, int revents) 1314 t1_cb (EV_P_ ev_timer *w, int revents)
1178 { 1315 {
1179 struct my_biggy big = (struct my_biggy * 1316 struct my_biggy big = (struct my_biggy *)
1180 (((char *)w) - offsetof (struct my_biggy, t1)); 1317 (((char *)w) - offsetof (struct my_biggy, t1));
1181 } 1318 }
1182 1319
1183 static void 1320 static void
1184 t2_cb (EV_P_ ev_timer *w, int revents) 1321 t2_cb (EV_P_ ev_timer *w, int revents)
1185 { 1322 {
1186 struct my_biggy big = (struct my_biggy * 1323 struct my_biggy big = (struct my_biggy *)
1187 (((char *)w) - offsetof (struct my_biggy, t2)); 1324 (((char *)w) - offsetof (struct my_biggy, t2));
1188 } 1325 }
1326
1327=head2 WATCHER PRIORITY MODELS
1328
1329Many event loops support I<watcher priorities>, which are usually small
1330integers that influence the ordering of event callback invocation
1331between watchers in some way, all else being equal.
1332
1333In libev, Watcher priorities can be set using C<ev_set_priority>. See its
1334description for the more technical details such as the actual priority
1335range.
1336
1337There are two common ways how these these priorities are being interpreted
1338by event loops:
1339
1340In the more common lock-out model, higher priorities "lock out" invocation
1341of lower priority watchers, which means as long as higher priority
1342watchers receive events, lower priority watchers are not being invoked.
1343
1344The less common only-for-ordering model uses priorities solely to order
1345callback invocation within a single event loop iteration: Higher priority
1346watchers are invoked before lower priority ones, but they all get invoked
1347before polling for new events.
1348
1349Libev uses the second (only-for-ordering) model for all its watchers
1350except for idle watchers (which use the lock-out model).
1351
1352The rationale behind this is that implementing the lock-out model for
1353watchers is not well supported by most kernel interfaces, and most event
1354libraries will just poll for the same events again and again as long as
1355their callbacks have not been executed, which is very inefficient in the
1356common case of one high-priority watcher locking out a mass of lower
1357priority ones.
1358
1359Static (ordering) priorities are most useful when you have two or more
1360watchers handling the same resource: a typical usage example is having an
1361C<ev_io> watcher to receive data, and an associated C<ev_timer> to handle
1362timeouts. Under load, data might be received while the program handles
1363other jobs, but since timers normally get invoked first, the timeout
1364handler will be executed before checking for data. In that case, giving
1365the timer a lower priority than the I/O watcher ensures that I/O will be
1366handled first even under adverse conditions (which is usually, but not
1367always, what you want).
1368
1369Since idle watchers use the "lock-out" model, meaning that idle watchers
1370will only be executed when no same or higher priority watchers have
1371received events, they can be used to implement the "lock-out" model when
1372required.
1373
1374For example, to emulate how many other event libraries handle priorities,
1375you can associate an C<ev_idle> watcher to each such watcher, and in
1376the normal watcher callback, you just start the idle watcher. The real
1377processing is done in the idle watcher callback. This causes libev to
1378continously poll and process kernel event data for the watcher, but when
1379the lock-out case is known to be rare (which in turn is rare :), this is
1380workable.
1381
1382Usually, however, the lock-out model implemented that way will perform
1383miserably under the type of load it was designed to handle. In that case,
1384it might be preferable to stop the real watcher before starting the
1385idle watcher, so the kernel will not have to process the event in case
1386the actual processing will be delayed for considerable time.
1387
1388Here is an example of an I/O watcher that should run at a strictly lower
1389priority than the default, and which should only process data when no
1390other events are pending:
1391
1392 ev_idle idle; // actual processing watcher
1393 ev_io io; // actual event watcher
1394
1395 static void
1396 io_cb (EV_P_ ev_io *w, int revents)
1397 {
1398 // stop the I/O watcher, we received the event, but
1399 // are not yet ready to handle it.
1400 ev_io_stop (EV_A_ w);
1401
1402 // start the idle watcher to ahndle the actual event.
1403 // it will not be executed as long as other watchers
1404 // with the default priority are receiving events.
1405 ev_idle_start (EV_A_ &idle);
1406 }
1407
1408 static void
1409 idle_cb (EV_P_ ev_idle *w, int revents)
1410 {
1411 // actual processing
1412 read (STDIN_FILENO, ...);
1413
1414 // have to start the I/O watcher again, as
1415 // we have handled the event
1416 ev_io_start (EV_P_ &io);
1417 }
1418
1419 // initialisation
1420 ev_idle_init (&idle, idle_cb);
1421 ev_io_init (&io, io_cb, STDIN_FILENO, EV_READ);
1422 ev_io_start (EV_DEFAULT_ &io);
1423
1424In the "real" world, it might also be beneficial to start a timer, so that
1425low-priority connections can not be locked out forever under load. This
1426enables your program to keep a lower latency for important connections
1427during short periods of high load, while not completely locking out less
1428important ones.
1189 1429
1190 1430
1191=head1 WATCHER TYPES 1431=head1 WATCHER TYPES
1192 1432
1193This section describes each watcher in detail, but will not repeat 1433This section describes each watcher in detail, but will not repeat
1219descriptors to non-blocking mode is also usually a good idea (but not 1459descriptors to non-blocking mode is also usually a good idea (but not
1220required if you know what you are doing). 1460required if you know what you are doing).
1221 1461
1222If you cannot use non-blocking mode, then force the use of a 1462If you cannot use non-blocking mode, then force the use of a
1223known-to-be-good backend (at the time of this writing, this includes only 1463known-to-be-good backend (at the time of this writing, this includes only
1224C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). 1464C<EVBACKEND_SELECT> and C<EVBACKEND_POLL>). The same applies to file
1465descriptors for which non-blocking operation makes no sense (such as
1466files) - libev doesn't guarentee any specific behaviour in that case.
1225 1467
1226Another thing you have to watch out for is that it is quite easy to 1468Another thing you have to watch out for is that it is quite easy to
1227receive "spurious" readiness notifications, that is your callback might 1469receive "spurious" readiness notifications, that is your callback might
1228be called with C<EV_READ> but a subsequent C<read>(2) will actually block 1470be called with C<EV_READ> but a subsequent C<read>(2) will actually block
1229because there is no data. Not only are some backends known to create a 1471because there is no data. Not only are some backends known to create a
1350year, it will still time out after (roughly) one hour. "Roughly" because 1592year, it will still time out after (roughly) one hour. "Roughly" because
1351detecting time jumps is hard, and some inaccuracies are unavoidable (the 1593detecting time jumps is hard, and some inaccuracies are unavoidable (the
1352monotonic clock option helps a lot here). 1594monotonic clock option helps a lot here).
1353 1595
1354The callback is guaranteed to be invoked only I<after> its timeout has 1596The callback is guaranteed to be invoked only I<after> its timeout has
1355passed. If multiple timers become ready during the same loop iteration 1597passed (not I<at>, so on systems with very low-resolution clocks this
1356then the ones with earlier time-out values are invoked before ones with 1598might introduce a small delay). If multiple timers become ready during the
1357later time-out values (but this is no longer true when a callback calls 1599same loop iteration then the ones with earlier time-out values are invoked
1358C<ev_loop> recursively). 1600before ones of the same priority with later time-out values (but this is
1601no longer true when a callback calls C<ev_loop> recursively).
1359 1602
1360=head3 Be smart about timeouts 1603=head3 Be smart about timeouts
1361 1604
1362Many real-world problems involve some kind of timeout, usually for error 1605Many real-world problems involve some kind of timeout, usually for error
1363recovery. A typical example is an HTTP request - if the other side hangs, 1606recovery. A typical example is an HTTP request - if the other side hangs,
1407C<after> argument to C<ev_timer_set>, and only ever use the C<repeat> 1650C<after> argument to C<ev_timer_set>, and only ever use the C<repeat>
1408member and C<ev_timer_again>. 1651member and C<ev_timer_again>.
1409 1652
1410At start: 1653At start:
1411 1654
1412 ev_timer_init (timer, callback); 1655 ev_init (timer, callback);
1413 timer->repeat = 60.; 1656 timer->repeat = 60.;
1414 ev_timer_again (loop, timer); 1657 ev_timer_again (loop, timer);
1415 1658
1416Each time there is some activity: 1659Each time there is some activity:
1417 1660
1479 1722
1480To start the timer, simply initialise the watcher and set C<last_activity> 1723To start the timer, simply initialise the watcher and set C<last_activity>
1481to the current time (meaning we just have some activity :), then call the 1724to the current time (meaning we just have some activity :), then call the
1482callback, which will "do the right thing" and start the timer: 1725callback, which will "do the right thing" and start the timer:
1483 1726
1484 ev_timer_init (timer, callback); 1727 ev_init (timer, callback);
1485 last_activity = ev_now (loop); 1728 last_activity = ev_now (loop);
1486 callback (loop, timer, EV_TIMEOUT); 1729 callback (loop, timer, EV_TIMEOUT);
1487 1730
1488And when there is some activity, simply store the current time in 1731And when there is some activity, simply store the current time in
1489C<last_activity>, no libev calls at all: 1732C<last_activity>, no libev calls at all:
1550 1793
1551If the event loop is suspended for a long time, you can also force an 1794If the event loop is suspended for a long time, you can also force an
1552update of the time returned by C<ev_now ()> by calling C<ev_now_update 1795update of the time returned by C<ev_now ()> by calling C<ev_now_update
1553()>. 1796()>.
1554 1797
1798=head3 The special problems of suspended animation
1799
1800When you leave the server world it is quite customary to hit machines that
1801can suspend/hibernate - what happens to the clocks during such a suspend?
1802
1803Some quick tests made with a Linux 2.6.28 indicate that a suspend freezes
1804all processes, while the clocks (C<times>, C<CLOCK_MONOTONIC>) continue
1805to run until the system is suspended, but they will not advance while the
1806system is suspended. That means, on resume, it will be as if the program
1807was frozen for a few seconds, but the suspend time will not be counted
1808towards C<ev_timer> when a monotonic clock source is used. The real time
1809clock advanced as expected, but if it is used as sole clocksource, then a
1810long suspend would be detected as a time jump by libev, and timers would
1811be adjusted accordingly.
1812
1813I would not be surprised to see different behaviour in different between
1814operating systems, OS versions or even different hardware.
1815
1816The other form of suspend (job control, or sending a SIGSTOP) will see a
1817time jump in the monotonic clocks and the realtime clock. If the program
1818is suspended for a very long time, and monotonic clock sources are in use,
1819then you can expect C<ev_timer>s to expire as the full suspension time
1820will be counted towards the timers. When no monotonic clock source is in
1821use, then libev will again assume a timejump and adjust accordingly.
1822
1823It might be beneficial for this latter case to call C<ev_suspend>
1824and C<ev_resume> in code that handles C<SIGTSTP>, to at least get
1825deterministic behaviour in this case (you can do nothing against
1826C<SIGSTOP>).
1827
1555=head3 Watcher-Specific Functions and Data Members 1828=head3 Watcher-Specific Functions and Data Members
1556 1829
1557=over 4 1830=over 4
1558 1831
1559=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat) 1832=item ev_timer_init (ev_timer *, callback, ev_tstamp after, ev_tstamp repeat)
1582If the timer is started but non-repeating, stop it (as if it timed out). 1855If the timer is started but non-repeating, stop it (as if it timed out).
1583 1856
1584If the timer is repeating, either start it if necessary (with the 1857If the timer is repeating, either start it if necessary (with the
1585C<repeat> value), or reset the running timer to the C<repeat> value. 1858C<repeat> value), or reset the running timer to the C<repeat> value.
1586 1859
1587This sounds a bit complicated, see "Be smart about timeouts", above, for a 1860This sounds a bit complicated, see L<Be smart about timeouts>, above, for a
1588usage example. 1861usage example.
1862
1863=item ev_tstamp ev_timer_remaining (loop, ev_timer *)
1864
1865Returns the remaining time until a timer fires. If the timer is active,
1866then this time is relative to the current event loop time, otherwise it's
1867the timeout value currently configured.
1868
1869That is, after an C<ev_timer_set (w, 5, 7)>, C<ev_timer_remaining> returns
1870C<5>. When the timer is started and one second passes, C<ev_timer_remain>
1871will return C<4>. When the timer expires and is restarted, it will return
1872roughly C<7> (likely slightly less as callback invocation takes some time,
1873too), and so on.
1589 1874
1590=item ev_tstamp repeat [read-write] 1875=item ev_tstamp repeat [read-write]
1591 1876
1592The current C<repeat> value. Will be used each time the watcher times out 1877The current C<repeat> value. Will be used each time the watcher times out
1593or C<ev_timer_again> is called, and determines the next timeout (if any), 1878or C<ev_timer_again> is called, and determines the next timeout (if any),
1829Signal watchers will trigger an event when the process receives a specific 2114Signal watchers will trigger an event when the process receives a specific
1830signal one or more times. Even though signals are very asynchronous, libev 2115signal one or more times. Even though signals are very asynchronous, libev
1831will try it's best to deliver signals synchronously, i.e. as part of the 2116will try it's best to deliver signals synchronously, i.e. as part of the
1832normal event processing, like any other event. 2117normal event processing, like any other event.
1833 2118
1834If you want signals asynchronously, just use C<sigaction> as you would 2119If you want signals to be delivered truly asynchronously, just use
1835do without libev and forget about sharing the signal. You can even use 2120C<sigaction> as you would do without libev and forget about sharing
1836C<ev_async> from a signal handler to synchronously wake up an event loop. 2121the signal. You can even use C<ev_async> from a signal handler to
2122synchronously wake up an event loop.
1837 2123
1838You can configure as many watchers as you like per signal. Only when the 2124You can configure as many watchers as you like for the same signal, but
2125only within the same loop, i.e. you can watch for C<SIGINT> in your
2126default loop and for C<SIGIO> in another loop, but you cannot watch for
2127C<SIGINT> in both the default loop and another loop at the same time. At
2128the moment, C<SIGCHLD> is permanently tied to the default loop.
2129
1839first watcher gets started will libev actually register a signal handler 2130When the first watcher gets started will libev actually register something
1840with the kernel (thus it coexists with your own signal handlers as long as 2131with the kernel (thus it coexists with your own signal handlers as long as
1841you don't register any with libev for the same signal). Similarly, when 2132you don't register any with libev for the same signal).
1842the last signal watcher for a signal is stopped, libev will reset the
1843signal handler to SIG_DFL (regardless of what it was set to before).
1844 2133
1845If possible and supported, libev will install its handlers with 2134If possible and supported, libev will install its handlers with
1846C<SA_RESTART> behaviour enabled, so system calls should not be unduly 2135C<SA_RESTART> (or equivalent) behaviour enabled, so system calls should
1847interrupted. If you have a problem with system calls getting interrupted by 2136not be unduly interrupted. If you have a problem with system calls getting
1848signals you can block all signals in an C<ev_check> watcher and unblock 2137interrupted by signals you can block all signals in an C<ev_check> watcher
1849them in an C<ev_prepare> watcher. 2138and unblock them in an C<ev_prepare> watcher.
2139
2140=head3 The special problem of inheritance over fork/execve/pthread_create
2141
2142Both the signal mask (C<sigprocmask>) and the signal disposition
2143(C<sigaction>) are unspecified after starting a signal watcher (and after
2144stopping it again), that is, libev might or might not block the signal,
2145and might or might not set or restore the installed signal handler.
2146
2147While this does not matter for the signal disposition (libev never
2148sets signals to C<SIG_IGN>, so handlers will be reset to C<SIG_DFL> on
2149C<execve>), this matters for the signal mask: many programs do not expect
2150certain signals to be blocked.
2151
2152This means that before calling C<exec> (from the child) you should reset
2153the signal mask to whatever "default" you expect (all clear is a good
2154choice usually).
2155
2156The simplest way to ensure that the signal mask is reset in the child is
2157to install a fork handler with C<pthread_atfork> that resets it. That will
2158catch fork calls done by libraries (such as the libc) as well.
2159
2160In current versions of libev, the signal will not be blocked indefinitely
2161unless you use the C<signalfd> API (C<EV_SIGNALFD>). While this reduces
2162the window of opportunity for problems, it will not go away, as libev
2163I<has> to modify the signal mask, at least temporarily.
2164
2165So I can't stress this enough I<if you do not reset your signal mask
2166when you expect it to be empty, you have a race condition in your
2167program>. This is not a libev-specific thing, this is true for most event
2168libraries.
1850 2169
1851=head3 Watcher-Specific Functions and Data Members 2170=head3 Watcher-Specific Functions and Data Members
1852 2171
1853=over 4 2172=over 4
1854 2173
1886some child status changes (most typically when a child of yours dies or 2205some child status changes (most typically when a child of yours dies or
1887exits). It is permissible to install a child watcher I<after> the child 2206exits). It is permissible to install a child watcher I<after> the child
1888has been forked (which implies it might have already exited), as long 2207has been forked (which implies it might have already exited), as long
1889as the event loop isn't entered (or is continued from a watcher), i.e., 2208as the event loop isn't entered (or is continued from a watcher), i.e.,
1890forking and then immediately registering a watcher for the child is fine, 2209forking and then immediately registering a watcher for the child is fine,
1891but forking and registering a watcher a few event loop iterations later is 2210but forking and registering a watcher a few event loop iterations later or
1892not. 2211in the next callback invocation is not.
1893 2212
1894Only the default event loop is capable of handling signals, and therefore 2213Only the default event loop is capable of handling signals, and therefore
1895you can only register child watchers in the default event loop. 2214you can only register child watchers in the default event loop.
1896 2215
2216Due to some design glitches inside libev, child watchers will always be
2217handled at maximum priority (their priority is set to C<EV_MAXPRI> by
2218libev)
2219
1897=head3 Process Interaction 2220=head3 Process Interaction
1898 2221
1899Libev grabs C<SIGCHLD> as soon as the default event loop is 2222Libev grabs C<SIGCHLD> as soon as the default event loop is
1900initialised. This is necessary to guarantee proper behaviour even if 2223initialised. This is necessary to guarantee proper behaviour even if the
1901the first child watcher is started after the child exits. The occurrence 2224first child watcher is started after the child exits. The occurrence
1902of C<SIGCHLD> is recorded asynchronously, but child reaping is done 2225of C<SIGCHLD> is recorded asynchronously, but child reaping is done
1903synchronously as part of the event loop processing. Libev always reaps all 2226synchronously as part of the event loop processing. Libev always reaps all
1904children, even ones not watched. 2227children, even ones not watched.
1905 2228
1906=head3 Overriding the Built-In Processing 2229=head3 Overriding the Built-In Processing
1916=head3 Stopping the Child Watcher 2239=head3 Stopping the Child Watcher
1917 2240
1918Currently, the child watcher never gets stopped, even when the 2241Currently, the child watcher never gets stopped, even when the
1919child terminates, so normally one needs to stop the watcher in the 2242child terminates, so normally one needs to stop the watcher in the
1920callback. Future versions of libev might stop the watcher automatically 2243callback. Future versions of libev might stop the watcher automatically
1921when a child exit is detected. 2244when a child exit is detected (calling C<ev_child_stop> twice is not a
2245problem).
1922 2246
1923=head3 Watcher-Specific Functions and Data Members 2247=head3 Watcher-Specific Functions and Data Members
1924 2248
1925=over 4 2249=over 4
1926 2250
2252 // no longer anything immediate to do. 2576 // no longer anything immediate to do.
2253 } 2577 }
2254 2578
2255 ev_idle *idle_watcher = malloc (sizeof (ev_idle)); 2579 ev_idle *idle_watcher = malloc (sizeof (ev_idle));
2256 ev_idle_init (idle_watcher, idle_cb); 2580 ev_idle_init (idle_watcher, idle_cb);
2257 ev_idle_start (loop, idle_cb); 2581 ev_idle_start (loop, idle_watcher);
2258 2582
2259 2583
2260=head2 C<ev_prepare> and C<ev_check> - customise your event loop! 2584=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
2261 2585
2262Prepare and check watchers are usually (but not always) used in pairs: 2586Prepare and check watchers are usually (but not always) used in pairs:
2355 struct pollfd fds [nfd]; 2679 struct pollfd fds [nfd];
2356 // actual code will need to loop here and realloc etc. 2680 // actual code will need to loop here and realloc etc.
2357 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ())); 2681 adns_beforepoll (ads, fds, &nfd, &timeout, timeval_from (ev_time ()));
2358 2682
2359 /* the callback is illegal, but won't be called as we stop during check */ 2683 /* the callback is illegal, but won't be called as we stop during check */
2360 ev_timer_init (&tw, 0, timeout * 1e-3); 2684 ev_timer_init (&tw, 0, timeout * 1e-3, 0.);
2361 ev_timer_start (loop, &tw); 2685 ev_timer_start (loop, &tw);
2362 2686
2363 // create one ev_io per pollfd 2687 // create one ev_io per pollfd
2364 for (int i = 0; i < nfd; ++i) 2688 for (int i = 0; i < nfd; ++i)
2365 { 2689 {
2595event loop blocks next and before C<ev_check> watchers are being called, 2919event loop blocks next and before C<ev_check> watchers are being called,
2596and only in the child after the fork. If whoever good citizen calling 2920and only in the child after the fork. If whoever good citizen calling
2597C<ev_default_fork> cheats and calls it in the wrong process, the fork 2921C<ev_default_fork> cheats and calls it in the wrong process, the fork
2598handlers will be invoked, too, of course. 2922handlers will be invoked, too, of course.
2599 2923
2924=head3 The special problem of life after fork - how is it possible?
2925
2926Most uses of C<fork()> consist of forking, then some simple calls to ste
2927up/change the process environment, followed by a call to C<exec()>. This
2928sequence should be handled by libev without any problems.
2929
2930This changes when the application actually wants to do event handling
2931in the child, or both parent in child, in effect "continuing" after the
2932fork.
2933
2934The default mode of operation (for libev, with application help to detect
2935forks) is to duplicate all the state in the child, as would be expected
2936when I<either> the parent I<or> the child process continues.
2937
2938When both processes want to continue using libev, then this is usually the
2939wrong result. In that case, usually one process (typically the parent) is
2940supposed to continue with all watchers in place as before, while the other
2941process typically wants to start fresh, i.e. without any active watchers.
2942
2943The cleanest and most efficient way to achieve that with libev is to
2944simply create a new event loop, which of course will be "empty", and
2945use that for new watchers. This has the advantage of not touching more
2946memory than necessary, and thus avoiding the copy-on-write, and the
2947disadvantage of having to use multiple event loops (which do not support
2948signal watchers).
2949
2950When this is not possible, or you want to use the default loop for
2951other reasons, then in the process that wants to start "fresh", call
2952C<ev_default_destroy ()> followed by C<ev_default_loop (...)>. Destroying
2953the default loop will "orphan" (not stop) all registered watchers, so you
2954have to be careful not to execute code that modifies those watchers. Note
2955also that in that case, you have to re-register any signal watchers.
2956
2600=head3 Watcher-Specific Functions and Data Members 2957=head3 Watcher-Specific Functions and Data Members
2601 2958
2602=over 4 2959=over 4
2603 2960
2604=item ev_fork_init (ev_signal *, callback) 2961=item ev_fork_init (ev_signal *, callback)
2633=head3 Queueing 2990=head3 Queueing
2634 2991
2635C<ev_async> does not support queueing of data in any way. The reason 2992C<ev_async> does not support queueing of data in any way. The reason
2636is that the author does not know of a simple (or any) algorithm for a 2993is that the author does not know of a simple (or any) algorithm for a
2637multiple-writer-single-reader queue that works in all cases and doesn't 2994multiple-writer-single-reader queue that works in all cases and doesn't
2638need elaborate support such as pthreads. 2995need elaborate support such as pthreads or unportable memory access
2996semantics.
2639 2997
2640That means that if you want to queue data, you have to provide your own 2998That means that if you want to queue data, you have to provide your own
2641queue. But at least I can tell you how to implement locking around your 2999queue. But at least I can tell you how to implement locking around your
2642queue: 3000queue:
2643 3001
2801 /* doh, nothing entered */; 3159 /* doh, nothing entered */;
2802 } 3160 }
2803 3161
2804 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0); 3162 ev_once (STDIN_FILENO, EV_READ, 10., stdin_ready, 0);
2805 3163
2806=item ev_feed_event (struct ev_loop *, watcher *, int revents)
2807
2808Feeds the given event set into the event loop, as if the specified event
2809had happened for the specified watcher (which must be a pointer to an
2810initialised but not necessarily started event watcher).
2811
2812=item ev_feed_fd_event (struct ev_loop *, int fd, int revents) 3164=item ev_feed_fd_event (loop, int fd, int revents)
2813 3165
2814Feed an event on the given fd, as if a file descriptor backend detected 3166Feed an event on the given fd, as if a file descriptor backend detected
2815the given events it. 3167the given events it.
2816 3168
2817=item ev_feed_signal_event (struct ev_loop *loop, int signum) 3169=item ev_feed_signal_event (loop, int signum)
2818 3170
2819Feed an event as if the given signal occurred (C<loop> must be the default 3171Feed an event as if the given signal occurred (C<loop> must be the default
2820loop!). 3172loop!).
2821 3173
2822=back 3174=back
2902 3254
2903=over 4 3255=over 4
2904 3256
2905=item ev::TYPE::TYPE () 3257=item ev::TYPE::TYPE ()
2906 3258
2907=item ev::TYPE::TYPE (struct ev_loop *) 3259=item ev::TYPE::TYPE (loop)
2908 3260
2909=item ev::TYPE::~TYPE 3261=item ev::TYPE::~TYPE
2910 3262
2911The constructor (optionally) takes an event loop to associate the watcher 3263The constructor (optionally) takes an event loop to associate the watcher
2912with. If it is omitted, it will use C<EV_DEFAULT>. 3264with. If it is omitted, it will use C<EV_DEFAULT>.
2989Example: Use a plain function as callback. 3341Example: Use a plain function as callback.
2990 3342
2991 static void io_cb (ev::io &w, int revents) { } 3343 static void io_cb (ev::io &w, int revents) { }
2992 iow.set <io_cb> (); 3344 iow.set <io_cb> ();
2993 3345
2994=item w->set (struct ev_loop *) 3346=item w->set (loop)
2995 3347
2996Associates a different C<struct ev_loop> with this watcher. You can only 3348Associates a different C<struct ev_loop> with this watcher. You can only
2997do this when the watcher is inactive (and not pending either). 3349do this when the watcher is inactive (and not pending either).
2998 3350
2999=item w->set ([arguments]) 3351=item w->set ([arguments])
3096=item Ocaml 3448=item Ocaml
3097 3449
3098Erkki Seppala has written Ocaml bindings for libev, to be found at 3450Erkki Seppala has written Ocaml bindings for libev, to be found at
3099L<http://modeemi.cs.tut.fi/~flux/software/ocaml-ev/>. 3451L<http://modeemi.cs.tut.fi/~flux/software/ocaml-ev/>.
3100 3452
3453=item Lua
3454
3455Brian Maher has written a partial interface to libev
3456for lua (only C<ev_io> and C<ev_timer>), to be found at
3457L<http://github.com/brimworks/lua-ev>.
3458
3101=back 3459=back
3102 3460
3103 3461
3104=head1 MACRO MAGIC 3462=head1 MACRO MAGIC
3105 3463
3271keeps libev from including F<config.h>, and it also defines dummy 3629keeps libev from including F<config.h>, and it also defines dummy
3272implementations for some libevent functions (such as logging, which is not 3630implementations for some libevent functions (such as logging, which is not
3273supported). It will also not define any of the structs usually found in 3631supported). It will also not define any of the structs usually found in
3274F<event.h> that are not directly supported by the libev core alone. 3632F<event.h> that are not directly supported by the libev core alone.
3275 3633
3276In stanbdalone mode, libev will still try to automatically deduce the 3634In standalone mode, libev will still try to automatically deduce the
3277configuration, but has to be more conservative. 3635configuration, but has to be more conservative.
3278 3636
3279=item EV_USE_MONOTONIC 3637=item EV_USE_MONOTONIC
3280 3638
3281If defined to be C<1>, libev will try to detect the availability of the 3639If defined to be C<1>, libev will try to detect the availability of the
3346be used is the winsock select). This means that it will call 3704be used is the winsock select). This means that it will call
3347C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise, 3705C<_get_osfhandle> on the fd to convert it to an OS handle. Otherwise,
3348it is assumed that all these functions actually work on fds, even 3706it is assumed that all these functions actually work on fds, even
3349on win32. Should not be defined on non-win32 platforms. 3707on win32. Should not be defined on non-win32 platforms.
3350 3708
3351=item EV_FD_TO_WIN32_HANDLE 3709=item EV_FD_TO_WIN32_HANDLE(fd)
3352 3710
3353If C<EV_SELECT_IS_WINSOCKET> is enabled, then libev needs a way to map 3711If C<EV_SELECT_IS_WINSOCKET> is enabled, then libev needs a way to map
3354file descriptors to socket handles. When not defining this symbol (the 3712file descriptors to socket handles. When not defining this symbol (the
3355default), then libev will call C<_get_osfhandle>, which is usually 3713default), then libev will call C<_get_osfhandle>, which is usually
3356correct. In some cases, programs use their own file descriptor management, 3714correct. In some cases, programs use their own file descriptor management,
3357in which case they can provide this function to map fds to socket handles. 3715in which case they can provide this function to map fds to socket handles.
3716
3717=item EV_WIN32_HANDLE_TO_FD(handle)
3718
3719If C<EV_SELECT_IS_WINSOCKET> then libev maps handles to file descriptors
3720using the standard C<_open_osfhandle> function. For programs implementing
3721their own fd to handle mapping, overwriting this function makes it easier
3722to do so. This can be done by defining this macro to an appropriate value.
3723
3724=item EV_WIN32_CLOSE_FD(fd)
3725
3726If programs implement their own fd to handle mapping on win32, then this
3727macro can be used to override the C<close> function, useful to unregister
3728file descriptors again. Note that the replacement function has to close
3729the underlying OS handle.
3358 3730
3359=item EV_USE_POLL 3731=item EV_USE_POLL
3360 3732
3361If defined to be C<1>, libev will compile in support for the C<poll>(2) 3733If defined to be C<1>, libev will compile in support for the C<poll>(2)
3362backend. Otherwise it will be enabled on non-win32 platforms. It 3734backend. Otherwise it will be enabled on non-win32 platforms. It
3494defined to be C<0>, then they are not. 3866defined to be C<0>, then they are not.
3495 3867
3496=item EV_MINIMAL 3868=item EV_MINIMAL
3497 3869
3498If you need to shave off some kilobytes of code at the expense of some 3870If you need to shave off some kilobytes of code at the expense of some
3499speed, define this symbol to C<1>. Currently this is used to override some 3871speed (but with the full API), define this symbol to C<1>. Currently this
3500inlining decisions, saves roughly 30% code size on amd64. It also selects a 3872is used to override some inlining decisions, saves roughly 30% code size
3501much smaller 2-heap for timer management over the default 4-heap. 3873on amd64. It also selects a much smaller 2-heap for timer management over
3874the default 4-heap.
3875
3876You can save even more by disabling watcher types you do not need
3877and setting C<EV_MAXPRI> == C<EV_MINPRI>. Also, disabling C<assert>
3878(C<-DNDEBUG>) will usually reduce code size a lot.
3879
3880Defining C<EV_MINIMAL> to C<2> will additionally reduce the core API to
3881provide a bare-bones event library. See C<ev.h> for details on what parts
3882of the API are still available, and do not complain if this subset changes
3883over time.
3884
3885=item EV_NSIG
3886
3887The highest supported signal number, +1 (or, the number of
3888signals): Normally, libev tries to deduce the maximum number of signals
3889automatically, but sometimes this fails, in which case it can be
3890specified. Also, using a lower number than detected (C<32> should be
3891good for about any system in existance) can save some memory, as libev
3892statically allocates some 12-24 bytes per signal number.
3502 3893
3503=item EV_PID_HASHSIZE 3894=item EV_PID_HASHSIZE
3504 3895
3505C<ev_child> watchers use a small hash table to distribute workload by 3896C<ev_child> watchers use a small hash table to distribute workload by
3506pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more 3897pid. The default size is C<16> (or C<1> with C<EV_MINIMAL>), usually more
3692default loop and triggering an C<ev_async> watcher from the default loop 4083default loop and triggering an C<ev_async> watcher from the default loop
3693watcher callback into the event loop interested in the signal. 4084watcher callback into the event loop interested in the signal.
3694 4085
3695=back 4086=back
3696 4087
4088=head4 THREAD LOCKING EXAMPLE
4089
4090Here is a fictitious example of how to run an event loop in a different
4091thread than where callbacks are being invoked and watchers are
4092created/added/removed.
4093
4094For a real-world example, see the C<EV::Loop::Async> perl module,
4095which uses exactly this technique (which is suited for many high-level
4096languages).
4097
4098The example uses a pthread mutex to protect the loop data, a condition
4099variable to wait for callback invocations, an async watcher to notify the
4100event loop thread and an unspecified mechanism to wake up the main thread.
4101
4102First, you need to associate some data with the event loop:
4103
4104 typedef struct {
4105 mutex_t lock; /* global loop lock */
4106 ev_async async_w;
4107 thread_t tid;
4108 cond_t invoke_cv;
4109 } userdata;
4110
4111 void prepare_loop (EV_P)
4112 {
4113 // for simplicity, we use a static userdata struct.
4114 static userdata u;
4115
4116 ev_async_init (&u->async_w, async_cb);
4117 ev_async_start (EV_A_ &u->async_w);
4118
4119 pthread_mutex_init (&u->lock, 0);
4120 pthread_cond_init (&u->invoke_cv, 0);
4121
4122 // now associate this with the loop
4123 ev_set_userdata (EV_A_ u);
4124 ev_set_invoke_pending_cb (EV_A_ l_invoke);
4125 ev_set_loop_release_cb (EV_A_ l_release, l_acquire);
4126
4127 // then create the thread running ev_loop
4128 pthread_create (&u->tid, 0, l_run, EV_A);
4129 }
4130
4131The callback for the C<ev_async> watcher does nothing: the watcher is used
4132solely to wake up the event loop so it takes notice of any new watchers
4133that might have been added:
4134
4135 static void
4136 async_cb (EV_P_ ev_async *w, int revents)
4137 {
4138 // just used for the side effects
4139 }
4140
4141The C<l_release> and C<l_acquire> callbacks simply unlock/lock the mutex
4142protecting the loop data, respectively.
4143
4144 static void
4145 l_release (EV_P)
4146 {
4147 userdata *u = ev_userdata (EV_A);
4148 pthread_mutex_unlock (&u->lock);
4149 }
4150
4151 static void
4152 l_acquire (EV_P)
4153 {
4154 userdata *u = ev_userdata (EV_A);
4155 pthread_mutex_lock (&u->lock);
4156 }
4157
4158The event loop thread first acquires the mutex, and then jumps straight
4159into C<ev_loop>:
4160
4161 void *
4162 l_run (void *thr_arg)
4163 {
4164 struct ev_loop *loop = (struct ev_loop *)thr_arg;
4165
4166 l_acquire (EV_A);
4167 pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS, 0);
4168 ev_loop (EV_A_ 0);
4169 l_release (EV_A);
4170
4171 return 0;
4172 }
4173
4174Instead of invoking all pending watchers, the C<l_invoke> callback will
4175signal the main thread via some unspecified mechanism (signals? pipe
4176writes? C<Async::Interrupt>?) and then waits until all pending watchers
4177have been called (in a while loop because a) spurious wakeups are possible
4178and b) skipping inter-thread-communication when there are no pending
4179watchers is very beneficial):
4180
4181 static void
4182 l_invoke (EV_P)
4183 {
4184 userdata *u = ev_userdata (EV_A);
4185
4186 while (ev_pending_count (EV_A))
4187 {
4188 wake_up_other_thread_in_some_magic_or_not_so_magic_way ();
4189 pthread_cond_wait (&u->invoke_cv, &u->lock);
4190 }
4191 }
4192
4193Now, whenever the main thread gets told to invoke pending watchers, it
4194will grab the lock, call C<ev_invoke_pending> and then signal the loop
4195thread to continue:
4196
4197 static void
4198 real_invoke_pending (EV_P)
4199 {
4200 userdata *u = ev_userdata (EV_A);
4201
4202 pthread_mutex_lock (&u->lock);
4203 ev_invoke_pending (EV_A);
4204 pthread_cond_signal (&u->invoke_cv);
4205 pthread_mutex_unlock (&u->lock);
4206 }
4207
4208Whenever you want to start/stop a watcher or do other modifications to an
4209event loop, you will now have to lock:
4210
4211 ev_timer timeout_watcher;
4212 userdata *u = ev_userdata (EV_A);
4213
4214 ev_timer_init (&timeout_watcher, timeout_cb, 5.5, 0.);
4215
4216 pthread_mutex_lock (&u->lock);
4217 ev_timer_start (EV_A_ &timeout_watcher);
4218 ev_async_send (EV_A_ &u->async_w);
4219 pthread_mutex_unlock (&u->lock);
4220
4221Note that sending the C<ev_async> watcher is required because otherwise
4222an event loop currently blocking in the kernel will have no knowledge
4223about the newly added timer. By waking up the loop it will pick up any new
4224watchers in the next event loop iteration.
4225
3697=head3 COROUTINES 4226=head3 COROUTINES
3698 4227
3699Libev is very accommodating to coroutines ("cooperative threads"): 4228Libev is very accommodating to coroutines ("cooperative threads"):
3700libev fully supports nesting calls to its functions from different 4229libev fully supports nesting calls to its functions from different
3701coroutines (e.g. you can call C<ev_loop> on the same loop from two 4230coroutines (e.g. you can call C<ev_loop> on the same loop from two
3702different coroutines, and switch freely between both coroutines running the 4231different coroutines, and switch freely between both coroutines running
3703loop, as long as you don't confuse yourself). The only exception is that 4232the loop, as long as you don't confuse yourself). The only exception is
3704you must not do this from C<ev_periodic> reschedule callbacks. 4233that you must not do this from C<ev_periodic> reschedule callbacks.
3705 4234
3706Care has been taken to ensure that libev does not keep local state inside 4235Care has been taken to ensure that libev does not keep local state inside
3707C<ev_loop>, and other calls do not usually allow for coroutine switches as 4236C<ev_loop>, and other calls do not usually allow for coroutine switches as
3708they do not call any callbacks. 4237they do not call any callbacks.
3709 4238
3786way (note also that glib is the slowest event library known to man). 4315way (note also that glib is the slowest event library known to man).
3787 4316
3788There is no supported compilation method available on windows except 4317There is no supported compilation method available on windows except
3789embedding it into other applications. 4318embedding it into other applications.
3790 4319
4320Sensible signal handling is officially unsupported by Microsoft - libev
4321tries its best, but under most conditions, signals will simply not work.
4322
3791Not a libev limitation but worth mentioning: windows apparently doesn't 4323Not a libev limitation but worth mentioning: windows apparently doesn't
3792accept large writes: instead of resulting in a partial write, windows will 4324accept large writes: instead of resulting in a partial write, windows will
3793either accept everything or return C<ENOBUFS> if the buffer is too large, 4325either accept everything or return C<ENOBUFS> if the buffer is too large,
3794so make sure you only write small amounts into your sockets (less than a 4326so make sure you only write small amounts into your sockets (less than a
3795megabyte seems safe, but this apparently depends on the amount of memory 4327megabyte seems safe, but this apparently depends on the amount of memory
3799the abysmal performance of winsockets, using a large number of sockets 4331the abysmal performance of winsockets, using a large number of sockets
3800is not recommended (and not reasonable). If your program needs to use 4332is not recommended (and not reasonable). If your program needs to use
3801more than a hundred or so sockets, then likely it needs to use a totally 4333more than a hundred or so sockets, then likely it needs to use a totally
3802different implementation for windows, as libev offers the POSIX readiness 4334different implementation for windows, as libev offers the POSIX readiness
3803notification model, which cannot be implemented efficiently on windows 4335notification model, which cannot be implemented efficiently on windows
3804(Microsoft monopoly games). 4336(due to Microsoft monopoly games).
3805 4337
3806A typical way to use libev under windows is to embed it (see the embedding 4338A typical way to use libev under windows is to embed it (see the embedding
3807section for details) and use the following F<evwrap.h> header file instead 4339section for details) and use the following F<evwrap.h> header file instead
3808of F<ev.h>: 4340of F<ev.h>:
3809 4341
3845 4377
3846Early versions of winsocket's select only supported waiting for a maximum 4378Early versions of winsocket's select only supported waiting for a maximum
3847of C<64> handles (probably owning to the fact that all windows kernels 4379of C<64> handles (probably owning to the fact that all windows kernels
3848can only wait for C<64> things at the same time internally; Microsoft 4380can only wait for C<64> things at the same time internally; Microsoft
3849recommends spawning a chain of threads and wait for 63 handles and the 4381recommends spawning a chain of threads and wait for 63 handles and the
3850previous thread in each. Great). 4382previous thread in each. Sounds great!).
3851 4383
3852Newer versions support more handles, but you need to define C<FD_SETSIZE> 4384Newer versions support more handles, but you need to define C<FD_SETSIZE>
3853to some high number (e.g. C<2048>) before compiling the winsocket select 4385to some high number (e.g. C<2048>) before compiling the winsocket select
3854call (which might be in libev or elsewhere, for example, perl does its own 4386call (which might be in libev or elsewhere, for example, perl and many
3855select emulation on windows). 4387other interpreters do their own select emulation on windows).
3856 4388
3857Another limit is the number of file descriptors in the Microsoft runtime 4389Another limit is the number of file descriptors in the Microsoft runtime
3858libraries, which by default is C<64> (there must be a hidden I<64> fetish 4390libraries, which by default is C<64> (there must be a hidden I<64>
3859or something like this inside Microsoft). You can increase this by calling 4391fetish or something like this inside Microsoft). You can increase this
3860C<_setmaxstdio>, which can increase this limit to C<2048> (another 4392by calling C<_setmaxstdio>, which can increase this limit to C<2048>
3861arbitrary limit), but is broken in many versions of the Microsoft runtime 4393(another arbitrary limit), but is broken in many versions of the Microsoft
3862libraries.
3863
3864This might get you to about C<512> or C<2048> sockets (depending on 4394runtime libraries. This might get you to about C<512> or C<2048> sockets
3865windows version and/or the phase of the moon). To get more, you need to 4395(depending on windows version and/or the phase of the moon). To get more,
3866wrap all I/O functions and provide your own fd management, but the cost of 4396you need to wrap all I/O functions and provide your own fd management, but
3867calling select (O(n²)) will likely make this unworkable. 4397the cost of calling select (O(n²)) will likely make this unworkable.
3868 4398
3869=back 4399=back
3870 4400
3871=head2 PORTABILITY REQUIREMENTS 4401=head2 PORTABILITY REQUIREMENTS
3872 4402
3915=item C<double> must hold a time value in seconds with enough accuracy 4445=item C<double> must hold a time value in seconds with enough accuracy
3916 4446
3917The type C<double> is used to represent timestamps. It is required to 4447The type C<double> is used to represent timestamps. It is required to
3918have at least 51 bits of mantissa (and 9 bits of exponent), which is good 4448have at least 51 bits of mantissa (and 9 bits of exponent), which is good
3919enough for at least into the year 4000. This requirement is fulfilled by 4449enough for at least into the year 4000. This requirement is fulfilled by
3920implementations implementing IEEE 754 (basically all existing ones). 4450implementations implementing IEEE 754, which is basically all existing
4451ones. With IEEE 754 doubles, you get microsecond accuracy until at least
44522200.
3921 4453
3922=back 4454=back
3923 4455
3924If you know of other additional requirements drop me a note. 4456If you know of other additional requirements drop me a note.
3925 4457
3993involves iterating over all running async watchers or all signal numbers. 4525involves iterating over all running async watchers or all signal numbers.
3994 4526
3995=back 4527=back
3996 4528
3997 4529
4530=head1 GLOSSARY
4531
4532=over 4
4533
4534=item active
4535
4536A watcher is active as long as it has been started (has been attached to
4537an event loop) but not yet stopped (disassociated from the event loop).
4538
4539=item application
4540
4541In this document, an application is whatever is using libev.
4542
4543=item callback
4544
4545The address of a function that is called when some event has been
4546detected. Callbacks are being passed the event loop, the watcher that
4547received the event, and the actual event bitset.
4548
4549=item callback invocation
4550
4551The act of calling the callback associated with a watcher.
4552
4553=item event
4554
4555A change of state of some external event, such as data now being available
4556for reading on a file descriptor, time having passed or simply not having
4557any other events happening anymore.
4558
4559In libev, events are represented as single bits (such as C<EV_READ> or
4560C<EV_TIMEOUT>).
4561
4562=item event library
4563
4564A software package implementing an event model and loop.
4565
4566=item event loop
4567
4568An entity that handles and processes external events and converts them
4569into callback invocations.
4570
4571=item event model
4572
4573The model used to describe how an event loop handles and processes
4574watchers and events.
4575
4576=item pending
4577
4578A watcher is pending as soon as the corresponding event has been detected,
4579and stops being pending as soon as the watcher will be invoked or its
4580pending status is explicitly cleared by the application.
4581
4582A watcher can be pending, but not active. Stopping a watcher also clears
4583its pending status.
4584
4585=item real time
4586
4587The physical time that is observed. It is apparently strictly monotonic :)
4588
4589=item wall-clock time
4590
4591The time and date as shown on clocks. Unlike real time, it can actually
4592be wrong and jump forwards and backwards, e.g. when the you adjust your
4593clock.
4594
4595=item watcher
4596
4597A data structure that describes interest in certain events. Watchers need
4598to be started (attached to an event loop) before they can receive events.
4599
4600=item watcher invocation
4601
4602The act of calling the callback associated with a watcher.
4603
4604=back
4605
3998=head1 AUTHOR 4606=head1 AUTHOR
3999 4607
4000Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael Magnusson. 4608Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael Magnusson.
4001 4609

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines