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

Comparing EV/EV.pm (file contents):
Revision 1.52 by root, Sat Nov 24 16:20:30 2007 UTC vs.
Revision 1.75 by root, Fri Dec 21 10:36:22 2007 UTC

38 # CHILD/PID STATUS CHANGES 38 # CHILD/PID STATUS CHANGES
39 39
40 my $w = EV::child 666, sub { 40 my $w = EV::child 666, sub {
41 my ($w, $revents) = @_; 41 my ($w, $revents) = @_;
42 my $status = $w->rstatus; 42 my $status = $w->rstatus;
43 };
44
45 # STAT CHANGES
46 my $w = EV::stat "/etc/passwd", 10, sub {
47 my ($w, $revents) = @_;
48 warn $w->path, " has changed somehow.\n";
43 }; 49 };
44 50
45 # MAINLOOP 51 # MAINLOOP
46 EV::loop; # loop until EV::unloop is called or all watchers stop 52 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 53 EV::loop EV::LOOP_ONESHOT; # block until at least one event could be handled
52This module provides an interface to libev 58This module provides an interface to libev
53(L<http://software.schmorp.de/pkg/libev.html>). While the documentation 59(L<http://software.schmorp.de/pkg/libev.html>). While the documentation
54below is comprehensive, one might also consult the documentation of libev 60below is comprehensive, one might also consult the documentation of libev
55itself (L<http://cvs.schmorp.de/libev/ev.html>) for more subtle details on 61itself (L<http://cvs.schmorp.de/libev/ev.html>) for more subtle details on
56watcher semantics or some discussion on the available backends, or how to 62watcher semantics or some discussion on the available backends, or how to
57force a specific backend with C<LIBEV_FLAGS>. 63force a specific backend with C<LIBEV_FLAGS>, or just about in any case
64because it has much more detailed information.
58 65
59=cut 66=cut
60 67
61package EV; 68package EV;
62 69
63use strict; 70use strict;
64 71
65BEGIN { 72BEGIN {
66 our $VERSION = '1.3'; 73 our $VERSION = '2.0';
67 use XSLoader; 74 use XSLoader;
68 XSLoader::load "EV", $VERSION; 75 XSLoader::load "EV", $VERSION;
69} 76}
70 77
71@EV::IO::ISA = 78@EV::IO::ISA =
72@EV::Timer::ISA = 79@EV::Timer::ISA =
73@EV::Periodic::ISA = 80@EV::Periodic::ISA =
74@EV::Signal::ISA = 81@EV::Signal::ISA =
82@EV::Child::ISA =
83@EV::Stat::ISA =
75@EV::Idle::ISA = 84@EV::Idle::ISA =
76@EV::Prepare::ISA = 85@EV::Prepare::ISA =
77@EV::Check::ISA = 86@EV::Check::ISA =
78@EV::Child::ISA = "EV::Watcher"; 87@EV::Embed::ISA =
88@EV::Fork::ISA =
89 "EV::Watcher";
90
91@EV::Loop::Default::ISA = "EV::Loop";
92
93=head1 EVENT LOOPS
94
95EV supports multiple event loops: There is a single "default event loop"
96that can handle everything including signals and child watchers, and any
97number of "dynamic event loops" that can use different backends (with
98various limitations), but no child and signal watchers.
99
100You do not have to do anything to create the default event loop: When
101the module is loaded a suitable backend is selected on the premise of
102selecting a working backend (which for example rules out kqueue on most
103BSDs). Modules should, unless they have "special needs" always use the
104default loop as this is fastest (perl-wise), best supported by other
105modules (e.g. AnyEvent or Coro) and most portable event loop.
106
107For specific programs you cna create additional event loops dynamically.
108
109=over 4
110
111=item $loop = new EV::loop [$flags]
112
113Create a new event loop as per the specified flags. Please refer to the
114C<ev_loop_new ()> function description in the libev documentation
115(L<http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod#GLOBAL_FUNCTIONS>)
116for more info.
117
118The loop will automatically be destroyed when it is no longer referenced
119by any watcher and the loop object goes out of scope.
120
121Using C<EV::FLAG_FORKCHECK> is recommended, as only the default event loop
122is protected by this module.
123
124=item $loop->loop_fork
125
126Must be called after a fork in the child, before entering or continuing
127the event loop. An alternative is to use C<EV::FLAG_FORKCHECK> which calls
128this fucntion automatically, at some performance loss (refer to the libev
129documentation).
130
131=back
132
79 133
80=head1 BASIC INTERFACE 134=head1 BASIC INTERFACE
81 135
82=over 4 136=over 4
83 137
84=item $EV::DIED 138=item $EV::DIED
85 139
86Must contain a reference to a function that is called when a callback 140Must contain a reference to a function that is called when a callback
87throws an exception (with $@ containing thr error). The default prints an 141throws an exception (with $@ containing the error). The default prints an
88informative message and continues. 142informative message and continues.
89 143
90If this callback throws an exception it will be silently ignored. 144If this callback throws an exception it will be silently ignored.
91 145
92=item $time = EV::time 146=item $time = EV::time
93 147
94Returns the current time in (fractional) seconds since the epoch. 148Returns the current time in (fractional) seconds since the epoch.
95 149
96=item $time = EV::now 150=item $time = EV::now
151
152=item $time = $loop->now
97 153
98Returns the time the last event loop iteration has been started. This 154Returns the time the last event loop iteration has been started. This
99is the time that (relative) timers are based on, and refering to it is 155is the time that (relative) timers are based on, and refering to it is
100usually faster then calling EV::time. 156usually faster then calling EV::time.
101 157
102=item $method = EV::method 158=item $backend = EV::backend
159
160=item $backend = $loop->backend
103 161
104Returns an integer describing the backend used by libev (EV::METHOD_SELECT 162Returns an integer describing the backend used by libev (EV::METHOD_SELECT
105or EV::METHOD_EPOLL). 163or EV::METHOD_EPOLL).
106 164
107=item EV::loop [$flags] 165=item EV::loop [$flags]
166
167=item $loop->loop ([$flags])
108 168
109Begin checking for events and calling callbacks. It returns when a 169Begin checking for events and calling callbacks. It returns when a
110callback calls EV::unloop. 170callback calls EV::unloop.
111 171
112The $flags argument can be one of the following: 172The $flags argument can be one of the following:
115 EV::LOOP_ONESHOT block at most once (wait, but do not loop) 175 EV::LOOP_ONESHOT block at most once (wait, but do not loop)
116 EV::LOOP_NONBLOCK do not block at all (fetch/handle events but do not wait) 176 EV::LOOP_NONBLOCK do not block at all (fetch/handle events but do not wait)
117 177
118=item EV::unloop [$how] 178=item EV::unloop [$how]
119 179
180=item $loop->unloop ([$how])
181
120When called with no arguments or an argument of EV::UNLOOP_ONE, makes the 182When called with no arguments or an argument of EV::UNLOOP_ONE, makes the
121innermost call to EV::loop return. 183innermost call to EV::loop return.
122 184
123When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as 185When called with an argument of EV::UNLOOP_ALL, all calls to EV::loop will return as
124fast as possible. 186fast as possible.
125 187
188=item $count = EV::loop_count
189
190=item $count = $loop->loop_count
191
192Return the number of times the event loop has polled for new
193events. Sometiems useful as a generation counter.
194
126=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents) 195=item EV::once $fh_or_undef, $events, $timeout, $cb->($revents)
196
197=item $loop->once ($fh_or_undef, $events, $timeout, $cb->($revents))
127 198
128This function rolls together an I/O and a timer watcher for a single 199This function rolls together an I/O and a timer watcher for a single
129one-shot event without the need for managing a watcher object. 200one-shot event without the need for managing a watcher object.
130 201
131If C<$fh_or_undef> is a filehandle or file descriptor, then C<$events> 202If C<$fh_or_undef> is a filehandle or file descriptor, then C<$events>
144 215
145EV::once doesn't return anything: the watchers stay active till either 216EV::once doesn't return anything: the watchers stay active till either
146of them triggers, then they will be stopped and freed, and the callback 217of them triggers, then they will be stopped and freed, and the callback
147invoked. 218invoked.
148 219
149=back 220=item EV::feed_fd_event ($fd, $revents)
150 221
151=head2 WATCHER 222=item $loop->feed_fd_event ($fd, $revents)
223
224Feed an event on a file descriptor into EV. EV will react to this call as
225if the readyness notifications specified by C<$revents> (a combination of
226C<EV::READ> and C<EV::WRITE>) happened on the file descriptor C<$fd>.
227
228=item EV::feed_signal_event ($signal)
229
230Feed a signal event into EV. EV will react to this call as if the signal
231specified by C<$signal> had occured.
232
233=back
234
235
236=head1 WATCHER OBJECTS
152 237
153A watcher is an object that gets created to record your interest in some 238A watcher is an object that gets created to record your interest in some
154event. For instance, if you want to wait for STDIN to become readable, you 239event. For instance, if you want to wait for STDIN to become readable, you
155would create an EV::io watcher for that: 240would create an EV::io watcher for that:
156 241
165events. 250events.
166 251
167Each watcher type has its associated bit in revents, so you can use the 252Each watcher type has its associated bit in revents, so you can use the
168same callback for multiple watchers. The event mask is named after the 253same callback for multiple watchers. The event mask is named after the
169type, i..e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE, 254type, i..e. EV::child sets EV::CHILD, EV::prepare sets EV::PREPARE,
170EV::periodic sets EV::PERIODIC and so on, with the exception of IO events 255EV::periodic sets EV::PERIODIC and so on, with the exception of I/O events
171(which can set both EV::READ and EV::WRITE bits), and EV::timer (which 256(which can set both EV::READ and EV::WRITE bits), and EV::timer (which
172uses EV::TIMEOUT). 257uses EV::TIMEOUT).
173 258
174In the rare case where one wants to create a watcher but not start it at 259In the rare case where one wants to create a watcher but not start it at
175the same time, each constructor has a variant with a trailing C<_ns> in 260the same time, each constructor has a variant with a trailing C<_ns> in
181 266
182Also, all methods changing some aspect of a watcher (->set, ->priority, 267Also, all methods changing some aspect of a watcher (->set, ->priority,
183->fh and so on) automatically stop and start it again if it is active, 268->fh and so on) automatically stop and start it again if it is active,
184which means pending events get lost. 269which means pending events get lost.
185 270
186=head2 WATCHER TYPES 271=head2 COMMON WATCHER METHODS
187 272
188Now lets move to the existing watcher types and asociated methods. 273This section lists methods common to all watchers.
189
190The following methods are available for all watchers. Then followes a
191description of each watcher constructor (EV::io, EV::timer, EV::periodic,
192EV::signal, EV::child, EV::idle, EV::prepare and EV::check), followed by
193any type-specific methods (if any).
194 274
195=over 4 275=over 4
196 276
197=item $w->start 277=item $w->start
198 278
202 282
203=item $w->stop 283=item $w->stop
204 284
205Stop a watcher if it is active. Also clear any pending events (events that 285Stop a watcher if it is active. Also clear any pending events (events that
206have been received but that didn't yet result in a callback invocation), 286have been received but that didn't yet result in a callback invocation),
207regardless of wether the watcher was active or not. 287regardless of whether the watcher was active or not.
208 288
209=item $bool = $w->is_active 289=item $bool = $w->is_active
210 290
211Returns true if the watcher is active, false otherwise. 291Returns true if the watcher is active, false otherwise.
212 292
242The default priority of any newly-created watcher is 0. 322The default priority of any newly-created watcher is 0.
243 323
244Note that the priority semantics have not yet been fleshed out and are 324Note that the priority semantics have not yet been fleshed out and are
245subject to almost certain change. 325subject to almost certain change.
246 326
247=item $w->trigger ($revents) 327=item $w->invoke ($revents)
248 328
249Call the callback *now* with the given event mask. 329Call the callback *now* with the given event mask.
330
331=item $w->feed_event ($revents)
332
333Feed some events on this watcher into EV. EV will react to this call as if
334the watcher had received the given C<$revents> mask.
335
336=item $revents = $w->clear_pending
337
338If the watcher is pending, this function returns clears its pending status
339and returns its C<$revents> bitset (as if its callback was invoked). If the
340watcher isn't pending it does nothing and returns C<0>.
250 341
251=item $previous_state = $w->keepalive ($bool) 342=item $previous_state = $w->keepalive ($bool)
252 343
253Normally, C<EV::loop> will return when there are no active watchers 344Normally, C<EV::loop> will return when there are no active watchers
254(which is a "deadlock" because no progress can be made anymore). This is 345(which is a "deadlock" because no progress can be made anymore). This is
267though your watcher is active, it won't keep C<EV::loop> from returning. 358though your watcher is active, it won't keep C<EV::loop> from returning.
268 359
269The initial value for keepalive is true (enabled), and you cna change it 360The initial value for keepalive is true (enabled), and you cna change it
270any time. 361any time.
271 362
272Example: Register an IO watcher for some UDP socket but do not keep the 363Example: Register an I/O watcher for some UDP socket but do not keep the
273event loop from running just because of that watcher. 364event loop from running just because of that watcher.
274 365
275 my $udp_socket = ... 366 my $udp_socket = ...
276 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... }; 367 my $udp_watcher = EV::io $udp_socket, EV::READ, sub { ... };
277 $udp_watcher->keepalive (0); 368 $1000udp_watcher->keepalive (0);
369
370=item $loop = $w->loop
371
372Return the loop that this watcher is attached to.
373
374=back
375
376
377=head1 WATCHER TYPES
378
379Each of the following subsections describes a single watcher type.
380
381=head3 I/O WATCHERS - is this file descriptor readable or writable?
382
383=over 4
278 384
279=item $w = EV::io $fileno_or_fh, $eventmask, $callback 385=item $w = EV::io $fileno_or_fh, $eventmask, $callback
280 386
281=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback 387=item $w = EV::io_ns $fileno_or_fh, $eventmask, $callback
282 388
389=item $w = $loop->io 8$fileno_or_fh, $eventmask, $callback)
390
391=item $w = $loop->io_ns ($fileno_or_fh, $eventmask, $callback)
392
283As long as the returned watcher object is alive, call the C<$callback> 393As long as the returned watcher object is alive, call the C<$callback>
284when the events specified in C<$eventmask>. 394when at least one of events specified in C<$eventmask> occurs.
285 395
286The $eventmask can be one or more of these constants ORed together: 396The $eventmask can be one or more of these constants ORed together:
287 397
288 EV::READ wait until read() wouldn't block anymore 398 EV::READ wait until read() wouldn't block anymore
289 EV::WRITE wait until write() wouldn't block anymore 399 EV::WRITE wait until write() wouldn't block anymore
305 415
306=item $old_eventmask = $w->events ($new_eventmask) 416=item $old_eventmask = $w->events ($new_eventmask)
307 417
308Returns the previously set event mask and optionally set a new one. 418Returns the previously set event mask and optionally set a new one.
309 419
420=back
421
422
423=head3 TIMER WATCHERS - relative and optionally repeating timeouts
424
425=over 4
310 426
311=item $w = EV::timer $after, $repeat, $callback 427=item $w = EV::timer $after, $repeat, $callback
312 428
313=item $w = EV::timer_ns $after, $repeat, $callback 429=item $w = EV::timer_ns $after, $repeat, $callback
314 430
315Calls the callback after C<$after> seconds. If C<$repeat> is non-zero, 431=item $w = $loop->timer ($after, $repeat, $callback)
316the timer will be restarted (with the $repeat value as $after) after the 432
317callback returns. 433=item $w = $loop->timer_ns ($after, $repeat, $callback)
434
435Calls the callback after C<$after> seconds (which may be fractional). If
436C<$repeat> is non-zero, the timer will be restarted (with the $repeat
437value as $after) after the callback returns.
318 438
319This means that the callback would be called roughly after C<$after> 439This means that the callback would be called roughly after C<$after>
320seconds, and then every C<$repeat> seconds. The timer does his best not 440seconds, and then every C<$repeat> seconds. The timer does his best not
321to drift, but it will not invoke the timer more often then once per event 441to drift, but it will not invoke the timer more often then once per event
322loop iteration, and might drift in other cases. If that isn't acceptable, 442loop iteration, and might drift in other cases. If that isn't acceptable,
328 448
329The C<timer_ns> variant doesn't start (activate) the newly created watcher. 449The C<timer_ns> variant doesn't start (activate) the newly created watcher.
330 450
331=item $w->set ($after, $repeat) 451=item $w->set ($after, $repeat)
332 452
333Reconfigures the watcher, see the constructor above for details. Can be at 453Reconfigures the watcher, see the constructor above for details. Can be called at
334any time. 454any time.
335 455
336=item $w->again 456=item $w->again
337 457
338Similar to the C<start> method, but has special semantics for repeating timers: 458Similar to the C<start> method, but has special semantics for repeating timers:
349This behaviour is useful when you have a timeout for some IO 469This behaviour is useful when you have a timeout for some IO
350operation. You create a timer object with the same value for C<$after> and 470operation. You create a timer object with the same value for C<$after> and
351C<$repeat>, and then, in the read/write watcher, run the C<again> method 471C<$repeat>, and then, in the read/write watcher, run the C<again> method
352on the timeout. 472on the timeout.
353 473
474=back
475
476
477=head3 PERIODIC WATCHERS - to cron or not to cron?
478
479=over 4
354 480
355=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback 481=item $w = EV::periodic $at, $interval, $reschedule_cb, $callback
356 482
357=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback 483=item $w = EV::periodic_ns $at, $interval, $reschedule_cb, $callback
484
485=item $w = $loop->periodic ($at, $interval, $reschedule_cb, $callback)
486
487=item $w = $loop->periodic_ns ($at, $interval, $reschedule_cb, $callback)
358 488
359Similar to EV::timer, but is not based on relative timeouts but on 489Similar to EV::timer, but is not based on relative timeouts but on
360absolute times. Apart from creating "simple" timers that trigger "at" the 490absolute times. Apart from creating "simple" timers that trigger "at" the
361specified time, it can also be used for non-drifting absolute timers and 491specified time, it can also be used for non-drifting absolute timers and
362more complex, cron-like, setups that are not adversely affected by time 492more complex, cron-like, setups that are not adversely affected by time
430 560
431The C<periodic_ns> variant doesn't start (activate) the newly created watcher. 561The C<periodic_ns> variant doesn't start (activate) the newly created watcher.
432 562
433=item $w->set ($at, $interval, $reschedule_cb) 563=item $w->set ($at, $interval, $reschedule_cb)
434 564
435Reconfigures the watcher, see the constructor above for details. Can be at 565Reconfigures the watcher, see the constructor above for details. Can be called at
436any time. 566any time.
437 567
438=item $w->again 568=item $w->again
439 569
440Simply stops and starts the watcher again. 570Simply stops and starts the watcher again.
441 571
572=item $time = $w->at
573
574Return the time that the watcher is expected to trigger next.
575
576=back
577
578
579=head3 SIGNAL WATCHERS - signal me when a signal gets signalled!
580
581=over 4
442 582
443=item $w = EV::signal $signal, $callback 583=item $w = EV::signal $signal, $callback
444 584
445=item $w = EV::signal_ns $signal, $callback 585=item $w = EV::signal_ns $signal, $callback
446 586
447Call the callback when $signal is received (the signal can be specified 587Call the callback when $signal is received (the signal can be specified by
448by number or by name, just as with kill or %SIG). 588number or by name, just as with C<kill> or C<%SIG>).
449 589
450EV will grab the signal for the process (the kernel only allows one 590EV will grab the signal for the process (the kernel only allows one
451component to receive a signal at a time) when you start a signal watcher, 591component to receive a signal at a time) when you start a signal watcher,
452and removes it again when you stop it. Perl does the same when you 592and removes it again when you stop it. Perl does the same when you
453add/remove callbacks to %SIG, so watch out. 593add/remove callbacks to C<%SIG>, so watch out.
454 594
455You can have as many signal watchers per signal as you want. 595You can have as many signal watchers per signal as you want.
456 596
457The C<signal_ns> variant doesn't start (activate) the newly created watcher. 597The C<signal_ns> variant doesn't start (activate) the newly created watcher.
458 598
459=item $w->set ($signal) 599=item $w->set ($signal)
460 600
461Reconfigures the watcher, see the constructor above for details. Can be at 601Reconfigures the watcher, see the constructor above for details. Can be
462any time. 602called at any time.
463 603
464=item $current_signum = $w->signal 604=item $current_signum = $w->signal
465 605
466=item $old_signum = $w->signal ($new_signal) 606=item $old_signum = $w->signal ($new_signal)
467 607
468Returns the previously set signal (always as a number not name) and 608Returns the previously set signal (always as a number not name) and
469optionally set a new one. 609optionally set a new one.
470 610
611=back
612
613
614=head3 CHILD WATCHERS - watch out for process status changes
615
616=over 4
471 617
472=item $w = EV::child $pid, $callback 618=item $w = EV::child $pid, $callback
473 619
474=item $w = EV::child_ns $pid, $callback 620=item $w = EV::child_ns $pid, $callback
475 621
622=item $w = $loop->child ($pid, $callback)
623
624=item $w = $loop->child_ns ($pid, $callback)
625
476Call the callback when a status change for pid C<$pid> (or any pid 626Call the callback when a status change for pid C<$pid> (or any pid if
477if C<$pid> is 0) has been received. More precisely: when the process 627C<$pid> is 0) has been received. More precisely: when the process receives
478receives a SIGCHLD, EV will fetch the outstanding exit/wait status for all 628a C<SIGCHLD>, EV will fetch the outstanding exit/wait status for all
479changed/zombie children and call the callback. 629changed/zombie children and call the callback.
480 630
481You can access both status and pid by using the C<rstatus> and C<rpid> 631It is valid (and fully supported) to install a child watcher after a child
482methods on the watcher object. 632has exited but before the event loop has started its next iteration (for
633example, first you C<fork>, then the new child process might exit, and
634only then do you install a child watcher in the parent for the new pid).
483 635
636You can access both exit (or tracing) status and pid by using the
637C<rstatus> and C<rpid> methods on the watcher object.
638
484You can have as many pid watchers per pid as you want. 639You can have as many pid watchers per pid as you want, they will all be
640called.
485 641
486The C<child_ns> variant doesn't start (activate) the newly created watcher. 642The C<child_ns> variant doesn't start (activate) the newly created watcher.
487 643
488=item $w->set ($pid) 644=item $w->set ($pid)
489 645
490Reconfigures the watcher, see the constructor above for details. Can be at 646Reconfigures the watcher, see the constructor above for details. Can be called at
491any time. 647any time.
492 648
493=item $current_pid = $w->pid 649=item $current_pid = $w->pid
494 650
495=item $old_pid = $w->pid ($new_pid) 651=item $old_pid = $w->pid ($new_pid)
504=item $pid = $w->rpid 660=item $pid = $w->rpid
505 661
506Return the pid of the awaited child (useful when you have installed a 662Return the pid of the awaited child (useful when you have installed a
507watcher for all pids). 663watcher for all pids).
508 664
665=back
666
667
668=head3 STAT WATCHERS - did the file attributes just change?
669
670=over 4
671
672=item $w = EV::stat $path, $interval, $callback
673
674=item $w = EV::stat_ns $path, $interval, $callback
675
676=item $w = $loop->stat ($path, $interval, $callback)
677
678=item $w = $loop->stat_ns ($path, $interval, $callback)
679
680Call the callback when a file status change has been detected on
681C<$path>. The C<$path> does not need to exist, changing from "path exists"
682to "path does not exist" is a status change like any other.
683
684The C<$interval> is a recommended polling interval for systems where
685OS-supported change notifications don't exist or are not supported. If
686you use C<0> then an unspecified default is used (which is highly
687recommended!), which is to be expected to be around five seconds usually.
688
689This watcher type is not meant for massive numbers of stat watchers,
690as even with OS-supported change notifications, this can be
691resource-intensive.
692
693The C<stat_ns> variant doesn't start (activate) the newly created watcher.
694
695=item ... = $w->stat
696
697This call is very similar to the perl C<stat> built-in: It stats (using
698C<lstat>) the path specified in the watcher and sets perls stat cache (as
699well as EV's idea of the current stat values) to the values found.
700
701In scalar context, a boolean is return indicating success or failure of
702the stat. In list context, the same 13-value list as with stat is returned
703(except that the blksize and blocks fields are not reliable).
704
705In the case of an error, errno is set to C<ENOENT> (regardless of the
706actual error value) and the C<nlink> value is forced to zero (if the stat
707was successful then nlink is guaranteed to be non-zero).
708
709See also the next two entries for more info.
710
711=item ... = $w->attr
712
713Just like C<< $w->stat >>, but without the initial stat'ing: this returns
714the values most recently detected by EV. See the next entry for more info.
715
716=item ... = $w->prev
717
718Just like C<< $w->stat >>, but without the initial stat'ing: this returns
719the previous set of values, before the change.
720
721That is, when the watcher callback is invoked, C<< $w->prev >> will be set
722to the values found I<before> a change was detected, while C<< $w->attr >>
723returns the values found leading to the change detection. The difference (if any)
724between C<prev> and C<attr> is what triggered the callback.
725
726If you did something to the filesystem object and do not want to trigger
727yet another change, you can call C<stat> to update EV's idea of what the
728current attributes are.
729
730=item $w->set ($path, $interval)
731
732Reconfigures the watcher, see the constructor above for details. Can be
733called at any time.
734
735=item $current_path = $w->path
736
737=item $old_path = $w->path ($new_path)
738
739Returns the previously set path and optionally set a new one.
740
741=item $current_interval = $w->interval
742
743=item $old_interval = $w->interval ($new_interval)
744
745Returns the previously set interval and optionally set a new one. Can be
746used to query the actual interval used.
747
748=back
749
750
751=head3 IDLE WATCHERS - when you've got nothing better to do...
752
753=over 4
509 754
510=item $w = EV::idle $callback 755=item $w = EV::idle $callback
511 756
512=item $w = EV::idle_ns $callback 757=item $w = EV::idle_ns $callback
513 758
514Call the callback when there are no pending io, timer/periodic, signal or 759=item $w = $loop->idle ($callback)
515child events, i.e. when the process is idle. 760
761=item $w = $loop->idle_ns ($callback)
762
763Call the callback when there are no other pending watchers of the same or
764higher priority (excluding check, prepare and other idle watchers of the
765same or lower priority, of course). They are called idle watchers because
766when the watcher is the highest priority pending event in the process, the
767process is considered to be idle at that priority.
768
769If you want a watcher that is only ever called when I<no> other events are
770outstanding you have to set the priority to C<EV::MINPRI>.
516 771
517The process will not block as long as any idle watchers are active, and 772The process will not block as long as any idle watchers are active, and
518they will be called repeatedly until stopped. 773they will be called repeatedly until stopped.
519 774
775For example, if you have idle watchers at priority C<0> and C<1>, and
776an I/O watcher at priority C<0>, then the idle watcher at priority C<1>
777and the I/O watcher will always run when ready. Only when the idle watcher
778at priority C<1> is stopped and the I/O watcher at priority C<0> is not
779pending with the C<0>-priority idle watcher be invoked.
780
520The C<idle_ns> variant doesn't start (activate) the newly created watcher. 781The C<idle_ns> variant doesn't start (activate) the newly created watcher.
521 782
783=back
784
785
786=head3 PREPARE WATCHERS - customise your event loop!
787
788=over 4
522 789
523=item $w = EV::prepare $callback 790=item $w = EV::prepare $callback
524 791
525=item $w = EV::prepare_ns $callback 792=item $w = EV::prepare_ns $callback
793
794=item $w = $loop->prepare ($callback)
795
796=item $w = $loop->prepare_ns 8$callback)
526 797
527Call the callback just before the process would block. You can still 798Call the callback just before the process would block. You can still
528create/modify any watchers at this point. 799create/modify any watchers at this point.
529 800
530See the EV::check watcher, below, for explanations and an example. 801See the EV::check watcher, below, for explanations and an example.
531 802
532The C<prepare_ns> variant doesn't start (activate) the newly created watcher. 803The C<prepare_ns> variant doesn't start (activate) the newly created watcher.
533 804
805=back
806
807
808=head3 CHECK WATCHERS - customise your event loop even more!
809
810=over 4
534 811
535=item $w = EV::check $callback 812=item $w = EV::check $callback
536 813
537=item $w = EV::check_ns $callback 814=item $w = EV::check_ns $callback
815
816=item $w = $loop->check ($callback)
817
818=item $w = $loop->check_ns ($callback)
538 819
539Call the callback just after the process wakes up again (after it has 820Call the callback just after the process wakes up again (after it has
540gathered events), but before any other callbacks have been invoked. 821gathered events), but before any other callbacks have been invoked.
541 822
542This is used to integrate other event-based software into the EV 823This is used to integrate other event-based software into the EV
552 or return; 833 or return;
553 834
554 # make the dispatcher handle any outstanding stuff 835 # make the dispatcher handle any outstanding stuff
555 ... not shown 836 ... not shown
556 837
557 # create an IO watcher for each and every socket 838 # create an I/O watcher for each and every socket
558 @snmp_watcher = ( 839 @snmp_watcher = (
559 (map { EV::io $_, EV::READ, sub { } } 840 (map { EV::io $_, EV::READ, sub { } }
560 keys %{ $dispatcher->{_descriptors} }), 841 keys %{ $dispatcher->{_descriptors} }),
561 842
562 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE] 843 EV::timer +($event->[Net::SNMP::Dispatcher::_ACTIVE]
583first). 864first).
584 865
585The C<check_ns> variant doesn't start (activate) the newly created watcher. 866The C<check_ns> variant doesn't start (activate) the newly created watcher.
586 867
587=back 868=back
869
870
871=head3 FORK WATCHERS - the audacity to resume the event loop after a fork
872
873Fork watchers are called when a C<fork ()> was detected. The invocation
874is done before the event loop blocks next and before C<check> watchers
875are being called, and only in the child after the fork.
876
877=over 4
878
879=item $w = EV::fork $callback
880
881=item $w = EV::fork_ns $callback
882
883=item $w = $loop->fork ($callback)
884
885=item $w = $loop->fork_ns ($callback)
886
887Call the callback before the event loop is resumed in the child process
888after a fork.
889
890The C<fork_ns> variant doesn't start (activate) the newly created watcher.
891
892=back
893
894
895=head1 PERL SIGNALS
896
897While Perl signal handling (C<%SIG>) is not affected by EV, the behaviour
898with EV is as the same as any other C library: Perl-signals will only be
899handled when Perl runs, which means your signal handler might be invoked
900only the next time an event callback is invoked.
901
902The solution is to use EV signal watchers (see C<EV::signal>), which will
903ensure proper operations with regards to other event watchers.
904
905If you cannot do this for whatever reason, you can also force a watcher
906to be called on every event loop iteration by installing a C<EV::check>
907watcher:
908
909 my $async_check = EV::check sub { };
910
911This ensures that perl gets into control for a short time to handle any
912pending signals, and also ensures (slightly) slower overall operation.
588 913
589=head1 THREADS 914=head1 THREADS
590 915
591Threads are not supported by this module in any way. Perl pseudo-threads 916Threads are not supported by this module in any way. Perl pseudo-threads
592is evil stuff and must die. As soon as Perl gains real threads I will work 917is evil stuff and must die. As soon as Perl gains real threads I will work
614our $DIED = sub { 939our $DIED = sub {
615 warn "EV: error in callback (ignoring): $@"; 940 warn "EV: error in callback (ignoring): $@";
616}; 941};
617 942
618default_loop 943default_loop
619 or die 'EV: cannot initialise libev backend. bad $ENV{LIBEV_METHODS}?'; 944 or die 'EV: cannot initialise libev backend. bad $ENV{LIBEV_FLAGS}?';
620 945
6211; 9461;
622 947
623=head1 SEE ALSO 948=head1 SEE ALSO
624 949
625 L<EV::DNS>. 950L<EV::ADNS> (asynchronous DNS), L<Glib::EV> (makes Glib/Gtk2 use EV as
951event loop), L<EV::Glib> (embed Glib into EV), L<Coro::EV> (efficient
952coroutines with EV), L<Net::SNMP::EV> (asynchronous SNMP).
626 953
627=head1 AUTHOR 954=head1 AUTHOR
628 955
629 Marc Lehmann <schmorp@schmorp.de> 956 Marc Lehmann <schmorp@schmorp.de>
630 http://home.schmorp.de/ 957 http://home.schmorp.de/

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines