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

Comparing libev/ev.pod (file contents):
Revision 1.354 by root, Tue Jan 11 01:40:25 2011 UTC vs.
Revision 1.370 by root, Thu Jun 2 23:42:40 2011 UTC

58 ev_timer_start (loop, &timeout_watcher); 58 ev_timer_start (loop, &timeout_watcher);
59 59
60 // now wait for events to arrive 60 // now wait for events to arrive
61 ev_run (loop, 0); 61 ev_run (loop, 0);
62 62
63 // unloop was called, so exit 63 // break was called, so exit
64 return 0; 64 return 0;
65 } 65 }
66 66
67=head1 ABOUT THIS DOCUMENT 67=head1 ABOUT THIS DOCUMENT
68 68
442 442
443This behaviour is useful when you want to do your own signal handling, or 443This behaviour is useful when you want to do your own signal handling, or
444want to handle signals only in specific threads and want to avoid libev 444want to handle signals only in specific threads and want to avoid libev
445unblocking the signals. 445unblocking the signals.
446 446
447It's also required by POSIX in a threaded program, as libev calls
448C<sigprocmask>, whose behaviour is officially unspecified.
449
447This flag's behaviour will become the default in future versions of libev. 450This flag's behaviour will become the default in future versions of libev.
448 451
449=item C<EVBACKEND_SELECT> (value 1, portable select backend) 452=item C<EVBACKEND_SELECT> (value 1, portable select backend)
450 453
451This is your standard select(2) backend. Not I<completely> standard, as 454This is your standard select(2) backend. Not I<completely> standard, as
480=item C<EVBACKEND_EPOLL> (value 4, Linux) 483=item C<EVBACKEND_EPOLL> (value 4, Linux)
481 484
482Use the linux-specific epoll(7) interface (for both pre- and post-2.6.9 485Use the linux-specific epoll(7) interface (for both pre- and post-2.6.9
483kernels). 486kernels).
484 487
485For few fds, this backend is a bit little slower than poll and select, 488For few fds, this backend is a bit little slower than poll and select, but
486but it scales phenomenally better. While poll and select usually scale 489it scales phenomenally better. While poll and select usually scale like
487like O(total_fds) where n is the total number of fds (or the highest fd), 490O(total_fds) where total_fds is the total number of fds (or the highest
488epoll scales either O(1) or O(active_fds). 491fd), epoll scales either O(1) or O(active_fds).
489 492
490The epoll mechanism deserves honorable mention as the most misdesigned 493The epoll mechanism deserves honorable mention as the most misdesigned
491of the more advanced event mechanisms: mere annoyances include silently 494of the more advanced event mechanisms: mere annoyances include silently
492dropping file descriptors, requiring a system call per change per file 495dropping file descriptors, requiring a system call per change per file
493descriptor (and unnecessary guessing of parameters), problems with dup, 496descriptor (and unnecessary guessing of parameters), problems with dup,
4960.1ms) and so on. The biggest issue is fork races, however - if a program 4990.1ms) and so on. The biggest issue is fork races, however - if a program
497forks then I<both> parent and child process have to recreate the epoll 500forks then I<both> parent and child process have to recreate the epoll
498set, which can take considerable time (one syscall per file descriptor) 501set, which can take considerable time (one syscall per file descriptor)
499and is of course hard to detect. 502and is of course hard to detect.
500 503
501Epoll is also notoriously buggy - embedding epoll fds I<should> work, but 504Epoll is also notoriously buggy - embedding epoll fds I<should> work,
502of course I<doesn't>, and epoll just loves to report events for totally 505but of course I<doesn't>, and epoll just loves to report events for
503I<different> file descriptors (even already closed ones, so one cannot 506totally I<different> file descriptors (even already closed ones, so
504even remove them from the set) than registered in the set (especially 507one cannot even remove them from the set) than registered in the set
505on SMP systems). Libev tries to counter these spurious notifications by 508(especially on SMP systems). Libev tries to counter these spurious
506employing an additional generation counter and comparing that against the 509notifications by employing an additional generation counter and comparing
507events to filter out spurious ones, recreating the set when required. Last 510that against the events to filter out spurious ones, recreating the set
511when required. Epoll also errornously rounds down timeouts, but gives you
512no way to know when and by how much, so sometimes you have to busy-wait
513because epoll returns immediately despite a nonzero timeout. And last
508not least, it also refuses to work with some file descriptors which work 514not least, it also refuses to work with some file descriptors which work
509perfectly fine with C<select> (files, many character devices...). 515perfectly fine with C<select> (files, many character devices...).
510 516
511Epoll is truly the train wreck analog among event poll mechanisms, 517Epoll is truly the train wreck among event poll mechanisms, a frankenpoll,
512a frankenpoll, cobbled together in a hurry, no thought to design or 518cobbled together in a hurry, no thought to design or interaction with
513interaction with others. 519others. Oh, the pain, will it ever stop...
514 520
515While stopping, setting and starting an I/O watcher in the same iteration 521While stopping, setting and starting an I/O watcher in the same iteration
516will result in some caching, there is still a system call per such 522will result in some caching, there is still a system call per such
517incident (because the same I<file descriptor> could point to a different 523incident (because the same I<file descriptor> could point to a different
518I<file description> now), so its best to avoid that. Also, C<dup ()>'ed 524I<file description> now), so its best to avoid that. Also, C<dup ()>'ed
822This is useful if you are waiting for some external event in conjunction 828This is useful if you are waiting for some external event in conjunction
823with something not expressible using other libev watchers (i.e. "roll your 829with something not expressible using other libev watchers (i.e. "roll your
824own C<ev_run>"). However, a pair of C<ev_prepare>/C<ev_check> watchers is 830own C<ev_run>"). However, a pair of C<ev_prepare>/C<ev_check> watchers is
825usually a better approach for this kind of thing. 831usually a better approach for this kind of thing.
826 832
827Here are the gory details of what C<ev_run> does: 833Here are the gory details of what C<ev_run> does (this is for your
834understanding, not a guarantee that things will work exactly like this in
835future versions):
828 836
829 - Increment loop depth. 837 - Increment loop depth.
830 - Reset the ev_break status. 838 - Reset the ev_break status.
831 - Before the first iteration, call any pending watchers. 839 - Before the first iteration, call any pending watchers.
832 LOOP: 840 LOOP:
865anymore. 873anymore.
866 874
867 ... queue jobs here, make sure they register event watchers as long 875 ... queue jobs here, make sure they register event watchers as long
868 ... as they still have work to do (even an idle watcher will do..) 876 ... as they still have work to do (even an idle watcher will do..)
869 ev_run (my_loop, 0); 877 ev_run (my_loop, 0);
870 ... jobs done or somebody called unloop. yeah! 878 ... jobs done or somebody called break. yeah!
871 879
872=item ev_break (loop, how) 880=item ev_break (loop, how)
873 881
874Can be used to make a call to C<ev_run> return early (but only after it 882Can be used to make a call to C<ev_run> return early (but only after it
875has processed all outstanding events). The C<how> argument must be either 883has processed all outstanding events). The C<how> argument must be either
1357See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related 1365See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related
1358functions that do not need a watcher. 1366functions that do not need a watcher.
1359 1367
1360=back 1368=back
1361 1369
1362=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER 1370See also the L<ASSOCIATING CUSTOM DATA WITH A WATCHER> and L<BUILDING YOUR
1363 1371OWN COMPOSITE WATCHERS> idioms.
1364Each watcher has, by default, a member C<void *data> that you can change
1365and read at any time: libev will completely ignore it. This can be used
1366to associate arbitrary data with your watcher. If you need more data and
1367don't want to allocate memory and store a pointer to it in that data
1368member, you can also "subclass" the watcher type and provide your own
1369data:
1370
1371 struct my_io
1372 {
1373 ev_io io;
1374 int otherfd;
1375 void *somedata;
1376 struct whatever *mostinteresting;
1377 };
1378
1379 ...
1380 struct my_io w;
1381 ev_io_init (&w.io, my_cb, fd, EV_READ);
1382
1383And since your callback will be called with a pointer to the watcher, you
1384can cast it back to your own type:
1385
1386 static void my_cb (struct ev_loop *loop, ev_io *w_, int revents)
1387 {
1388 struct my_io *w = (struct my_io *)w_;
1389 ...
1390 }
1391
1392More interesting and less C-conformant ways of casting your callback type
1393instead have been omitted.
1394
1395Another common scenario is to use some data structure with multiple
1396embedded watchers:
1397
1398 struct my_biggy
1399 {
1400 int some_data;
1401 ev_timer t1;
1402 ev_timer t2;
1403 }
1404
1405In this case getting the pointer to C<my_biggy> is a bit more
1406complicated: Either you store the address of your C<my_biggy> struct
1407in the C<data> member of the watcher (for woozies), or you need to use
1408some pointer arithmetic using C<offsetof> inside your watchers (for real
1409programmers):
1410
1411 #include <stddef.h>
1412
1413 static void
1414 t1_cb (EV_P_ ev_timer *w, int revents)
1415 {
1416 struct my_biggy big = (struct my_biggy *)
1417 (((char *)w) - offsetof (struct my_biggy, t1));
1418 }
1419
1420 static void
1421 t2_cb (EV_P_ ev_timer *w, int revents)
1422 {
1423 struct my_biggy big = (struct my_biggy *)
1424 (((char *)w) - offsetof (struct my_biggy, t2));
1425 }
1426 1372
1427=head2 WATCHER STATES 1373=head2 WATCHER STATES
1428 1374
1429There are various watcher states mentioned throughout this manual - 1375There are various watcher states mentioned throughout this manual -
1430active, pending and so on. In this section these states and the rules to 1376active, pending and so on. In this section these states and the rules to
1437 1383
1438Before a watcher can be registered with the event looop it has to be 1384Before a watcher can be registered with the event looop it has to be
1439initialised. This can be done with a call to C<ev_TYPE_init>, or calls to 1385initialised. This can be done with a call to C<ev_TYPE_init>, or calls to
1440C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function. 1386C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function.
1441 1387
1442In this state it is simply some block of memory that is suitable for use 1388In this state it is simply some block of memory that is suitable for
1443in an event loop. It can be moved around, freed, reused etc. at will. 1389use in an event loop. It can be moved around, freed, reused etc. at
1390will - as long as you either keep the memory contents intact, or call
1391C<ev_TYPE_init> again.
1444 1392
1445=item started/running/active 1393=item started/running/active
1446 1394
1447Once a watcher has been started with a call to C<ev_TYPE_start> it becomes 1395Once a watcher has been started with a call to C<ev_TYPE_start> it becomes
1448property of the event loop, and is actively waiting for events. While in 1396property of the event loop, and is actively waiting for events. While in
1476latter will clear any pending state the watcher might be in, regardless 1424latter will clear any pending state the watcher might be in, regardless
1477of whether it was active or not, so stopping a watcher explicitly before 1425of whether it was active or not, so stopping a watcher explicitly before
1478freeing it is often a good idea. 1426freeing it is often a good idea.
1479 1427
1480While stopped (and not pending) the watcher is essentially in the 1428While stopped (and not pending) the watcher is essentially in the
1481initialised state, that is it can be reused, moved, modified in any way 1429initialised state, that is, it can be reused, moved, modified in any way
1482you wish. 1430you wish (but when you trash the memory block, you need to C<ev_TYPE_init>
1431it again).
1483 1432
1484=back 1433=back
1485 1434
1486=head2 WATCHER PRIORITY MODELS 1435=head2 WATCHER PRIORITY MODELS
1487 1436
1680always get a readiness notification instantly, and your read (or possibly 1629always get a readiness notification instantly, and your read (or possibly
1681write) will still block on the disk I/O. 1630write) will still block on the disk I/O.
1682 1631
1683Another way to view it is that in the case of sockets, pipes, character 1632Another way to view it is that in the case of sockets, pipes, character
1684devices and so on, there is another party (the sender) that delivers data 1633devices and so on, there is another party (the sender) that delivers data
1685on it's own, but in the case of files, there is no such thing: the disk 1634on its own, but in the case of files, there is no such thing: the disk
1686will not send data on it's own, simply because it doesn't know what you 1635will not send data on its own, simply because it doesn't know what you
1687wish to read - you would first have to request some data. 1636wish to read - you would first have to request some data.
1688 1637
1689Since files are typically not-so-well supported by advanced notification 1638Since files are typically not-so-well supported by advanced notification
1690mechanism, libev tries hard to emulate POSIX behaviour with respect 1639mechanism, libev tries hard to emulate POSIX behaviour with respect
1691to files, even though you should not use it. The reason for this is 1640to files, even though you should not use it. The reason for this is
2207 2156
2208Another way to think about it (for the mathematically inclined) is that 2157Another way to think about it (for the mathematically inclined) is that
2209C<ev_periodic> will try to run the callback in this mode at the next possible 2158C<ev_periodic> will try to run the callback in this mode at the next possible
2210time where C<time = offset (mod interval)>, regardless of any time jumps. 2159time where C<time = offset (mod interval)>, regardless of any time jumps.
2211 2160
2212For numerical stability it is preferable that the C<offset> value is near 2161The C<interval> I<MUST> be positive, and for numerical stability, the
2213C<ev_now ()> (the current time), but there is no range requirement for 2162interval value should be higher than C<1/8192> (which is around 100
2214this value, and in fact is often specified as zero. 2163microseconds) and C<offset> should be higher than C<0> and should have
2164at most a similar magnitude as the current time (say, within a factor of
2165ten). Typical values for offset are, in fact, C<0> or something between
2166C<0> and C<interval>, which is also the recommended range.
2215 2167
2216Note also that there is an upper limit to how often a timer can fire (CPU 2168Note also that there is an upper limit to how often a timer can fire (CPU
2217speed for example), so if C<interval> is very small then timing stability 2169speed for example), so if C<interval> is very small then timing stability
2218will of course deteriorate. Libev itself tries to be exact to be about one 2170will of course deteriorate. Libev itself tries to be exact to be about one
2219millisecond (if the OS supports it and the machine is fast enough). 2171millisecond (if the OS supports it and the machine is fast enough).
2362=head3 The special problem of inheritance over fork/execve/pthread_create 2314=head3 The special problem of inheritance over fork/execve/pthread_create
2363 2315
2364Both the signal mask (C<sigprocmask>) and the signal disposition 2316Both the signal mask (C<sigprocmask>) and the signal disposition
2365(C<sigaction>) are unspecified after starting a signal watcher (and after 2317(C<sigaction>) are unspecified after starting a signal watcher (and after
2366stopping it again), that is, libev might or might not block the signal, 2318stopping it again), that is, libev might or might not block the signal,
2367and might or might not set or restore the installed signal handler. 2319and might or might not set or restore the installed signal handler (but
2320see C<EVFLAG_NOSIGMASK>).
2368 2321
2369While this does not matter for the signal disposition (libev never 2322While this does not matter for the signal disposition (libev never
2370sets signals to C<SIG_IGN>, so handlers will be reset to C<SIG_DFL> on 2323sets signals to C<SIG_IGN>, so handlers will be reset to C<SIG_DFL> on
2371C<execve>), this matters for the signal mask: many programs do not expect 2324C<execve>), this matters for the signal mask: many programs do not expect
2372certain signals to be blocked. 2325certain signals to be blocked.
3243 atexit (program_exits); 3196 atexit (program_exits);
3244 3197
3245 3198
3246=head2 C<ev_async> - how to wake up an event loop 3199=head2 C<ev_async> - how to wake up an event loop
3247 3200
3248In general, you cannot use an C<ev_run> from multiple threads or other 3201In general, you cannot use an C<ev_loop> from multiple threads or other
3249asynchronous sources such as signal handlers (as opposed to multiple event 3202asynchronous sources such as signal handlers (as opposed to multiple event
3250loops - those are of course safe to use in different threads). 3203loops - those are of course safe to use in different threads).
3251 3204
3252Sometimes, however, you need to wake up an event loop you do not control, 3205Sometimes, however, you need to wake up an event loop you do not control,
3253for example because it belongs to another thread. This is what C<ev_async> 3206for example because it belongs to another thread. This is what C<ev_async>
3363trust me. 3316trust me.
3364 3317
3365=item ev_async_send (loop, ev_async *) 3318=item ev_async_send (loop, ev_async *)
3366 3319
3367Sends/signals/activates the given C<ev_async> watcher, that is, feeds 3320Sends/signals/activates the given C<ev_async> watcher, that is, feeds
3368an C<EV_ASYNC> event on the watcher into the event loop. Unlike 3321an C<EV_ASYNC> event on the watcher into the event loop, and instantly
3322returns.
3323
3369C<ev_feed_event>, this call is safe to do from other threads, signal or 3324Unlike C<ev_feed_event>, this call is safe to do from other threads,
3370similar contexts (see the discussion of C<EV_ATOMIC_T> in the embedding 3325signal or similar contexts (see the discussion of C<EV_ATOMIC_T> in the
3371section below on what exactly this means). 3326embedding section below on what exactly this means).
3372 3327
3373Note that, as with other watchers in libev, multiple events might get 3328Note that, as with other watchers in libev, multiple events might get
3374compressed into a single callback invocation (another way to look at this 3329compressed into a single callback invocation (another way to look at this
3375is that C<ev_async> watchers are level-triggered, set on C<ev_async_send>, 3330is that C<ev_async> watchers are level-triggered, set on C<ev_async_send>,
3376reset when the event loop detects that). 3331reset when the event loop detects that).
3456 3411
3457This section explains some common idioms that are not immediately 3412This section explains some common idioms that are not immediately
3458obvious. Note that examples are sprinkled over the whole manual, and this 3413obvious. Note that examples are sprinkled over the whole manual, and this
3459section only contains stuff that wouldn't fit anywhere else. 3414section only contains stuff that wouldn't fit anywhere else.
3460 3415
3461=over 4 3416=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER
3462 3417
3463=item Model/nested event loop invocations and exit conditions. 3418Each watcher has, by default, a C<void *data> member that you can read
3419or modify at any time: libev will completely ignore it. This can be used
3420to associate arbitrary data with your watcher. If you need more data and
3421don't want to allocate memory separately and store a pointer to it in that
3422data member, you can also "subclass" the watcher type and provide your own
3423data:
3424
3425 struct my_io
3426 {
3427 ev_io io;
3428 int otherfd;
3429 void *somedata;
3430 struct whatever *mostinteresting;
3431 };
3432
3433 ...
3434 struct my_io w;
3435 ev_io_init (&w.io, my_cb, fd, EV_READ);
3436
3437And since your callback will be called with a pointer to the watcher, you
3438can cast it back to your own type:
3439
3440 static void my_cb (struct ev_loop *loop, ev_io *w_, int revents)
3441 {
3442 struct my_io *w = (struct my_io *)w_;
3443 ...
3444 }
3445
3446More interesting and less C-conformant ways of casting your callback
3447function type instead have been omitted.
3448
3449=head2 BUILDING YOUR OWN COMPOSITE WATCHERS
3450
3451Another common scenario is to use some data structure with multiple
3452embedded watchers, in effect creating your own watcher that combines
3453multiple libev event sources into one "super-watcher":
3454
3455 struct my_biggy
3456 {
3457 int some_data;
3458 ev_timer t1;
3459 ev_timer t2;
3460 }
3461
3462In this case getting the pointer to C<my_biggy> is a bit more
3463complicated: Either you store the address of your C<my_biggy> struct in
3464the C<data> member of the watcher (for woozies or C++ coders), or you need
3465to use some pointer arithmetic using C<offsetof> inside your watchers (for
3466real programmers):
3467
3468 #include <stddef.h>
3469
3470 static void
3471 t1_cb (EV_P_ ev_timer *w, int revents)
3472 {
3473 struct my_biggy big = (struct my_biggy *)
3474 (((char *)w) - offsetof (struct my_biggy, t1));
3475 }
3476
3477 static void
3478 t2_cb (EV_P_ ev_timer *w, int revents)
3479 {
3480 struct my_biggy big = (struct my_biggy *)
3481 (((char *)w) - offsetof (struct my_biggy, t2));
3482 }
3483
3484=head2 MODEL/NESTED EVENT LOOP INVOCATIONS AND EXIT CONDITIONS
3464 3485
3465Often (especially in GUI toolkits) there are places where you have 3486Often (especially in GUI toolkits) there are places where you have
3466I<modal> interaction, which is most easily implemented by recursively 3487I<modal> interaction, which is most easily implemented by recursively
3467invoking C<ev_run>. 3488invoking C<ev_run>.
3468 3489
3497 exit_main_loop = 1; 3518 exit_main_loop = 1;
3498 3519
3499 // exit both 3520 // exit both
3500 exit_main_loop = exit_nested_loop = 1; 3521 exit_main_loop = exit_nested_loop = 1;
3501 3522
3502=item Thread locking example 3523=head2 THREAD LOCKING EXAMPLE
3503 3524
3504Here is a fictitious example of how to run an event loop in a different 3525Here is a fictitious example of how to run an event loop in a different
3505thread than where callbacks are being invoked and watchers are 3526thread from where callbacks are being invoked and watchers are
3506created/added/removed. 3527created/added/removed.
3507 3528
3508For a real-world example, see the C<EV::Loop::Async> perl module, 3529For a real-world example, see the C<EV::Loop::Async> perl module,
3509which uses exactly this technique (which is suited for many high-level 3530which uses exactly this technique (which is suited for many high-level
3510languages). 3531languages).
3536 // now associate this with the loop 3557 // now associate this with the loop
3537 ev_set_userdata (EV_A_ u); 3558 ev_set_userdata (EV_A_ u);
3538 ev_set_invoke_pending_cb (EV_A_ l_invoke); 3559 ev_set_invoke_pending_cb (EV_A_ l_invoke);
3539 ev_set_loop_release_cb (EV_A_ l_release, l_acquire); 3560 ev_set_loop_release_cb (EV_A_ l_release, l_acquire);
3540 3561
3541 // then create the thread running ev_loop 3562 // then create the thread running ev_run
3542 pthread_create (&u->tid, 0, l_run, EV_A); 3563 pthread_create (&u->tid, 0, l_run, EV_A);
3543 } 3564 }
3544 3565
3545The callback for the C<ev_async> watcher does nothing: the watcher is used 3566The callback for the C<ev_async> watcher does nothing: the watcher is used
3546solely to wake up the event loop so it takes notice of any new watchers 3567solely to wake up the event loop so it takes notice of any new watchers
3635Note that sending the C<ev_async> watcher is required because otherwise 3656Note that sending the C<ev_async> watcher is required because otherwise
3636an event loop currently blocking in the kernel will have no knowledge 3657an event loop currently blocking in the kernel will have no knowledge
3637about the newly added timer. By waking up the loop it will pick up any new 3658about the newly added timer. By waking up the loop it will pick up any new
3638watchers in the next event loop iteration. 3659watchers in the next event loop iteration.
3639 3660
3640=back 3661=head2 THREADS, COROUTINES, CONTINUATIONS, QUEUES... INSTEAD OF CALLBACKS
3662
3663While the overhead of a callback that e.g. schedules a thread is small, it
3664is still an overhead. If you embed libev, and your main usage is with some
3665kind of threads or coroutines, you might want to customise libev so that
3666doesn't need callbacks anymore.
3667
3668Imagine you have coroutines that you can switch to using a function
3669C<switch_to (coro)>, that libev runs in a coroutine called C<libev_coro>
3670and that due to some magic, the currently active coroutine is stored in a
3671global called C<current_coro>. Then you can build your own "wait for libev
3672event" primitive by changing C<EV_CB_DECLARE> and C<EV_CB_INVOKE> (note
3673the differing C<;> conventions):
3674
3675 #define EV_CB_DECLARE(type) struct my_coro *cb;
3676 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb)
3677
3678That means instead of having a C callback function, you store the
3679coroutine to switch to in each watcher, and instead of having libev call
3680your callback, you instead have it switch to that coroutine.
3681
3682A coroutine might now wait for an event with a function called
3683C<wait_for_event>. (the watcher needs to be started, as always, but it doesn't
3684matter when, or whether the watcher is active or not when this function is
3685called):
3686
3687 void
3688 wait_for_event (ev_watcher *w)
3689 {
3690 ev_cb_set (w) = current_coro;
3691 switch_to (libev_coro);
3692 }
3693
3694That basically suspends the coroutine inside C<wait_for_event> and
3695continues the libev coroutine, which, when appropriate, switches back to
3696this or any other coroutine. I am sure if you sue this your own :)
3697
3698You can do similar tricks if you have, say, threads with an event queue -
3699instead of storing a coroutine, you store the queue object and instead of
3700switching to a coroutine, you push the watcher onto the queue and notify
3701any waiters.
3702
3703To embed libev, see L<EMBEDDING>, but in short, it's easiest to create two
3704files, F<my_ev.h> and F<my_ev.c> that include the respective libev files:
3705
3706 // my_ev.h
3707 #define EV_CB_DECLARE(type) struct my_coro *cb;
3708 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb);
3709 #include "../libev/ev.h"
3710
3711 // my_ev.c
3712 #define EV_H "my_ev.h"
3713 #include "../libev/ev.c"
3714
3715And then use F<my_ev.h> when you would normally use F<ev.h>, and compile
3716F<my_ev.c> into your project. When properly specifying include paths, you
3717can even use F<ev.h> as header file name directly.
3641 3718
3642 3719
3643=head1 LIBEVENT EMULATION 3720=head1 LIBEVENT EMULATION
3644 3721
3645Libev offers a compatibility emulation layer for libevent. It cannot 3722Libev offers a compatibility emulation layer for libevent. It cannot
4135F<event.h> that are not directly supported by the libev core alone. 4212F<event.h> that are not directly supported by the libev core alone.
4136 4213
4137In standalone mode, libev will still try to automatically deduce the 4214In standalone mode, libev will still try to automatically deduce the
4138configuration, but has to be more conservative. 4215configuration, but has to be more conservative.
4139 4216
4217=item EV_USE_FLOOR
4218
4219If defined to be C<1>, libev will use the C<floor ()> function for its
4220periodic reschedule calculations, otherwise libev will fall back on a
4221portable (slower) implementation. If you enable this, you usually have to
4222link against libm or something equivalent. Enabling this when the C<floor>
4223function is not available will fail, so the safe default is to not enable
4224this.
4225
4140=item EV_USE_MONOTONIC 4226=item EV_USE_MONOTONIC
4141 4227
4142If defined to be C<1>, libev will try to detect the availability of the 4228If defined to be C<1>, libev will try to detect the availability of the
4143monotonic clock option at both compile time and runtime. Otherwise no 4229monotonic clock option at both compile time and runtime. Otherwise no
4144use of the monotonic clock option will be attempted. If you enable this, 4230use of the monotonic clock option will be attempted. If you enable this,
4575And a F<ev_cpp.C> implementation file that contains libev proper and is compiled: 4661And a F<ev_cpp.C> implementation file that contains libev proper and is compiled:
4576 4662
4577 #include "ev_cpp.h" 4663 #include "ev_cpp.h"
4578 #include "ev.c" 4664 #include "ev.c"
4579 4665
4580=head1 INTERACTION WITH OTHER PROGRAMS OR LIBRARIES 4666=head1 INTERACTION WITH OTHER PROGRAMS, LIBRARIES OR THE ENVIRONMENT
4581 4667
4582=head2 THREADS AND COROUTINES 4668=head2 THREADS AND COROUTINES
4583 4669
4584=head3 THREADS 4670=head3 THREADS
4585 4671
4636default loop and triggering an C<ev_async> watcher from the default loop 4722default loop and triggering an C<ev_async> watcher from the default loop
4637watcher callback into the event loop interested in the signal. 4723watcher callback into the event loop interested in the signal.
4638 4724
4639=back 4725=back
4640 4726
4641See also L<Thread locking example>. 4727See also L<THREAD LOCKING EXAMPLE>.
4642 4728
4643=head3 COROUTINES 4729=head3 COROUTINES
4644 4730
4645Libev is very accommodating to coroutines ("cooperative threads"): 4731Libev is very accommodating to coroutines ("cooperative threads"):
4646libev fully supports nesting calls to its functions from different 4732libev fully supports nesting calls to its functions from different
5155The physical time that is observed. It is apparently strictly monotonic :) 5241The physical time that is observed. It is apparently strictly monotonic :)
5156 5242
5157=item wall-clock time 5243=item wall-clock time
5158 5244
5159The time and date as shown on clocks. Unlike real time, it can actually 5245The time and date as shown on clocks. Unlike real time, it can actually
5160be wrong and jump forwards and backwards, e.g. when the you adjust your 5246be wrong and jump forwards and backwards, e.g. when you adjust your
5161clock. 5247clock.
5162 5248
5163=item watcher 5249=item watcher
5164 5250
5165A data structure that describes interest in certain events. Watchers need 5251A data structure that describes interest in certain events. Watchers need
5168=back 5254=back
5169 5255
5170=head1 AUTHOR 5256=head1 AUTHOR
5171 5257
5172Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael 5258Marc Lehmann <libev@schmorp.de>, with repeated corrections by Mikael
5173Magnusson and Emanuele Giaquinta. 5259Magnusson and Emanuele Giaquinta, and minor corrections by many others.
5174 5260

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines