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

Comparing libev/ev.pod (file contents):
Revision 1.356 by root, Tue Jan 11 01:42:47 2011 UTC vs.
Revision 1.361 by root, Sun Jan 23 18:53:06 2011 UTC

441when you want to receive them. 441when you want to receive them.
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
447It's also required by POSIX in a threaded program, as libev calls
448C<sigprocmask>, whose behaviour is officially unspecified.
446 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
1357See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related 1360See also C<ev_feed_fd_event> and C<ev_feed_signal_event> for related
1358functions that do not need a watcher. 1361functions that do not need a watcher.
1359 1362
1360=back 1363=back
1361 1364
1362=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER 1365See also the L<ASSOCIATING CUSTOM DATA WITH A WATCHER> and L<BUILDING YOUR
1363 1366OWN 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 1367
1427=head2 WATCHER STATES 1368=head2 WATCHER STATES
1428 1369
1429There are various watcher states mentioned throughout this manual - 1370There are various watcher states mentioned throughout this manual -
1430active, pending and so on. In this section these states and the rules to 1371active, pending and so on. In this section these states and the rules to
1437 1378
1438Before a watcher can be registered with the event looop it has to be 1379Before 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 1380initialised. 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. 1381C<ev_init> followed by the watcher-specific C<ev_TYPE_set> function.
1441 1382
1442In this state it is simply some block of memory that is suitable for use 1383In 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. 1384use in an event loop. It can be moved around, freed, reused etc. at
1385will - as long as you either keep the memory contents intact, or call
1386C<ev_TYPE_init> again.
1444 1387
1445=item started/running/active 1388=item started/running/active
1446 1389
1447Once a watcher has been started with a call to C<ev_TYPE_start> it becomes 1390Once 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 1391property of the event loop, and is actively waiting for events. While in
1476latter will clear any pending state the watcher might be in, regardless 1419latter will clear any pending state the watcher might be in, regardless
1477of whether it was active or not, so stopping a watcher explicitly before 1420of whether it was active or not, so stopping a watcher explicitly before
1478freeing it is often a good idea. 1421freeing it is often a good idea.
1479 1422
1480While stopped (and not pending) the watcher is essentially in the 1423While stopped (and not pending) the watcher is essentially in the
1481initialised state, that is it can be reused, moved, modified in any way 1424initialised state, that is, it can be reused, moved, modified in any way
1482you wish. 1425you wish (but when you trash the memory block, you need to C<ev_TYPE_init>
1426it again).
1483 1427
1484=back 1428=back
1485 1429
1486=head2 WATCHER PRIORITY MODELS 1430=head2 WATCHER PRIORITY MODELS
1487 1431
1680always get a readiness notification instantly, and your read (or possibly 1624always get a readiness notification instantly, and your read (or possibly
1681write) will still block on the disk I/O. 1625write) will still block on the disk I/O.
1682 1626
1683Another way to view it is that in the case of sockets, pipes, character 1627Another 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 1628devices 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 1629on 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 1630will 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. 1631wish to read - you would first have to request some data.
1688 1632
1689Since files are typically not-so-well supported by advanced notification 1633Since files are typically not-so-well supported by advanced notification
1690mechanism, libev tries hard to emulate POSIX behaviour with respect 1634mechanism, libev tries hard to emulate POSIX behaviour with respect
1691to files, even though you should not use it. The reason for this is 1635to files, even though you should not use it. The reason for this is
2362=head3 The special problem of inheritance over fork/execve/pthread_create 2306=head3 The special problem of inheritance over fork/execve/pthread_create
2363 2307
2364Both the signal mask (C<sigprocmask>) and the signal disposition 2308Both the signal mask (C<sigprocmask>) and the signal disposition
2365(C<sigaction>) are unspecified after starting a signal watcher (and after 2309(C<sigaction>) are unspecified after starting a signal watcher (and after
2366stopping it again), that is, libev might or might not block the signal, 2310stopping it again), that is, libev might or might not block the signal,
2367and might or might not set or restore the installed signal handler. 2311and might or might not set or restore the installed signal handler (but
2312see C<EVFLAG_NOSIGMASK>).
2368 2313
2369While this does not matter for the signal disposition (libev never 2314While 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 2315sets 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 2316C<execve>), this matters for the signal mask: many programs do not expect
2372certain signals to be blocked. 2317certain signals to be blocked.
3456 3401
3457This section explains some common idioms that are not immediately 3402This section explains some common idioms that are not immediately
3458obvious. Note that examples are sprinkled over the whole manual, and this 3403obvious. Note that examples are sprinkled over the whole manual, and this
3459section only contains stuff that wouldn't fit anywhere else. 3404section only contains stuff that wouldn't fit anywhere else.
3460 3405
3406=head2 ASSOCIATING CUSTOM DATA WITH A WATCHER
3407
3408Each watcher has, by default, a C<void *data> member that you can read
3409or modify at any time: libev will completely ignore it. This can be used
3410to associate arbitrary data with your watcher. If you need more data and
3411don't want to allocate memory separately and store a pointer to it in that
3412data member, you can also "subclass" the watcher type and provide your own
3413data:
3414
3415 struct my_io
3416 {
3417 ev_io io;
3418 int otherfd;
3419 void *somedata;
3420 struct whatever *mostinteresting;
3421 };
3422
3423 ...
3424 struct my_io w;
3425 ev_io_init (&w.io, my_cb, fd, EV_READ);
3426
3427And since your callback will be called with a pointer to the watcher, you
3428can cast it back to your own type:
3429
3430 static void my_cb (struct ev_loop *loop, ev_io *w_, int revents)
3431 {
3432 struct my_io *w = (struct my_io *)w_;
3433 ...
3434 }
3435
3436More interesting and less C-conformant ways of casting your callback
3437function type instead have been omitted.
3438
3439=head2 BUILDING YOUR OWN COMPOSITE WATCHERS
3440
3441Another common scenario is to use some data structure with multiple
3442embedded watchers, in effect creating your own watcher that combines
3443multiple libev event sources into one "super-watcher":
3444
3445 struct my_biggy
3446 {
3447 int some_data;
3448 ev_timer t1;
3449 ev_timer t2;
3450 }
3451
3452In this case getting the pointer to C<my_biggy> is a bit more
3453complicated: Either you store the address of your C<my_biggy> struct in
3454the C<data> member of the watcher (for woozies or C++ coders), or you need
3455to use some pointer arithmetic using C<offsetof> inside your watchers (for
3456real programmers):
3457
3458 #include <stddef.h>
3459
3460 static void
3461 t1_cb (EV_P_ ev_timer *w, int revents)
3462 {
3463 struct my_biggy big = (struct my_biggy *)
3464 (((char *)w) - offsetof (struct my_biggy, t1));
3465 }
3466
3467 static void
3468 t2_cb (EV_P_ ev_timer *w, int revents)
3469 {
3470 struct my_biggy big = (struct my_biggy *)
3471 (((char *)w) - offsetof (struct my_biggy, t2));
3472 }
3473
3461=head2 MODEL/NESTED EVENT LOOP INVOCATIONS AND EXIT CONDITIONS 3474=head2 MODEL/NESTED EVENT LOOP INVOCATIONS AND EXIT CONDITIONS
3462 3475
3463Often (especially in GUI toolkits) there are places where you have 3476Often (especially in GUI toolkits) there are places where you have
3464I<modal> interaction, which is most easily implemented by recursively 3477I<modal> interaction, which is most easily implemented by recursively
3465invoking C<ev_run>. 3478invoking C<ev_run>.
3498 exit_main_loop = exit_nested_loop = 1; 3511 exit_main_loop = exit_nested_loop = 1;
3499 3512
3500=head2 THREAD LOCKING EXAMPLE 3513=head2 THREAD LOCKING EXAMPLE
3501 3514
3502Here is a fictitious example of how to run an event loop in a different 3515Here is a fictitious example of how to run an event loop in a different
3503thread than where callbacks are being invoked and watchers are 3516thread from where callbacks are being invoked and watchers are
3504created/added/removed. 3517created/added/removed.
3505 3518
3506For a real-world example, see the C<EV::Loop::Async> perl module, 3519For a real-world example, see the C<EV::Loop::Async> perl module,
3507which uses exactly this technique (which is suited for many high-level 3520which uses exactly this technique (which is suited for many high-level
3508languages). 3521languages).
3632 3645
3633Note that sending the C<ev_async> watcher is required because otherwise 3646Note that sending the C<ev_async> watcher is required because otherwise
3634an event loop currently blocking in the kernel will have no knowledge 3647an event loop currently blocking in the kernel will have no knowledge
3635about the newly added timer. By waking up the loop it will pick up any new 3648about the newly added timer. By waking up the loop it will pick up any new
3636watchers in the next event loop iteration. 3649watchers in the next event loop iteration.
3650
3651=head2 THREADS, COROUTINES, CONTINUATIONS, QUEUES... INSTEAD OF CALLBACKS
3652
3653While the overhead of a callback that e.g. schedules a thread is small, it
3654is still an overhead. If you embed libev, and your main usage is with some
3655kind of threads or coroutines, you might want to customise libev so that
3656doesn't need callbacks anymore.
3657
3658Imagine you have coroutines that you can switch to using a function
3659C<switch_to (coro)>, that libev runs in a coroutine called C<libev_coro>
3660and that due to some magic, the currently active coroutine is stored in a
3661global called C<current_coro>. Then you can build your own "wait for libev
3662event" primitive by changing C<EV_CB_DECLARE> and C<EV_CB_INVOKE> (note
3663the differing C<;> conventions):
3664
3665 #define EV_CB_DECLARE(type) struct my_coro *cb;
3666 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb)
3667
3668That means instead of having a C callback function, you store the
3669coroutine to switch to in each watcher, and instead of having libev call
3670your callback, you instead have it switch to that coroutine.
3671
3672A coroutine might now wait for an event with a function called
3673C<wait_for_event>. (the watcher needs to be started, as always, but it doesn't
3674matter when, or whether the watcher is active or not when this function is
3675called):
3676
3677 void
3678 wait_for_event (ev_watcher *w)
3679 {
3680 ev_cb_set (w) = current_coro;
3681 switch_to (libev_coro);
3682 }
3683
3684That basically suspends the coroutine inside C<wait_for_event> and
3685continues the libev coroutine, which, when appropriate, switches back to
3686this or any other coroutine. I am sure if you sue this your own :)
3687
3688You can do similar tricks if you have, say, threads with an event queue -
3689instead of storing a coroutine, you store the queue object and instead of
3690switching to a coroutine, you push the watcher onto the queue and notify
3691any waiters.
3692
3693To embed libev, see L<EMBEDDING>, but in short, it's easiest to create two
3694files, F<my_ev.h> and F<my_ev.c> that include the respective libev files:
3695
3696 // my_ev.h
3697 #define EV_CB_DECLARE(type) struct my_coro *cb;
3698 #define EV_CB_INVOKE(watcher) switch_to ((watcher)->cb);
3699 #include "../libev/ev.h"
3700
3701 // my_ev.c
3702 #define EV_H "my_ev.h"
3703 #include "../libev/ev.c"
3704
3705And then use F<my_ev.h> when you would normally use F<ev.h>, and compile
3706F<my_ev.c> into your project. When properly specifying include paths, you
3707can even use F<ev.h> as header file name directly.
3637 3708
3638 3709
3639=head1 LIBEVENT EMULATION 3710=head1 LIBEVENT EMULATION
3640 3711
3641Libev offers a compatibility emulation layer for libevent. It cannot 3712Libev offers a compatibility emulation layer for libevent. It cannot

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines