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

Comparing libev/ev.pod (file contents):
Revision 1.459 by root, Wed Jan 22 01:50:42 2020 UTC vs.
Revision 1.469 by root, Sat Jun 3 08:53:03 2023 UTC

675and is not embeddable, which would limit the usefulness of this backend 675and is not embeddable, which would limit the usefulness of this backend
676immensely. 676immensely.
677 677
678=item C<EVBACKEND_PORT> (value 32, Solaris 10) 678=item C<EVBACKEND_PORT> (value 32, Solaris 10)
679 679
680This uses the Solaris 10 event port mechanism. As with everything on Solaris, 680This uses the Solaris 10 event port mechanism. As with everything on
681it's really slow, but it still scales very well (O(active_fds)). 681Solaris, it's really slow, but it still scales very well (O(active_fds)).
682 682
683While this backend scales well, it requires one system call per active 683While this backend scales well, it requires one system call per active
684file descriptor per loop iteration. For small and medium numbers of file 684file descriptor per loop iteration. For small and medium numbers of file
685descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend 685descriptors a "slow" C<EVBACKEND_SELECT> or C<EVBACKEND_POLL> backend
686might perform better. 686might perform better.
959 - Queue all expired timers. 959 - Queue all expired timers.
960 - Queue all expired periodics. 960 - Queue all expired periodics.
961 - Queue all idle watchers with priority higher than that of pending events. 961 - Queue all idle watchers with priority higher than that of pending events.
962 - Queue all check watchers. 962 - Queue all check watchers.
963 - Call all queued watchers in reverse order (i.e. check watchers first). 963 - Call all queued watchers in reverse order (i.e. check watchers first).
964 Signals and child watchers are implemented as I/O watchers, and will 964 Signals, async and child watchers are implemented as I/O watchers, and
965 be handled here by queueing them when their watcher gets executed. 965 will be handled here by queueing them when their watcher gets executed.
966 - If ev_break has been called, or EVRUN_ONCE or EVRUN_NOWAIT 966 - If ev_break has been called, or EVRUN_ONCE or EVRUN_NOWAIT
967 were used, or there are no active watchers, goto FINISH, otherwise 967 were used, or there are no active watchers, goto FINISH, otherwise
968 continue with step LOOP. 968 continue with step LOOP.
969 FINISH: 969 FINISH:
970 - Reset the ev_break status iff it was EVBREAK_ONE. 970 - Reset the ev_break status iff it was EVBREAK_ONE.
1218with a watcher-specific start function (C<< ev_TYPE_start (loop, watcher 1218with a watcher-specific start function (C<< ev_TYPE_start (loop, watcher
1219*) >>), and you can stop watching for events at any time by calling the 1219*) >>), and you can stop watching for events at any time by calling the
1220corresponding stop function (C<< ev_TYPE_stop (loop, watcher *) >>. 1220corresponding stop function (C<< ev_TYPE_stop (loop, watcher *) >>.
1221 1221
1222As long as your watcher is active (has been started but not stopped) you 1222As long as your watcher is active (has been started but not stopped) you
1223must not touch the values stored in it. Most specifically you must never 1223must not touch the values stored in it except when explicitly documented
1224reinitialise it or call its C<ev_TYPE_set> macro. 1224otherwise. Most specifically you must never reinitialise it or call its
1225C<ev_TYPE_set> macro.
1225 1226
1226Each and every callback receives the event loop pointer as first, the 1227Each and every callback receives the event loop pointer as first, the
1227registered watcher structure as second, and a bitset of received events as 1228registered watcher structure as second, and a bitset of received events as
1228third argument. 1229third argument.
1229 1230
1395 1396
1396=item bool ev_is_active (ev_TYPE *watcher) 1397=item bool ev_is_active (ev_TYPE *watcher)
1397 1398
1398Returns a true value iff the watcher is active (i.e. it has been started 1399Returns a true value iff the watcher is active (i.e. it has been started
1399and not yet been stopped). As long as a watcher is active you must not modify 1400and not yet been stopped). As long as a watcher is active you must not modify
1400it. 1401it unless documented otherwise.
1402
1403Obviously, it is safe to call this on an active watcher, or actually any
1404watcher that is initialised.
1401 1405
1402=item bool ev_is_pending (ev_TYPE *watcher) 1406=item bool ev_is_pending (ev_TYPE *watcher)
1403 1407
1404Returns a true value iff the watcher is pending, (i.e. it has outstanding 1408Returns a true value iff the watcher is pending, (i.e. it has outstanding
1405events but its callback has not yet been invoked). As long as a watcher 1409events but its callback has not yet been invoked). As long as a watcher
1406is pending (but not active) you must not call an init function on it (but 1410is pending (but not active) you must not call an init function on it (but
1407C<ev_TYPE_set> is safe), you must not change its priority, and you must 1411C<ev_TYPE_set> is safe), you must not change its priority, and you must
1408make sure the watcher is available to libev (e.g. you cannot C<free ()> 1412make sure the watcher is available to libev (e.g. you cannot C<free ()>
1409it). 1413it).
1410 1414
1415It is safe to call this on any watcher in any state as long as it is
1416initialised.
1417
1411=item callback ev_cb (ev_TYPE *watcher) 1418=item callback ev_cb (ev_TYPE *watcher)
1412 1419
1413Returns the callback currently set on the watcher. 1420Returns the callback currently set on the watcher.
1414 1421
1415=item ev_set_cb (ev_TYPE *watcher, callback) 1422=item ev_set_cb (ev_TYPE *watcher, callback)
1428from being executed (except for C<ev_idle> watchers). 1435from being executed (except for C<ev_idle> watchers).
1429 1436
1430If you need to suppress invocation when higher priority events are pending 1437If you need to suppress invocation when higher priority events are pending
1431you need to look at C<ev_idle> watchers, which provide this functionality. 1438you need to look at C<ev_idle> watchers, which provide this functionality.
1432 1439
1433You I<must not> change the priority of a watcher as long as it is active or 1440You I<must not> change the priority of a watcher as long as it is active
1434pending. 1441or pending. Reading the priority with C<ev_priority> is fine in any state.
1435 1442
1436Setting a priority outside the range of C<EV_MINPRI> to C<EV_MAXPRI> is 1443Setting a priority outside the range of C<EV_MINPRI> to C<EV_MAXPRI> is
1437fine, as long as you do not mind that the priority value you query might 1444fine, as long as you do not mind that the priority value you query might
1438or might not have been clamped to the valid range. 1445or might not have been clamped to the valid range.
1439 1446
1461 1468
1462=item ev_feed_event (loop, ev_TYPE *watcher, int revents) 1469=item ev_feed_event (loop, ev_TYPE *watcher, int revents)
1463 1470
1464Feeds the given event set into the event loop, as if the specified event 1471Feeds the given event set into the event loop, as if the specified event
1465had happened for the specified watcher (which must be a pointer to an 1472had happened for the specified watcher (which must be a pointer to an
1466initialised but not necessarily started event watcher). Obviously you must 1473initialised but not necessarily started event watcher, though it can be
1467not free the watcher as long as it has pending events. 1474active). Obviously you must not free the watcher as long as it has pending
1475events.
1468 1476
1469Stopping the watcher, letting libev invoke it, or calling 1477Stopping the watcher, letting libev invoke it, or calling
1470C<ev_clear_pending> will clear the pending event, even if the watcher was 1478C<ev_clear_pending> will clear the pending event, even if the watcher was
1471not started in the first place. 1479not started in the first place.
1472 1480
1500 1508
1501=item started/running/active 1509=item started/running/active
1502 1510
1503Once a watcher has been started with a call to C<ev_TYPE_start> it becomes 1511Once a watcher has been started with a call to C<ev_TYPE_start> it becomes
1504property of the event loop, and is actively waiting for events. While in 1512property of the event loop, and is actively waiting for events. While in
1505this state it cannot be accessed (except in a few documented ways), moved, 1513this state it cannot be accessed (except in a few documented ways, such as
1506freed or anything else - the only legal thing is to keep a pointer to it, 1514stoping it), moved, freed or anything else - the only legal thing is to
1507and call libev functions on it that are documented to work on active watchers. 1515keep a pointer to it, and call libev functions on it that are documented
1516to work on active watchers.
1517
1518As a rule of thumb, before accessing a member or calling any function on
1519a watcher, it should be stopped (or freshly initialised). If that is not
1520convenient, you can check the documentation for that function or member to
1521see if it is safe to use on an active watcher.
1508 1522
1509=item pending 1523=item pending
1510 1524
1511If a watcher is active and libev determines that an event it is interested 1525If a watcher is active and libev determines that an event it is interested
1512in has occurred (such as a timer expiring), it will become pending. It will 1526in has occurred (such as a timer expiring), it will become pending. It
1513stay in this pending state until either it is stopped or its callback is 1527will stay in this pending state until either it is explicitly stopped or
1514about to be invoked, so it is not normally pending inside the watcher 1528its callback is about to be invoked, so it is not normally pending inside
1515callback. 1529the watcher callback.
1516 1530
1517The watcher might or might not be active while it is pending (for example, 1531Generally, the watcher might or might not be active while it is pending
1518an expired non-repeating timer can be pending but no longer active). If it 1532(for example, an expired non-repeating timer can be pending but no longer
1519is stopped, it can be freely accessed (e.g. by calling C<ev_TYPE_set>), 1533active). If it is pending but not active, it can be freely accessed (e.g.
1520but it is still property of the event loop at this time, so cannot be 1534by calling C<ev_TYPE_set>), but it is still property of the event loop at
1521moved, freed or reused. And if it is active the rules described in the 1535this time, so cannot be moved, freed or reused. And if it is active the
1522previous item still apply. 1536rules described in the previous item still apply.
1537
1538Explicitly stopping a watcher will also clear the pending state
1539unconditionally, so it is safe to stop a watcher and then free it.
1523 1540
1524It is also possible to feed an event on a watcher that is not active (e.g. 1541It is also possible to feed an event on a watcher that is not active (e.g.
1525via C<ev_feed_event>), in which case it becomes pending without being 1542via C<ev_feed_event>), in which case it becomes pending without being
1526active. 1543active.
1527 1544
1652 1669
1653Most members are additionally marked with either I<[read-only]>, meaning 1670Most members are additionally marked with either I<[read-only]>, meaning
1654that, while the watcher is active, you can look at the member and expect 1671that, while the watcher is active, you can look at the member and expect
1655some sensible content, but you must not modify it (you can modify it while 1672some sensible content, but you must not modify it (you can modify it while
1656the watcher is stopped to your hearts content), or I<[read-write]>, which 1673the watcher is stopped to your hearts content), or I<[read-write]>, which
1657means you can expect it to have some sensible content while the watcher 1674means you can expect it to have some sensible content while the watcher is
1658is active, but you can also modify it. Modifying it may not do something 1675active, but you can also modify it (within the same thread as the event
1676loop, i.e. without creating data races). Modifying it may not do something
1659sensible or take immediate effect (or do anything at all), but libev will 1677sensible or take immediate effect (or do anything at all), but libev will
1660not crash or malfunction in any way. 1678not crash or malfunction in any way.
1661 1679
1662In any case, the documentation for each member will explain what the 1680In any case, the documentation for each member will explain what the
1663effects are, and if there are any additional access restrictions. 1681effects are, and if there are any additional access restrictions.
1828=item ev_io_init (ev_io *, callback, int fd, int events) 1846=item ev_io_init (ev_io *, callback, int fd, int events)
1829 1847
1830=item ev_io_set (ev_io *, int fd, int events) 1848=item ev_io_set (ev_io *, int fd, int events)
1831 1849
1832Configures an C<ev_io> watcher. The C<fd> is the file descriptor to 1850Configures an C<ev_io> watcher. The C<fd> is the file descriptor to
1833receive events for and C<events> is either C<EV_READ>, C<EV_WRITE> or 1851receive events for and C<events> is either C<EV_READ>, C<EV_WRITE>, both
1834C<EV_READ | EV_WRITE>, to express the desire to receive the given events. 1852C<EV_READ | EV_WRITE> or C<0>, to express the desire to receive the given
1853events.
1854
1855Note that setting the C<events> to C<0> and starting the watcher is
1856supported, but not specially optimized - if your program sometimes happens
1857to generate this combination this is fine, but if it is easy to avoid
1858starting an io watcher watching for no events you should do so.
1835 1859
1836=item ev_io_modify (ev_io *, int events) 1860=item ev_io_modify (ev_io *, int events)
1837 1861
1838Similar to C<ev_io_set>, but only changes the event mask. Using this might 1862Similar to C<ev_io_set>, but only changes the requested events. Using this
1839be faster with some backends, as libev can assume that the C<fd> still 1863might be faster with some backends, as libev can assume that the C<fd>
1840refers to the same underlying file description, something it cannot do 1864still refers to the same underlying file description, something it cannot
1841when using C<ev_io_set>. 1865do when using C<ev_io_set>.
1842 1866
1843=item int fd [no-modify] 1867=item int fd [no-modify]
1844 1868
1845The file descriptor being watched. While it can be read at any time, you 1869The file descriptor being watched. While it can be read at any time, you
1846must not modify this member even when the watcher is stopped - always use 1870must not modify this member even when the watcher is stopped - always use
1847C<ev_io_set> for that. 1871C<ev_io_set> for that.
1848 1872
1849=item int events [no-modify] 1873=item int events [no-modify]
1850 1874
1851The set of events being watched, among other flags. This field is a 1875The set of events the fd is being watched for, among other flags. Remember
1852bit set - to test for C<EV_READ>, use C<< w->events & EV_READ >>, and 1876that this is a bit set - to test for C<EV_READ>, use C<< w->events &
1853similarly for C<EV_WRITE>. 1877EV_READ >>, and similarly for C<EV_WRITE>.
1854 1878
1855As with C<fd>, you must not modify this member even when the watcher is 1879As with C<fd>, you must not modify this member even when the watcher is
1856stopped, always use C<ev_io_set> or C<ev_io_modify> for that. 1880stopped, always use C<ev_io_set> or C<ev_io_modify> for that.
1857 1881
1858=back 1882=back
3854event loop thread and an unspecified mechanism to wake up the main thread. 3878event loop thread and an unspecified mechanism to wake up the main thread.
3855 3879
3856First, you need to associate some data with the event loop: 3880First, you need to associate some data with the event loop:
3857 3881
3858 typedef struct { 3882 typedef struct {
3859 mutex_t lock; /* global loop lock */ 3883 pthread_mutex_t lock; /* global loop lock */
3884 pthread_t tid;
3885 pthread_cond_t invoke_cv;
3860 ev_async async_w; 3886 ev_async async_w;
3861 thread_t tid;
3862 cond_t invoke_cv;
3863 } userdata; 3887 } userdata;
3864 3888
3865 void prepare_loop (EV_P) 3889 void prepare_loop (EV_P)
3866 { 3890 {
3867 // for simplicity, we use a static userdata struct. 3891 // for simplicity, we use a static userdata struct.
3868 static userdata u; 3892 static userdata u;
3869 3893
3870 ev_async_init (&u->async_w, async_cb); 3894 ev_async_init (&u.async_w, async_cb);
3871 ev_async_start (EV_A_ &u->async_w); 3895 ev_async_start (EV_A_ &u.async_w);
3872 3896
3873 pthread_mutex_init (&u->lock, 0); 3897 pthread_mutex_init (&u.lock, 0);
3874 pthread_cond_init (&u->invoke_cv, 0); 3898 pthread_cond_init (&u.invoke_cv, 0);
3875 3899
3876 // now associate this with the loop 3900 // now associate this with the loop
3877 ev_set_userdata (EV_A_ u); 3901 ev_set_userdata (EV_A_ &u);
3878 ev_set_invoke_pending_cb (EV_A_ l_invoke); 3902 ev_set_invoke_pending_cb (EV_A_ l_invoke);
3879 ev_set_loop_release_cb (EV_A_ l_release, l_acquire); 3903 ev_set_loop_release_cb (EV_A_ l_release, l_acquire);
3880 3904
3881 // then create the thread running ev_run 3905 // then create the thread running ev_run
3882 pthread_create (&u->tid, 0, l_run, EV_A); 3906 pthread_create (&u.tid, 0, l_run, EV_A);
3883 } 3907 }
3884 3908
3885The callback for the C<ev_async> watcher does nothing: the watcher is used 3909The callback for the C<ev_async> watcher does nothing: the watcher is used
3886solely to wake up the event loop so it takes notice of any new watchers 3910solely to wake up the event loop so it takes notice of any new watchers
3887that might have been added: 3911that might have been added:
4258gets automatically stopped and restarted when reconfiguring it with this 4282gets automatically stopped and restarted when reconfiguring it with this
4259method. 4283method.
4260 4284
4261For C<ev::embed> watchers this method is called C<set_embed>, to avoid 4285For C<ev::embed> watchers this method is called C<set_embed>, to avoid
4262clashing with the C<set (loop)> method. 4286clashing with the C<set (loop)> method.
4287
4288For C<ev::io> watchers there is an additional C<set> method that acepts a
4289new event mask only, and internally calls C<ev_io_modify>.
4263 4290
4264=item w->start () 4291=item w->start ()
4265 4292
4266Starts the watcher. Note that there is no C<loop> argument, as the 4293Starts the watcher. Note that there is no C<loop> argument, as the
4267constructor already stores the event loop. 4294constructor already stores the event loop.

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines