ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev++.h
Revision: 1.30
Committed: Fri Jan 18 18:15:35 2008 UTC (16 years, 3 months ago) by llucax
Content type: text/plain
Branch: MAIN
Changes since 1.29: +111 -78 lines
Log Message:
Add exceptions support to C++ interface.

Add exception specification and a ev::bad_loop exception that is thrown
when a loop can't be initialized.

File Contents

# User Rev Content
1 root 1.21 /*
2     * libev simple C++ wrapper classes
3     *
4     * Copyright (c) 2007 Marc Alexander Lehmann <libev@schmorp.de>
5     * All rights reserved.
6     *
7     * Redistribution and use in source and binary forms, with or without modifica-
8     * tion, are permitted provided that the following conditions are met:
9     *
10     * 1. Redistributions of source code must retain the above copyright notice,
11     * this list of conditions and the following disclaimer.
12     *
13     * 2. Redistributions in binary form must reproduce the above copyright
14     * notice, this list of conditions and the following disclaimer in the
15     * documentation and/or other materials provided with the distribution.
16     *
17     * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
18     * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MER-
19     * CHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
20     * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPE-
21     * CIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
22     * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
23     * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
24     * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTH-
25     * ERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
26     * OF THE POSSIBILITY OF SUCH DAMAGE.
27     *
28     * Alternatively, the contents of this file may be used under the terms of
29     * the GNU General Public License ("GPL") version 2 or any later version,
30     * in which case the provisions of the GPL are applicable instead of
31     * the above. If you wish to allow the use of your version of this file
32     * only under the terms of the GPL and not to allow others to use your
33     * version of this file under the BSD license, indicate your decision
34     * by deleting the provisions above and replace them with the notice
35     * and other provisions required by the GPL. If you do not delete the
36     * provisions above, a recipient may use your version of this file under
37     * either the BSD or the GPL.
38     */
39    
40 root 1.1 #ifndef EVPP_H__
41     #define EVPP_H__
42    
43 root 1.20 #ifdef EV_H
44     # include EV_H
45     #else
46 root 1.22 # include "ev.h"
47 root 1.20 #endif
48 root 1.1
49 llucax 1.30 #ifndef EV_CXX_EXCEPTIONS
50     #define EV_CXX_EXCEPTIONS 1
51     #endif
52    
53     #undef EV_THROW
54     #if EV_CXX_EXCEPTIONS
55     # include <stdexcept>
56     # define EV_THROW(exception) throw (exception)
57     #else
58     # define EV_THROW(exception)
59     #endif
60    
61 root 1.1 namespace ev {
62    
63 llucax 1.24 typedef ev_tstamp tstamp;
64    
65     enum {
66     UNDEF = EV_UNDEF,
67     NONE = EV_NONE,
68     READ = EV_READ,
69     WRITE = EV_WRITE,
70     TIMEOUT = EV_TIMEOUT,
71     PERIODIC = EV_PERIODIC,
72     SIGNAL = EV_SIGNAL,
73     CHILD = EV_CHILD,
74     STAT = EV_STAT,
75     IDLE = EV_IDLE,
76     CHECK = EV_CHECK,
77     PREPARE = EV_PREPARE,
78     FORK = EV_FORK,
79     EMBED = EV_EMBED,
80     ERROR = EV_ERROR,
81     };
82    
83 llucax 1.25 enum
84     {
85     AUTO = EVFLAG_AUTO,
86     NOENV = EVFLAG_NOENV,
87     FORKCHECK = EVFLAG_FORKCHECK,
88     SELECT = EVBACKEND_SELECT,
89     POLL = EVBACKEND_POLL,
90     EPOLL = EVBACKEND_EPOLL,
91     KQUEUE = EVBACKEND_KQUEUE,
92     DEVPOLL = EVBACKEND_DEVPOLL,
93     PORT = EVBACKEND_PORT
94     };
95    
96     enum
97     {
98     NONBLOCK = EVLOOP_NONBLOCK,
99     ONESHOT = EVLOOP_ONESHOT
100     };
101    
102     enum how_t
103     {
104     ONE = EVUNLOOP_ONE,
105     ALL = EVUNLOOP_ALL
106     };
107    
108 llucax 1.30 #if EV_CXX_EXCEPTIONS
109     struct bad_loop: std::runtime_error
110     {
111     bad_loop()
112     : std::runtime_error("loop can't be initialized") {}
113     };
114     #endif
115    
116 llucax 1.28 #ifdef EV_AX
117     # undef EV_AX
118     #endif
119    
120     #ifdef EV_AX_
121     # undef EV_AX_
122     #endif
123    
124     #if EV_MULTIPLICITY
125     # define EV_AX raw_loop
126     # define EV_AX_ raw_loop,
127     #else
128     # define EV_AX
129     # define EV_AX_
130     #endif
131    
132     struct loop_ref
133     {
134    
135     loop_ref (EV_P)
136     #if EV_MULTIPLICITY
137 llucax 1.30 EV_THROW (bad_loop) : EV_AX (EV_A)
138 llucax 1.28 #endif
139     {
140 llucax 1.30 #if EV_MULTIPLICIY && EV_CXX_EXCEPTIONS
141     if (!EV_A)
142     throw bad_loop ();
143     #endif
144 llucax 1.28 }
145    
146 llucax 1.30 bool operator== (const loop_ref &other) const EV_THROW ()
147 llucax 1.28 {
148     #if EV_MULTIPLICITY
149     return this->EV_AX == other.EV_AX;
150     #else
151     return true;
152     #endif
153     }
154    
155 llucax 1.30 bool operator!= (const loop_ref &other) const EV_THROW ()
156 llucax 1.28 {
157     #if EV_MULTIPLICITY
158     return ! (*this == other);
159     #else
160     return false;
161     #endif
162     }
163    
164     #if EV_MULTIPLICITY
165 llucax 1.30 bool operator== (struct ev_loop *other) const EV_THROW ()
166 llucax 1.28 {
167     return this->EV_AX == other;
168     }
169    
170 llucax 1.30 bool operator!= (struct ev_loop *other) const EV_THROW ()
171 llucax 1.28 {
172     return ! (*this == other);
173     }
174    
175 llucax 1.30 bool operator== (const struct ev_loop *other) const EV_THROW ()
176 llucax 1.28 {
177     return this->EV_AX == other;
178     }
179    
180 llucax 1.30 bool operator!= (const struct ev_loop *other) const EV_THROW ()
181 llucax 1.28 {
182     return (*this == other);
183     }
184    
185 llucax 1.30 operator struct ev_loop * () const EV_THROW ()
186 llucax 1.28 {
187     return EV_AX;
188     }
189    
190 llucax 1.30 operator const struct ev_loop * () const EV_THROW ()
191 llucax 1.28 {
192     return EV_AX;
193     }
194    
195 llucax 1.30 bool is_default () const EV_THROW ()
196 llucax 1.28 {
197     return EV_AX == ev_default_loop (0);
198     }
199     #endif
200    
201     void loop (int flags = 0)
202     {
203     ev_loop (EV_AX_ flags);
204     }
205    
206 llucax 1.30 void unloop (how_t how = ONE) EV_THROW ()
207 llucax 1.28 {
208     ev_unloop (EV_AX_ how);
209     }
210    
211 llucax 1.30 void post_fork () EV_THROW ()
212 llucax 1.28 {
213     #if EV_MULTIPLICITY
214     ev_loop_fork (EV_AX);
215     #else
216     ev_default_fork ();
217     #endif
218     }
219    
220 llucax 1.30 unsigned int count () const EV_THROW ()
221 llucax 1.28 {
222     return ev_loop_count (EV_AX);
223     }
224    
225 llucax 1.30 unsigned int backend () const EV_THROW ()
226 llucax 1.28 {
227     return ev_backend (EV_AX);
228     }
229    
230 llucax 1.30 tstamp now () const EV_THROW ()
231 llucax 1.28 {
232     return ev_now (EV_AX);
233     }
234    
235 llucax 1.30 void ref () EV_THROW ()
236 llucax 1.28 {
237     ev_ref (EV_AX);
238     }
239    
240 llucax 1.30 void unref () EV_THROW ()
241 llucax 1.28 {
242     ev_unref (EV_AX);
243     }
244    
245 llucax 1.30 void set_io_collect_interval (tstamp interval) EV_THROW ()
246 llucax 1.28 {
247     ev_set_io_collect_interval (EV_AX_ interval);
248     }
249    
250 llucax 1.30 void set_timeout_collect_interval (tstamp interval) EV_THROW ()
251 llucax 1.28 {
252     ev_set_timeout_collect_interval (EV_AX_ interval);
253     }
254    
255     // function callback
256 llucax 1.30 void once (int fd, int events, tstamp timeout, void (*cb)(int, void *), void* arg = 0) EV_THROW ()
257 llucax 1.28 {
258     ev_once (EV_AX_ fd, events, timeout, cb, arg);
259     }
260    
261     // method callback
262     template<class K, void (K::*method)(int)>
263 llucax 1.30 void once (int fd, int events, tstamp timeout, K *object) EV_THROW ()
264 llucax 1.28 {
265     once (fd, events, timeout, method_thunk<K, method>, object);
266     }
267    
268     template<class K, void (K::*method)(int)>
269     static void method_thunk (int revents, void* arg)
270     {
271     K *obj = static_cast<K *>(arg);
272     (obj->*method) (revents);
273     }
274    
275     // const method callback
276     template<class K, void (K::*method)(int) const>
277 llucax 1.30 void once (int fd, int events, tstamp timeout, const K *object) EV_THROW ()
278 llucax 1.28 {
279     once (fd, events, timeout, const_method_thunk<K, method>, object);
280     }
281    
282     template<class K, void (K::*method)(int) const>
283     static void const_method_thunk (int revents, void* arg)
284     {
285     K *obj = static_cast<K *>(arg);
286     (obj->*method) (revents);
287     }
288    
289     // simple method callback
290     template<class K, void (K::*method)()>
291 llucax 1.30 void once (int fd, int events, tstamp timeout, K *object) EV_THROW ()
292 llucax 1.28 {
293     once (fd, events, timeout, method_noargs_thunk<K, method>, object);
294     }
295    
296     template<class K, void (K::*method)()>
297     static void method_noargs_thunk (int revents, void* arg)
298     {
299     K *obj = static_cast<K *>(arg);
300     (obj->*method) ();
301     }
302    
303     // simpler function callback
304     template<void (*cb)(int)>
305 llucax 1.30 void once (int fd, int events, tstamp timeout) EV_THROW ()
306 llucax 1.28 {
307     once (fd, events, timeout, simpler_func_thunk<cb>);
308     }
309    
310     template<void (*cb)(int)>
311     static void simpler_func_thunk (int revents, void* arg)
312     {
313     (*cb) (revents);
314     }
315    
316     // simplest function callback
317     template<void (*cb)()>
318 llucax 1.30 void once (int fd, int events, tstamp timeout) EV_THROW ()
319 llucax 1.28 {
320     once (fd, events, timeout, simplest_func_thunk<cb>);
321     }
322    
323     template<void (*cb)()>
324     static void simplest_func_thunk (int revents, void* arg)
325     {
326     (*cb) ();
327     }
328    
329 llucax 1.30 void feed_fd_event (int fd, int revents) EV_THROW ()
330 llucax 1.28 {
331     ev_feed_fd_event (EV_AX_ fd, revents);
332     }
333    
334 llucax 1.30 void feed_signal_event (int signum) EV_THROW ()
335 llucax 1.28 {
336     ev_feed_signal_event (EV_AX_ signum);
337     }
338    
339     #if EV_MULTIPLICITY
340     struct ev_loop* EV_AX;
341     #endif
342    
343     };
344    
345     #if EV_MULTIPLICITY
346     struct dynamic_loop: loop_ref
347     {
348    
349 llucax 1.30 dynamic_loop (unsigned int flags = AUTO) EV_THROW (bad_loop)
350 llucax 1.28 : loop_ref (ev_loop_new (flags))
351     {
352     }
353    
354 llucax 1.30 ~dynamic_loop () EV_THROW ()
355 llucax 1.28 {
356     ev_loop_destroy (EV_AX);
357     EV_AX = 0;
358     }
359    
360     private:
361    
362     dynamic_loop (const dynamic_loop &);
363    
364     dynamic_loop & operator= (const dynamic_loop &);
365    
366     };
367     #endif
368    
369     struct default_loop: loop_ref
370     {
371    
372 llucax 1.30 default_loop (unsigned int flags = AUTO) EV_THROW (bad_loop)
373 llucax 1.28 #if EV_MULTIPLICITY
374     : loop_ref (ev_default_loop (flags))
375     {
376     }
377     #else
378     {
379 llucax 1.30 #if EV_CXX_EXCEPTIONS
380     int r =
381     #endif
382     ev_default_loop (flags);
383     #if EV_CXX_EXCEPTIONS
384     if (!r)
385     throw bad_loop ();
386     #endif
387 llucax 1.28 }
388     #endif
389    
390 llucax 1.30 ~default_loop () EV_THROW ()
391 llucax 1.28 {
392     ev_default_destroy ();
393     #if EV_MULTIPLICITY
394     EV_AX = 0;
395     #endif
396     }
397    
398     private:
399    
400     default_loop (const default_loop &);
401    
402     default_loop & operator= (const default_loop &);
403    
404     };
405    
406 llucax 1.30 inline loop_ref get_default_loop () EV_THROW ()
407 llucax 1.28 {
408     #if EV_MULTIPLICITY
409     return ev_default_loop (0);
410     #else
411     return loop_ref ();
412     #endif
413     }
414    
415     #undef EV_AX
416     #undef EV_AX_
417    
418     #undef EV_PX
419     #undef EV_PX_
420     #if EV_MULTIPLICITY
421     # define EV_PX loop_ref EV_A
422     # define EV_PX_ loop_ref EV_A_
423     #else
424     # define EV_PX
425     # define EV_PX_
426     #endif
427    
428 root 1.13 template<class ev_watcher, class watcher>
429     struct base : ev_watcher
430 root 1.1 {
431 root 1.13 #if EV_MULTIPLICITY
432 llucax 1.28 EV_PX;
433 root 1.1
434 llucax 1.30 void set (EV_PX) EV_THROW ()
435 root 1.13 {
436     this->EV_A = EV_A;
437     }
438     #endif
439 root 1.1
440 llucax 1.30 base (EV_PX) EV_THROW ()
441 llucax 1.28 #if EV_MULTIPLICITY
442     : EV_A (EV_A)
443     #endif
444 root 1.13 {
445     ev_init (this, 0);
446     }
447    
448 llucax 1.30 void set_ (void *data, void (*cb)(EV_P_ ev_watcher *w, int revents)) EV_THROW ()
449 root 1.13 {
450 root 1.17 this->data = data;
451 root 1.18 ev_set_cb (static_cast<ev_watcher *>(this), cb);
452 root 1.13 }
453    
454 root 1.19 // method callback
455 root 1.13 template<class K, void (K::*method)(watcher &w, int)>
456 llucax 1.30 void set (K *object) EV_THROW ()
457 root 1.13 {
458     set_ (object, method_thunk<K, method>);
459     }
460    
461     template<class K, void (K::*method)(watcher &w, int)>
462 root 1.18 static void method_thunk (EV_P_ ev_watcher *w, int revents)
463 root 1.13 {
464 root 1.17 K *obj = static_cast<K *>(w->data);
465 root 1.18 (obj->*method) (*static_cast<watcher *>(w), revents);
466 root 1.13 }
467    
468 root 1.19 // const method callback
469 root 1.13 template<class K, void (K::*method)(watcher &w, int) const>
470 llucax 1.30 void set (const K *object) EV_THROW ()
471 root 1.13 {
472     set_ (object, const_method_thunk<K, method>);
473     }
474    
475     template<class K, void (K::*method)(watcher &w, int) const>
476 root 1.18 static void const_method_thunk (EV_P_ ev_watcher *w, int revents)
477 root 1.13 {
478 root 1.17 K *obj = static_cast<K *>(w->data);
479 root 1.18 (static_cast<K *>(w->data)->*method) (*static_cast<watcher *>(w), revents);
480 root 1.13 }
481    
482 root 1.19 // function callback
483 root 1.17 template<void (*function)(watcher &w, int)>
484 llucax 1.30 void set (void *data = 0) EV_THROW ()
485 root 1.13 {
486 root 1.16 set_ (data, function_thunk<function>);
487 root 1.13 }
488    
489     template<void (*function)(watcher &w, int)>
490 root 1.18 static void function_thunk (EV_P_ ev_watcher *w, int revents)
491 root 1.13 {
492 root 1.18 function (*static_cast<watcher *>(w), revents);
493 root 1.13 }
494    
495 root 1.19 // simple callback
496     template<class K, void (K::*method)()>
497 llucax 1.30 void set (K *object) EV_THROW ()
498 root 1.19 {
499     set_ (object, method_noargs_thunk<K, method>);
500     }
501    
502     template<class K, void (K::*method)()>
503     static void method_noargs_thunk (EV_P_ ev_watcher *w, int revents)
504     {
505     K *obj = static_cast<K *>(w->data);
506     (obj->*method) ();
507     }
508    
509 root 1.13 void operator ()(int events = EV_UNDEF)
510     {
511 root 1.14 return ev_cb (static_cast<ev_watcher *>(this))
512     (static_cast<ev_watcher *>(this), events);
513 root 1.13 }
514    
515 llucax 1.30 bool is_active () const EV_THROW ()
516 root 1.1 {
517 root 1.13 return ev_is_active (static_cast<const ev_watcher *>(this));
518 root 1.1 }
519    
520 llucax 1.30 bool is_pending () const EV_THROW ()
521 root 1.1 {
522 root 1.13 return ev_is_pending (static_cast<const ev_watcher *>(this));
523 root 1.1 }
524 llucax 1.27
525 llucax 1.30 void feed_event (int revents) EV_THROW ()
526 llucax 1.27 {
527     ev_feed_event (EV_A_ static_cast<const ev_watcher *>(this), revents);
528     }
529 root 1.1 };
530    
531 llucax 1.30 inline tstamp now () EV_THROW ()
532 llucax 1.29 {
533     return ev_time ();
534     }
535    
536 llucax 1.30 inline void delay (tstamp interval) EV_THROW ()
537 llucax 1.26 {
538     ev_sleep (interval);
539     }
540    
541 llucax 1.30 inline int version_major () EV_THROW ()
542 llucax 1.26 {
543     return ev_version_major ();
544     }
545    
546 llucax 1.30 inline int version_minor () EV_THROW ()
547 llucax 1.26 {
548     return ev_version_minor ();
549     }
550    
551 llucax 1.30 inline unsigned int supported_backends () EV_THROW ()
552 llucax 1.26 {
553     return ev_supported_backends ();
554     }
555    
556 llucax 1.30 inline unsigned int recommended_backends () EV_THROW ()
557 llucax 1.26 {
558     return ev_recommended_backends ();
559     }
560    
561 llucax 1.30 inline unsigned int embeddable_backends () EV_THROW ()
562 llucax 1.26 {
563     return ev_embeddable_backends ();
564     }
565    
566 llucax 1.30 inline void set_allocator (void *(*cb)(void *ptr, long size)) EV_THROW ()
567 llucax 1.26 {
568     ev_set_allocator (cb);
569     }
570    
571 llucax 1.30 inline void set_syserr_cb (void (*cb)(const char *msg)) EV_THROW ()
572 llucax 1.26 {
573     ev_set_syserr_cb (cb);
574     }
575    
576 root 1.1 #if EV_MULTIPLICITY
577 llucax 1.28 #define EV_CONSTRUCT(cppstem,cstem) \
578 llucax 1.30 (EV_PX = get_default_loop ()) EV_THROW () \
579 llucax 1.28 : base<ev_ ## cstem, cppstem> (EV_A) \
580 root 1.1 { \
581 root 1.13 }
582 root 1.1 #else
583 llucax 1.28 #define EV_CONSTRUCT(cppstem,cstem) \
584 llucax 1.30 () EV_THROW () \
585 root 1.13 { \
586     }
587 root 1.1 #endif
588    
589     /* using a template here would require quite a bit more lines,
590     * so a macro solution was chosen */
591 root 1.4 #define EV_BEGIN_WATCHER(cppstem,cstem) \
592 root 1.1 \
593 root 1.13 struct cppstem : base<ev_ ## cstem, cppstem> \
594 root 1.1 { \
595 llucax 1.30 void start () EV_THROW () \
596 root 1.1 { \
597     ev_ ## cstem ## _start (EV_A_ static_cast<ev_ ## cstem *>(this)); \
598     } \
599     \
600 llucax 1.30 void stop () EV_THROW () \
601 root 1.1 { \
602     ev_ ## cstem ## _stop (EV_A_ static_cast<ev_ ## cstem *>(this)); \
603     } \
604     \
605 llucax 1.28 cppstem EV_CONSTRUCT(cppstem,cstem) \
606 root 1.1 \
607 llucax 1.30 ~cppstem () EV_THROW () \
608 root 1.3 { \
609     stop (); \
610     } \
611     \
612 root 1.13 using base<ev_ ## cstem, cppstem>::set; \
613     \
614 root 1.1 private: \
615     \
616 llucax 1.23 cppstem (const cppstem &o); \
617 root 1.6 \
618 llucax 1.23 cppstem & operator =(const cppstem &o); \
619 root 1.1 \
620     public:
621    
622 root 1.4 #define EV_END_WATCHER(cppstem,cstem) \
623 root 1.6 };
624 root 1.4
625     EV_BEGIN_WATCHER (io, io)
626 llucax 1.30 void set (int fd, int events) EV_THROW ()
627 root 1.1 {
628     int active = is_active ();
629     if (active) stop ();
630     ev_io_set (static_cast<ev_io *>(this), fd, events);
631     if (active) start ();
632     }
633    
634 llucax 1.30 void set (int events) EV_THROW ()
635 root 1.1 {
636     int active = is_active ();
637     if (active) stop ();
638     ev_io_set (static_cast<ev_io *>(this), fd, events);
639     if (active) start ();
640     }
641    
642 llucax 1.30 void start (int fd, int events) EV_THROW ()
643 root 1.1 {
644     set (fd, events);
645     start ();
646     }
647 root 1.4 EV_END_WATCHER (io, io)
648 root 1.1
649 root 1.4 EV_BEGIN_WATCHER (timer, timer)
650 llucax 1.30 void set (ev_tstamp after, ev_tstamp repeat = 0.) EV_THROW ()
651 root 1.1 {
652     int active = is_active ();
653     if (active) stop ();
654     ev_timer_set (static_cast<ev_timer *>(this), after, repeat);
655     if (active) start ();
656     }
657    
658 llucax 1.30 void start (ev_tstamp after, ev_tstamp repeat = 0.) EV_THROW ()
659 root 1.1 {
660     set (after, repeat);
661     start ();
662     }
663    
664 llucax 1.30 void again () EV_THROW ()
665 root 1.1 {
666     ev_timer_again (EV_A_ static_cast<ev_timer *>(this));
667     }
668 root 1.4 EV_END_WATCHER (timer, timer)
669 root 1.1
670 root 1.8 #if EV_PERIODIC_ENABLE
671 root 1.4 EV_BEGIN_WATCHER (periodic, periodic)
672 llucax 1.30 void set (ev_tstamp at, ev_tstamp interval = 0.) EV_THROW ()
673 root 1.1 {
674     int active = is_active ();
675     if (active) stop ();
676     ev_periodic_set (static_cast<ev_periodic *>(this), at, interval, 0);
677     if (active) start ();
678     }
679    
680 llucax 1.30 void start (ev_tstamp at, ev_tstamp interval = 0.) EV_THROW ()
681 root 1.1 {
682     set (at, interval);
683     start ();
684     }
685    
686 llucax 1.30 void again () EV_THROW ()
687 root 1.1 {
688     ev_periodic_again (EV_A_ static_cast<ev_periodic *>(this));
689     }
690 root 1.4 EV_END_WATCHER (periodic, periodic)
691 root 1.3 #endif
692 root 1.1
693 root 1.4 EV_BEGIN_WATCHER (sig, signal)
694 llucax 1.30 void set (int signum) EV_THROW ()
695 root 1.1 {
696     int active = is_active ();
697     if (active) stop ();
698     ev_signal_set (static_cast<ev_signal *>(this), signum);
699     if (active) start ();
700     }
701    
702 llucax 1.30 void start (int signum) EV_THROW ()
703 root 1.1 {
704     set (signum);
705     start ();
706     }
707 root 1.4 EV_END_WATCHER (sig, signal)
708 root 1.1
709 root 1.4 EV_BEGIN_WATCHER (child, child)
710 llucax 1.30 void set (int pid) EV_THROW ()
711 root 1.1 {
712     int active = is_active ();
713     if (active) stop ();
714     ev_child_set (static_cast<ev_child *>(this), pid);
715     if (active) start ();
716     }
717    
718 llucax 1.30 void start (int pid) EV_THROW ()
719 root 1.1 {
720     set (pid);
721     start ();
722     }
723 root 1.4 EV_END_WATCHER (child, child)
724 root 1.1
725 root 1.8 #if EV_STAT_ENABLE
726     EV_BEGIN_WATCHER (stat, stat)
727 llucax 1.30 void set (const char *path, ev_tstamp interval = 0.) EV_THROW ()
728 root 1.8 {
729     int active = is_active ();
730     if (active) stop ();
731     ev_stat_set (static_cast<ev_stat *>(this), path, interval);
732     if (active) start ();
733     }
734    
735 llucax 1.30 void start (const char *path, ev_tstamp interval = 0.) EV_THROW ()
736 root 1.8 {
737 root 1.12 stop ();
738 root 1.8 set (path, interval);
739     start ();
740     }
741    
742 llucax 1.30 void update () EV_THROW ()
743 root 1.8 {
744     ev_stat_stat (EV_A_ static_cast<ev_stat *>(this));
745     }
746     EV_END_WATCHER (stat, stat)
747     #endif
748    
749     EV_BEGIN_WATCHER (idle, idle)
750 llucax 1.30 void set () EV_THROW () { }
751 root 1.8 EV_END_WATCHER (idle, idle)
752 root 1.7
753 root 1.8 EV_BEGIN_WATCHER (prepare, prepare)
754 llucax 1.30 void set () EV_THROW () { }
755 root 1.8 EV_END_WATCHER (prepare, prepare)
756    
757     EV_BEGIN_WATCHER (check, check)
758 llucax 1.30 void set () EV_THROW () { }
759 root 1.8 EV_END_WATCHER (check, check)
760    
761     #if EV_EMBED_ENABLE
762 root 1.7 EV_BEGIN_WATCHER (embed, embed)
763 llucax 1.30 void start (struct ev_loop *embedded_loop) EV_THROW ()
764 root 1.7 {
765 root 1.12 stop ();
766     ev_embed_set (static_cast<ev_embed *>(this), embedded_loop);
767 root 1.7 start ();
768     }
769    
770     void sweep ()
771     {
772     ev_embed_sweep (EV_A_ static_cast<ev_embed *>(this));
773     }
774     EV_END_WATCHER (embed, embed)
775     #endif
776    
777 root 1.10 #if EV_FORK_ENABLE
778     EV_BEGIN_WATCHER (fork, fork)
779 llucax 1.30 void set () EV_THROW () { }
780 root 1.10 EV_END_WATCHER (fork, fork)
781     #endif
782    
783 llucax 1.28 #undef EV_PX
784     #undef EV_PX_
785 root 1.1 #undef EV_CONSTRUCT
786 root 1.4 #undef EV_BEGIN_WATCHER
787 root 1.7 #undef EV_END_WATCHER
788 llucax 1.28
789 root 1.1 }
790    
791 llucax 1.30 #undef EV_THROW
792    
793 root 1.1 #endif
794