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

Comparing libev/ev.pod (file contents):
Revision 1.41 by root, Sat Nov 24 10:19:14 2007 UTC vs.
Revision 1.42 by root, Sat Nov 24 16:31:45 2007 UTC

468 ev_ref (myloop); 468 ev_ref (myloop);
469 ev_signal_stop (myloop, &exitsig); 469 ev_signal_stop (myloop, &exitsig);
470 470
471=back 471=back
472 472
473
473=head1 ANATOMY OF A WATCHER 474=head1 ANATOMY OF A WATCHER
474 475
475A watcher is a structure that you create and register to record your 476A watcher is a structure that you create and register to record your
476interest in some event. For instance, if you want to wait for STDIN to 477interest in some event. For instance, if you want to wait for STDIN to
477become readable, you would create an C<ev_io> watcher for that: 478become readable, you would create an C<ev_io> watcher for that:
576with the error from read() or write(). This will not work in multithreaded 577with the error from read() or write(). This will not work in multithreaded
577programs, though, so beware. 578programs, though, so beware.
578 579
579=back 580=back
580 581
581=head2 SUMMARY OF GENERIC WATCHER FUNCTIONS 582=head2 GENERIC WATCHER FUNCTIONS
582 583
583In the following description, C<TYPE> stands for the watcher type, 584In the following description, C<TYPE> stands for the watcher type,
584e.g. C<timer> for C<ev_timer> watchers and C<io> for C<ev_io> watchers. 585e.g. C<timer> for C<ev_timer> watchers and C<io> for C<ev_io> watchers.
585 586
586=over 4 587=over 4
595which rolls both calls into one. 596which rolls both calls into one.
596 597
597You can reinitialise a watcher at any time as long as it has been stopped 598You can reinitialise a watcher at any time as long as it has been stopped
598(or never started) and there are no pending events outstanding. 599(or never started) and there are no pending events outstanding.
599 600
600The callbakc is always of type C<void (*)(ev_loop *loop, ev_TYPE *watcher, 601The callback is always of type C<void (*)(ev_loop *loop, ev_TYPE *watcher,
601int revents)>. 602int revents)>.
602 603
603=item C<ev_TYPE_set> (ev_TYPE *, [args]) 604=item C<ev_TYPE_set> (ev_TYPE *, [args])
604 605
605This macro initialises the type-specific parts of a watcher. You need to 606This macro initialises the type-specific parts of a watcher. You need to
691 692
692This section describes each watcher in detail, but will not repeat 693This section describes each watcher in detail, but will not repeat
693information given in the last section. 694information given in the last section.
694 695
695 696
696=head2 C<ev_io> - is this file descriptor readable or writable 697=head2 C<ev_io> - is this file descriptor readable or writable?
697 698
698I/O watchers check whether a file descriptor is readable or writable 699I/O watchers check whether a file descriptor is readable or writable
699in each iteration of the event loop (This behaviour is called 700in each iteration of the event loop, or, more precisely, when reading
700level-triggering because you keep receiving events as long as the 701would not block the process and writing would at least be able to write
701condition persists. Remember you can stop the watcher if you don't want to 702some data. This behaviour is called level-triggering because you keep
702act on the event and neither want to receive future events). 703receiving events as long as the condition persists. Remember you can stop
704the watcher if you don't want to act on the event and neither want to
705receive future events.
703 706
704In general you can register as many read and/or write event watchers per 707In general you can register as many read and/or write event watchers per
705fd as you want (as long as you don't confuse yourself). Setting all file 708fd as you want (as long as you don't confuse yourself). Setting all file
706descriptors to non-blocking mode is also usually a good idea (but not 709descriptors to non-blocking mode is also usually a good idea (but not
707required if you know what you are doing). 710required if you know what you are doing).
708 711
709You have to be careful with dup'ed file descriptors, though. Some backends 712You have to be careful with dup'ed file descriptors, though. Some backends
710(the linux epoll backend is a notable example) cannot handle dup'ed file 713(the linux epoll backend is a notable example) cannot handle dup'ed file
711descriptors correctly if you register interest in two or more fds pointing 714descriptors correctly if you register interest in two or more fds pointing
712to the same underlying file/socket etc. description (that is, they share 715to the same underlying file/socket/etc. description (that is, they share
713the same underlying "file open"). 716the same underlying "file open").
714 717
715If you must do this, then force the use of a known-to-be-good backend 718If you must do this, then force the use of a known-to-be-good backend
716(at the time of this writing, this includes only C<EVBACKEND_SELECT> and 719(at the time of this writing, this includes only C<EVBACKEND_SELECT> and
717C<EVBACKEND_POLL>). 720C<EVBACKEND_POLL>).
718 721
722Another thing you have to watch out for is that it is quite easy to
723receive "spurious" readyness notifications, that is your callback might
724be called with C<EV_READ> but a subsequent C<read>(2) will actually block
725because there is no data. Not only are some backends known to create a
726lot of those (for example solaris ports), it is very easy to get into
727this situation even with a relatively standard program structure. Thus
728it is best to always use non-blocking I/O: An extra C<read>(2) returning
729C<EAGAIN> is far preferable to a program hanging until some data arrives.
730
731If you cannot run the fd in non-blocking mode (for example you should not
732play around with an Xlib connection), then you have to seperately re-test
733wether a file descriptor is really ready with a known-to-be good interface
734such as poll (fortunately in our Xlib example, Xlib already does this on
735its own, so its quite safe to use).
736
719=over 4 737=over 4
720 738
721=item ev_io_init (ev_io *, callback, int fd, int events) 739=item ev_io_init (ev_io *, callback, int fd, int events)
722 740
723=item ev_io_set (ev_io *, int fd, int events) 741=item ev_io_set (ev_io *, int fd, int events)
724 742
725Configures an C<ev_io> watcher. The fd is the file descriptor to rceeive 743Configures an C<ev_io> watcher. The C<fd> is the file descriptor to
726events for and events is either C<EV_READ>, C<EV_WRITE> or C<EV_READ | 744rceeive events for and events is either C<EV_READ>, C<EV_WRITE> or
727EV_WRITE> to receive the given events. 745C<EV_READ | EV_WRITE> to receive the given events.
728
729Please note that most of the more scalable backend mechanisms (for example
730epoll and solaris ports) can result in spurious readyness notifications
731for file descriptors, so you practically need to use non-blocking I/O (and
732treat callback invocation as hint only), or retest separately with a safe
733interface before doing I/O (XLib can do this), or force the use of either
734C<EVBACKEND_SELECT> or C<EVBACKEND_POLL>, which don't suffer from this
735problem. Also note that it is quite easy to have your callback invoked
736when the readyness condition is no longer valid even when employing
737typical ways of handling events, so its a good idea to use non-blocking
738I/O unconditionally.
739 746
740=back 747=back
741 748
742Example: call C<stdin_readable_cb> when STDIN_FILENO has become, well 749Example: call C<stdin_readable_cb> when STDIN_FILENO has become, well
743readable, but only once. Since it is likely line-buffered, you could 750readable, but only once. Since it is likely line-buffered, you could
756 ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ); 763 ev_io_init (&stdin_readable, stdin_readable_cb, STDIN_FILENO, EV_READ);
757 ev_io_start (loop, &stdin_readable); 764 ev_io_start (loop, &stdin_readable);
758 ev_loop (loop, 0); 765 ev_loop (loop, 0);
759 766
760 767
761=head2 C<ev_timer> - relative and optionally recurring timeouts 768=head2 C<ev_timer> - relative and optionally repeating timeouts
762 769
763Timer watchers are simple relative timers that generate an event after a 770Timer watchers are simple relative timers that generate an event after a
764given time, and optionally repeating in regular intervals after that. 771given time, and optionally repeating in regular intervals after that.
765 772
766The timers are based on real time, that is, if you register an event that 773The timers are based on real time, that is, if you register an event that
848 // and in some piece of code that gets executed on any "activity": 855 // and in some piece of code that gets executed on any "activity":
849 // reset the timeout to start ticking again at 10 seconds 856 // reset the timeout to start ticking again at 10 seconds
850 ev_timer_again (&mytimer); 857 ev_timer_again (&mytimer);
851 858
852 859
853=head2 C<ev_periodic> - to cron or not to cron 860=head2 C<ev_periodic> - to cron or not to cron?
854 861
855Periodic watchers are also timers of a kind, but they are very versatile 862Periodic watchers are also timers of a kind, but they are very versatile
856(and unfortunately a bit complex). 863(and unfortunately a bit complex).
857 864
858Unlike C<ev_timer>'s, they are not based on real time (or relative time) 865Unlike C<ev_timer>'s, they are not based on real time (or relative time)
986 ev_periodic_init (&hourly_tick, clock_cb, 993 ev_periodic_init (&hourly_tick, clock_cb,
987 fmod (ev_now (loop), 3600.), 3600., 0); 994 fmod (ev_now (loop), 3600.), 3600., 0);
988 ev_periodic_start (loop, &hourly_tick); 995 ev_periodic_start (loop, &hourly_tick);
989 996
990 997
991=head2 C<ev_signal> - signal me when a signal gets signalled 998=head2 C<ev_signal> - signal me when a signal gets signalled!
992 999
993Signal watchers will trigger an event when the process receives a specific 1000Signal watchers will trigger an event when the process receives a specific
994signal one or more times. Even though signals are very asynchronous, libev 1001signal one or more times. Even though signals are very asynchronous, libev
995will try it's best to deliver signals synchronously, i.e. as part of the 1002will try it's best to deliver signals synchronously, i.e. as part of the
996normal event processing, like any other event. 1003normal event processing, like any other event.
1012of the C<SIGxxx> constants). 1019of the C<SIGxxx> constants).
1013 1020
1014=back 1021=back
1015 1022
1016 1023
1017=head2 C<ev_child> - wait for pid status changes 1024=head2 C<ev_child> - watch out for process status changes
1018 1025
1019Child watchers trigger when your process receives a SIGCHLD in response to 1026Child watchers trigger when your process receives a SIGCHLD in response to
1020some child status changes (most typically when a child of yours dies). 1027some child status changes (most typically when a child of yours dies).
1021 1028
1022=over 4 1029=over 4
1045 struct ev_signal signal_watcher; 1052 struct ev_signal signal_watcher;
1046 ev_signal_init (&signal_watcher, sigint_cb, SIGINT); 1053 ev_signal_init (&signal_watcher, sigint_cb, SIGINT);
1047 ev_signal_start (loop, &sigint_cb); 1054 ev_signal_start (loop, &sigint_cb);
1048 1055
1049 1056
1050=head2 C<ev_idle> - when you've got nothing better to do 1057=head2 C<ev_idle> - when you've got nothing better to do...
1051 1058
1052Idle watchers trigger events when there are no other events are pending 1059Idle watchers trigger events when there are no other events are pending
1053(prepare, check and other idle watchers do not count). That is, as long 1060(prepare, check and other idle watchers do not count). That is, as long
1054as your process is busy handling sockets or timeouts (or even signals, 1061as your process is busy handling sockets or timeouts (or even signals,
1055imagine) it will not be triggered. But when your process is idle all idle 1062imagine) it will not be triggered. But when your process is idle all idle
1089 struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle)); 1096 struct ev_idle *idle_watcher = malloc (sizeof (struct ev_idle));
1090 ev_idle_init (idle_watcher, idle_cb); 1097 ev_idle_init (idle_watcher, idle_cb);
1091 ev_idle_start (loop, idle_cb); 1098 ev_idle_start (loop, idle_cb);
1092 1099
1093 1100
1094=head2 C<ev_prepare> and C<ev_check> - customise your event loop 1101=head2 C<ev_prepare> and C<ev_check> - customise your event loop!
1095 1102
1096Prepare and check watchers are usually (but not always) used in tandem: 1103Prepare and check watchers are usually (but not always) used in tandem:
1097prepare watchers get invoked before the process blocks and check watchers 1104prepare watchers get invoked before the process blocks and check watchers
1098afterwards. 1105afterwards.
1099 1106
1133=back 1140=back
1134 1141
1135Example: *TODO*. 1142Example: *TODO*.
1136 1143
1137 1144
1138=head2 C<ev_embed> - when one backend isn't enough 1145=head2 C<ev_embed> - when one backend isn't enough...
1139 1146
1140This is a rather advanced watcher type that lets you embed one event loop 1147This is a rather advanced watcher type that lets you embed one event loop
1141into another (currently only C<ev_io> events are supported in the embedded 1148into another (currently only C<ev_io> events are supported in the embedded
1142loop, other types of watchers might be handled in a delayed or incorrect 1149loop, other types of watchers might be handled in a delayed or incorrect
1143fashion and must not be used). 1150fashion and must not be used).

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines