ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/EV/EV.pm
(Generate patch)

Comparing EV/EV.pm (file contents):
Revision 1.37 by root, Mon Nov 12 07:58:52 2007 UTC vs.
Revision 1.46 by root, Fri Nov 23 05:00:44 2007 UTC

41 my ($w, $revents) = @_; 41 my ($w, $revents) = @_;
42 my $status = $w->rstatus; 42 my $status = $w->rstatus;
43 }; 43 };
44 44
45 # MAINLOOP 45 # MAINLOOP
46 EV::loop; # loop until EV::loop_done is called or all watchers stop 46 EV::loop; # loop until EV::unloop is called or all watchers stop
47 EV::loop EV::LOOP_ONESHOT; # block until at least one event could be handled 47 EV::loop EV::LOOP_ONESHOT; # block until at least one event could be handled
48 EV::loop EV::LOOP_NONBLOCK; # try to handle same events, but do not block 48 EV::loop EV::LOOP_NONBLOCK; # try to handle same events, but do not block
49 49
50=head1 DESCRIPTION 50=head1 DESCRIPTION
51 51
57package EV; 57package EV;
58 58
59use strict; 59use strict;
60 60
61BEGIN { 61BEGIN {
62 our $VERSION = '0.8'; 62 our $VERSION = '1.2';
63 use XSLoader; 63 use XSLoader;
64 XSLoader::load "EV", $VERSION; 64 XSLoader::load "EV", $VERSION;
65} 65}
66 66
67@EV::Io::ISA = 67@EV::Io::ISA =
93 93
94Returns the time the last event loop iteration has been started. This 94Returns the time the last event loop iteration has been started. This
95is the time that (relative) timers are based on, and refering to it is 95is the time that (relative) timers are based on, and refering to it is
96usually faster then calling EV::time. 96usually faster then calling EV::time.
97 97
98=item $method = EV::ev_method 98=item $method = EV::method
99 99
100Returns an integer describing the backend used by libev (EV::METHOD_SELECT 100Returns an integer describing the backend used by libev (EV::METHOD_SELECT
101or EV::METHOD_EPOLL). 101or EV::METHOD_EPOLL).
102 102
103=item EV::loop [$flags] 103=item EV::loop [$flags]
104 104
105Begin checking for events and calling callbacks. It returns when a 105Begin checking for events and calling callbacks. It returns when a
106callback calls EV::loop_done. 106callback calls EV::unloop.
107 107
108The $flags argument can be one of the following: 108The $flags argument can be one of the following:
109 109
110 0 as above 110 0 as above
111 EV::LOOP_ONESHOT block at most once (wait, but do not loop) 111 EV::LOOP_ONESHOT block at most once (wait, but do not loop)
112 EV::LOOP_NONBLOCK do not block at all (fetch/handle events but do not wait) 112 EV::LOOP_NONBLOCK do not block at all (fetch/handle events but do not wait)
113 113
114=item EV::loop_done [$how] 114=item EV::unloop [$how]
115 115
116When called with no arguments or an argument of 1, makes the innermost 116When called with no arguments or an argument of EV::UNLOOP_ONE, makes the
117call to EV::loop return. 117innermost call to EV::loop return.
118 118
119When called with an agrument of 2, all calls to EV::loop will return as 119When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as
120fast as possible. 120fast as possible.
121 121
122=back 122=back
123 123
124=head2 WATCHER 124=head2 WATCHER
258Calls the callback after C<$after> seconds. If C<$repeat> is non-zero, 258Calls the callback after C<$after> seconds. If C<$repeat> is non-zero,
259the timer will be restarted (with the $repeat value as $after) after the 259the timer will be restarted (with the $repeat value as $after) after the
260callback returns. 260callback returns.
261 261
262This means that the callback would be called roughly after C<$after> 262This means that the callback would be called roughly after C<$after>
263seconds, and then every C<$repeat> seconds. "Roughly" because the time of 263seconds, and then every C<$repeat> seconds. The timer does his best not
264callback processing is not taken into account, so the timer will slowly 264to drift, but it will not invoke the timer more often then once per event
265drift. If that isn't acceptable, look at EV::periodic. 265loop iteration, and might drift in other cases. If that isn't acceptable,
266look at EV::periodic, which can provide long-term stable timers.
266 267
267The timer is based on a monotonic clock, that is if somebody is sitting 268The timer is based on a monotonic clock, that is, if somebody is sitting
268in front of the machine while the timer is running and changes the system 269in front of the machine while the timer is running and changes the system
269clock, the timer will nevertheless run (roughly) the same time. 270clock, the timer will nevertheless run (roughly) the same time.
270 271
271The C<timer_ns> variant doesn't start (activate) the newly created watcher. 272The C<timer_ns> variant doesn't start (activate) the newly created watcher.
272 273
277 278
278=item $w->again 279=item $w->again
279 280
280Similar to the C<start> method, but has special semantics for repeating timers: 281Similar to the C<start> method, but has special semantics for repeating timers:
281 282
283If the timer is active and non-repeating, it will be stopped.
284
282If the timer is active and repeating, reset the timeout to occur 285If the timer is active and repeating, reset the timeout to occur
283C<$repeat> seconds after now. 286C<$repeat> seconds after now.
284 287
285If the timer is active and non-repeating, it will be stopped.
286
287If the timer is in active and repeating, start it. 288If the timer is inactive and repeating, start it using the repeat value.
288 289
289Otherwise do nothing. 290Otherwise do nothing.
290 291
291This behaviour is useful when you have a timeout for some IO 292This behaviour is useful when you have a timeout for some IO
292operation. You create a timer object with the same value for C<$after> and 293operation. You create a timer object with the same value for C<$after> and
492 # do nothing unless active 493 # do nothing unless active
493 $dispatcher->{_event_queue_h} 494 $dispatcher->{_event_queue_h}
494 or return; 495 or return;
495 496
496 # make the dispatcher handle any outstanding stuff 497 # make the dispatcher handle any outstanding stuff
498 ... not shown
497 499
498 # create an IO watcher for each and every socket 500 # create an IO watcher for each and every socket
499 @snmp_watcher = ( 501 @snmp_watcher = (
500 (map { EV::io $_, EV::READ, sub { } } 502 (map { EV::io $_, EV::READ, sub { } }
501 keys %{ $dispatcher->{_descriptors} }), 503 keys %{ $dispatcher->{_descriptors} }),
504
505 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE]
506 ? $event->[Net::SNMP::Dispatcher::_TIME] - EV::now : 0),
507 0, sub { },
502 ); 508 );
503
504 # if there are any timeouts, also create a timer
505 push @snmp_watcher, EV::timer $event->[Net::SNMP::Dispatcher::_TIME] - EV::now, 0, sub { }
506 if $event->[Net::SNMP::Dispatcher::_ACTIVE];
507 }; 509 };
508 510
509The callbacks are irrelevant, the only purpose of those watchers is 511The callbacks are irrelevant (and are not even being called), the
510to wake up the process as soon as one of those events occurs (socket 512only purpose of those watchers is to wake up the process as soon as
511readable, or timer timed out). The corresponding EV::check watcher will then 513one of those events occurs (socket readable, or timer timed out). The
512clean up: 514corresponding EV::check watcher will then clean up:
513 515
514 our $snmp_check = EV::check sub { 516 our $snmp_check = EV::check sub {
515 # destroy all watchers 517 # destroy all watchers
516 @snmp_watcher = (); 518 @snmp_watcher = ();
517 519
518 # make the dispatcher handle any new stuff 520 # make the dispatcher handle any new stuff
521 ... not shown
519 }; 522 };
520 523
521The callbacks of the created watchers will not be called as the watchers 524The callbacks of the created watchers will not be called as the watchers
522are destroyed before this cna happen (remember EV::check gets called 525are destroyed before this cna happen (remember EV::check gets called
523first). 526first).
526 529
527=back 530=back
528 531
529=head1 THREADS 532=head1 THREADS
530 533
531Threads are not supported by this in any way. Perl pseudo-threads is evil 534Threads are not supported by this module in any way. Perl pseudo-threads
532stuff and must die. 535is evil stuff and must die. As soon as Perl gains real threads I will work
536on thread support for it.
537
538=head1 FORK
539
540Most of the "improved" event delivering mechanisms of modern operating
541systems have quite a few problems with fork(2) (to put it bluntly: it is
542not supported and usually destructive). Libev makes it possible to work
543around this by having a function that recreates the kernel state after
544fork in the child.
545
546On non-win32 platforms, this module requires the pthread_atfork
547functionality to do this automatically for you. This function is quite
548buggy on most BSDs, though, so YMMV. The overhead for this is quite
549negligible, because everything the function currently does is set a flag
550that is checked only when the event loop gets used the next time, so when
551you do fork but not use EV, the overhead is minimal.
552
553On win32, there is no notion of fork so all this doesn't apply, of course.
533 554
534=cut 555=cut
535 556
536our $DIED = sub { 557our $DIED = sub {
537 warn "EV: error in callback (ignoring): $@"; 558 warn "EV: error in callback (ignoring): $@";
542 563
5431; 5641;
544 565
545=head1 SEE ALSO 566=head1 SEE ALSO
546 567
547 L<EV::DNS>, L<EV::AnyEvent>. 568 L<EV::DNS>.
548 569
549=head1 AUTHOR 570=head1 AUTHOR
550 571
551 Marc Lehmann <schmorp@schmorp.de> 572 Marc Lehmann <schmorp@schmorp.de>
552 http://home.schmorp.de/ 573 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines