ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/EV/EV.xs
Revision: 1.164
Committed: Fri Apr 5 21:04:18 2013 UTC (11 years, 1 month ago) by root
Branch: MAIN
Changes since 1.163: +55 -41 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 root 1.1 #include "EXTERN.h"
2     #include "perl.h"
3     #include "XSUB.h"
4    
5 root 1.108 /* fix perl api breakage */
6     #undef signal
7     #undef sigaction
8    
9 root 1.126 #include "schmorp.h"
10    
11 root 1.127 /* old API compatibility */
12     static int
13     sv_fileno (SV *fh)
14     {
15     return s_fileno (fh, 0);
16     }
17    
18 root 1.163 #ifndef GvCV_set
19     # define GvCV_set(gv,cv) GvCV (gv) = cv
20     #endif
21    
22 root 1.136 #define EV_STANDALONE 1
23 root 1.20 #define EV_PROTOTYPES 1
24 root 1.101 #define EV_USE_NANOSLEEP EV_USE_MONOTONIC
25 root 1.155 #define EV_USE_FLOOR 1
26 root 1.158 #define EV_API_STATIC
27 root 1.92 #define EV_H <ev.h>
28 root 1.136 #define EV_CONFIG_H error
29 root 1.11 #include "EV/EVAPI.h"
30    
31 root 1.64 #define EV_SELECT_IS_WINSOCKET 0
32     #ifdef _WIN32
33     # define EV_SELECT_USE_FD_SET 0
34     # define NFDBITS PERL_NFDBITS
35     # define fd_mask Perl_fd_mask
36     #endif
37 root 1.53 /* due to bugs in OS X we have to use libev/ explicitly here */
38     #include "libev/ev.c"
39 root 1.56
40 root 1.159 #if !defined _WIN32 && !defined _MINIX
41 root 1.55 # include <pthread.h>
42     #endif
43    
44 root 1.138 #define e_loop(w) INT2PTR (struct ev_loop *, SvIVX (((ev_watcher *)(w))->loop))
45     #define e_flags(w) ((ev_watcher *)(w))->e_flags
46     #define e_self(w) ((ev_watcher *)(w))->self
47     #define e_fh(w) ((ev_watcher *)(w))->fh
48     #define e_data(w) ((ev_watcher *)(w))->data
49 root 1.93
50 root 1.78 #define WFLAG_KEEPALIVE 1
51 root 1.121 #define WFLAG_UNREFED 2 /* has been unref'ed */
52 root 1.164 #define WFLAG_NOARGS 4 /* do not pass anything to the callback */
53 root 1.78
54     #define UNREF(w) \
55 root 1.138 if (!(e_flags (w) & (WFLAG_KEEPALIVE | WFLAG_UNREFED)) \
56 root 1.121 && ev_is_active (w)) \
57     { \
58     ev_unref (e_loop (w)); \
59 root 1.138 e_flags (w) |= WFLAG_UNREFED; \
60 root 1.121 }
61 root 1.78
62     #define REF(w) \
63 root 1.138 if (e_flags (w) & WFLAG_UNREFED) \
64 root 1.121 { \
65 root 1.138 e_flags (w) &= ~WFLAG_UNREFED; \
66 root 1.121 ev_ref (e_loop (w)); \
67     }
68 root 1.78
69     #define START(type,w) \
70     do { \
71 root 1.121 ev_ ## type ## _start (e_loop (w), w); \
72 root 1.78 UNREF (w); \
73     } while (0)
74    
75     #define STOP(type,w) \
76     do { \
77     REF (w); \
78 root 1.103 ev_ ## type ## _stop (e_loop (w), w); \
79 root 1.78 } while (0)
80    
81 root 1.80 #define RESET(type,w,seta) \
82 root 1.132 do { \
83     int active = ev_is_active (w); \
84     if (active) STOP (type, w); \
85     ev_ ## type ## _set seta; \
86     if (active) START (type, w); \
87     } while (0)
88 root 1.80
89 root 1.10 typedef int Signal;
90 root 1.1
91 root 1.132 /* horrible... */
92     #define CHECK_SIGNAL_CAN_START(w) \
93     do { \
94     /* dive into the internals of libev to avoid aborting in libev */ \
95     if (signals [(w)->signum - 1].loop \
96     && signals [(w)->signum - 1].loop != e_loop (w)) \
97     croak ("unable to start signal watcher, signal %d already registered in another loop", w->signum); \
98     } while (0)
99    
100     #define START_SIGNAL(w) \
101     do { \
102     CHECK_SIGNAL_CAN_START (w); \
103     START (signal, w); \
104     } while (0) \
105    
106     #define RESET_SIGNAL(w,seta) \
107     do { \
108     int active = ev_is_active (w); \
109     if (active) STOP (signal, w); \
110     ev_ ## signal ## _set seta; \
111     if (active) START_SIGNAL (w); \
112     } while (0)
113    
114 root 1.93 static SV *default_loop_sv;
115    
116 root 1.11 static struct EVAPI evapi;
117    
118 root 1.15 static HV
119 root 1.93 *stash_loop,
120 root 1.15 *stash_watcher,
121     *stash_io,
122     *stash_timer,
123     *stash_periodic,
124     *stash_signal,
125 root 1.81 *stash_child,
126     *stash_stat,
127 root 1.15 *stash_idle,
128 root 1.22 *stash_prepare,
129 root 1.23 *stash_check,
130 root 1.80 *stash_embed,
131 root 1.106 *stash_fork,
132 root 1.145 *stash_cleanup,
133 root 1.106 *stash_async;
134 root 1.1
135     /////////////////////////////////////////////////////////////////////////////
136     // Event
137    
138 root 1.91 static void e_cb (EV_P_ ev_watcher *w, int revents);
139 root 1.1
140 root 1.156 static void *
141 root 1.93 e_new (int size, SV *cb_sv, SV *loop)
142 root 1.1 {
143 root 1.126 SV *cv = cb_sv ? s_get_cv_croak (cb_sv) : 0;
144 root 1.78 ev_watcher *w;
145 root 1.15 SV *self = NEWSV (0, size);
146 root 1.1 SvPOK_only (self);
147 root 1.15 SvCUR_set (self, size);
148 root 1.1
149 root 1.78 w = (ev_watcher *)SvPVX (self);
150 root 1.1
151 root 1.114 ev_init (w, cv ? e_cb : 0);
152 root 1.1
153 root 1.104 w->loop = SvREFCNT_inc (SvRV (loop));
154     w->e_flags = WFLAG_KEEPALIVE;
155     w->data = 0;
156     w->fh = 0;
157 root 1.112 w->cb_sv = SvREFCNT_inc (cv);
158 root 1.104 w->self = self;
159 root 1.1
160 root 1.15 return (void *)w;
161 root 1.1 }
162    
163 root 1.56 static void
164 root 1.34 e_destroy (void *w_)
165     {
166 root 1.78 ev_watcher *w = (ev_watcher *)w_;
167 root 1.34
168 root 1.93 SvREFCNT_dec (w->loop ); w->loop = 0;
169 root 1.34 SvREFCNT_dec (w->fh ); w->fh = 0;
170     SvREFCNT_dec (w->cb_sv); w->cb_sv = 0;
171 root 1.60 SvREFCNT_dec (w->data ); w->data = 0;
172 root 1.34 }
173    
174 root 1.15 static SV *
175 root 1.78 e_bless (ev_watcher *w, HV *stash)
176 root 1.1 {
177     SV *rv;
178    
179 root 1.15 if (SvOBJECT (w->self))
180     rv = newRV_inc (w->self);
181 root 1.1 else
182     {
183 root 1.15 rv = newRV_noinc (w->self);
184     sv_bless (rv, stash);
185     SvREADONLY_on (w->self);
186 root 1.1 }
187    
188     return rv;
189     }
190    
191 root 1.116 static SV *sv_self_cache, *sv_events_cache;
192 root 1.75
193 root 1.1 static void
194 root 1.91 e_cb (EV_P_ ev_watcher *w, int revents)
195 root 1.1 {
196     dSP;
197 root 1.14 I32 mark = SP - PL_stack_base;
198 root 1.75 SV *sv_self, *sv_events;
199 root 1.1
200 root 1.121 /* libev might have stopped the watcher */
201     if (expect_false (w->e_flags & WFLAG_UNREFED)
202     && !ev_is_active (w))
203     REF (w);
204    
205 root 1.164 PUSHMARK (SP);
206    
207     if (!expect_true (e_flags (w) & WFLAG_NOARGS))
208 root 1.116 {
209 root 1.164 if (expect_true (sv_self_cache))
210     {
211     sv_self = sv_self_cache; sv_self_cache = 0;
212     SvRV_set (sv_self, SvREFCNT_inc_NN (w->self));
213     }
214     else
215     {
216     sv_self = newRV_inc (w->self); /* e_self (w) MUST be blessed by now */
217     SvREADONLY_on (sv_self);
218     }
219    
220     if (expect_true (sv_events_cache))
221     {
222     sv_events = sv_events_cache; sv_events_cache = 0;
223     SvIV_set (sv_events, revents);
224     SvIOK_only (sv_events);
225     }
226     else
227     {
228     sv_events = newSViv (revents);
229     SvREADONLY_on (sv_events);
230     }
231    
232     EXTEND (SP, 2);
233     PUSHs (sv_self);
234     PUSHs (sv_events);
235    
236     PUTBACK;
237     call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
238 root 1.14
239 root 1.164 if (expect_false (SvREFCNT (sv_self) != 1 || sv_self_cache))
240     SvREFCNT_dec (sv_self);
241     else
242     {
243     SvREFCNT_dec (SvRV (sv_self));
244     SvRV_set (sv_self, &PL_sv_undef);
245     sv_self_cache = sv_self;
246     }
247    
248     if (expect_false (SvREFCNT (sv_events) != 1 || sv_events_cache))
249     SvREFCNT_dec (sv_events);
250     else
251     sv_events_cache = sv_events;
252 root 1.14 }
253     else
254 root 1.116 {
255 root 1.164 EXTEND (SP, 2);
256     PUSHs (sv_self);
257     PUSHs (sv_events);
258 root 1.14
259 root 1.164 PUTBACK;
260     call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
261 root 1.116 }
262 root 1.75
263 root 1.119 if (expect_false (SvTRUE (ERRSV)))
264 root 1.75 {
265 root 1.84 SPAGAIN;
266 root 1.75 PUSHMARK (SP);
267     PUTBACK;
268     call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
269     }
270    
271     SP = PL_stack_base + mark;
272     PUTBACK;
273     }
274    
275     static void
276     e_once_cb (int revents, void *arg)
277     {
278     dSP;
279     I32 mark = SP - PL_stack_base;
280     SV *sv_events;
281    
282     if (sv_events_cache)
283     {
284     sv_events = sv_events_cache; sv_events_cache = 0;
285     SvIV_set (sv_events, revents);
286     }
287     else
288     sv_events = newSViv (revents);
289    
290     PUSHMARK (SP);
291     XPUSHs (sv_events);
292    
293     PUTBACK;
294     call_sv ((SV *)arg, G_DISCARD | G_VOID | G_EVAL);
295    
296     SvREFCNT_dec ((SV *)arg);
297 root 1.14
298     if (sv_events_cache)
299     SvREFCNT_dec (sv_events);
300     else
301     sv_events_cache = sv_events;
302 root 1.1
303 root 1.8 if (SvTRUE (ERRSV))
304     {
305 root 1.86 SPAGAIN;
306 root 1.8 PUSHMARK (SP);
307     PUTBACK;
308     call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
309     }
310 root 1.68
311     SP = PL_stack_base + mark;
312     PUTBACK;
313 root 1.1 }
314    
315 root 1.59 static ev_tstamp
316 root 1.78 e_periodic_cb (ev_periodic *w, ev_tstamp now)
317 root 1.59 {
318     ev_tstamp retval;
319     int count;
320     dSP;
321    
322     ENTER;
323     SAVETMPS;
324    
325     PUSHMARK (SP);
326     EXTEND (SP, 2);
327 root 1.138 PUSHs (newRV_inc (e_self (w))); /* e_self (w) MUST be blessed by now */
328 root 1.59 PUSHs (newSVnv (now));
329    
330     PUTBACK;
331     count = call_sv (w->fh, G_SCALAR | G_EVAL);
332     SPAGAIN;
333    
334     if (SvTRUE (ERRSV))
335     {
336     PUSHMARK (SP);
337     PUTBACK;
338     call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
339     SPAGAIN;
340     }
341    
342     if (count > 0)
343     {
344     retval = SvNV (TOPs);
345    
346     if (retval < now)
347     retval = now;
348     }
349     else
350     retval = now;
351    
352     FREETMPS;
353     LEAVE;
354    
355     return retval;
356     }
357    
358 root 1.18 #define CHECK_REPEAT(repeat) if (repeat < 0.) \
359     croak (# repeat " value must be >= 0");
360    
361 root 1.31 #define CHECK_FD(fh,fd) if ((fd) < 0) \
362     croak ("illegal file descriptor or filehandle (either no attached file descriptor or illegal value): %s", SvPV_nolen (fh));
363    
364 root 1.80 #define CHECK_SIG(sv,num) if ((num) < 0) \
365     croak ("illegal signal number or name: %s", SvPV_nolen (sv));
366    
367 root 1.148 static void
368     default_fork (void)
369 root 1.147 {
370     ev_loop_fork (EV_DEFAULT_UC);
371     }
372    
373 root 1.1 /////////////////////////////////////////////////////////////////////////////
374     // XS interface functions
375    
376 root 1.15 MODULE = EV PACKAGE = EV PREFIX = ev_
377 root 1.1
378 root 1.21 PROTOTYPES: ENABLE
379    
380 root 1.1 BOOT:
381     {
382     HV *stash = gv_stashpv ("EV", 1);
383    
384     static const struct {
385     const char *name;
386     IV iv;
387     } *civ, const_iv[] = {
388     # define const_iv(pfx, name) { # name, (IV) pfx ## name },
389 root 1.41 const_iv (EV_, MINPRI)
390     const_iv (EV_, MAXPRI)
391    
392 root 1.20 const_iv (EV_, UNDEF)
393 root 1.1 const_iv (EV_, NONE)
394     const_iv (EV_, READ)
395     const_iv (EV_, WRITE)
396 root 1.123 const_iv (EV_, IO)
397 root 1.147 const_iv (EV_, TIMER)
398 root 1.123 const_iv (EV_, PERIODIC)
399 root 1.1 const_iv (EV_, SIGNAL)
400 root 1.123 const_iv (EV_, CHILD)
401     const_iv (EV_, STAT)
402 root 1.15 const_iv (EV_, IDLE)
403 root 1.123 const_iv (EV_, PREPARE)
404 root 1.163 /*const_iv (EV_, CHECK) needs special tretament */
405 root 1.123 const_iv (EV_, EMBED)
406     const_iv (EV_, FORK)
407 root 1.145 const_iv (EV_, CLEANUP)
408 root 1.123 const_iv (EV_, ASYNC)
409     const_iv (EV_, CUSTOM)
410 root 1.20 const_iv (EV_, ERROR)
411 root 1.15
412 root 1.142 const_iv (EV, RUN_NOWAIT)
413     const_iv (EV, RUN_ONCE)
414 root 1.15
415 root 1.142 const_iv (EV, BREAK_CANCEL)
416     const_iv (EV, BREAK_ONE)
417     const_iv (EV, BREAK_ALL)
418 root 1.73 const_iv (EV, BACKEND_SELECT)
419     const_iv (EV, BACKEND_POLL)
420     const_iv (EV, BACKEND_EPOLL)
421     const_iv (EV, BACKEND_KQUEUE)
422     const_iv (EV, BACKEND_DEVPOLL)
423     const_iv (EV, BACKEND_PORT)
424 root 1.134 const_iv (EV, BACKEND_ALL)
425 root 1.153 const_iv (EV, BACKEND_MASK)
426 root 1.66 const_iv (EV, FLAG_AUTO)
427 root 1.134 const_iv (EV, FLAG_FORKCHECK)
428 root 1.135 const_iv (EV, FLAG_SIGNALFD)
429 root 1.153 const_iv (EV, FLAG_NOSIGMASK)
430 root 1.66 const_iv (EV, FLAG_NOENV)
431 root 1.134 const_iv (EV, FLAG_NOINOTIFY)
432 root 1.123
433     const_iv (EV_, VERSION_MAJOR)
434     const_iv (EV_, VERSION_MINOR)
435 root 1.142 #if EV_COMPAT3
436 root 1.147 const_iv (EV, FLAG_NOSIGFD) /* compatibility, always 0 */
437     const_iv (EV_, TIMEOUT)
438 root 1.142 const_iv (EV, LOOP_NONBLOCK)
439     const_iv (EV, LOOP_ONESHOT)
440     const_iv (EV, UNLOOP_CANCEL)
441     const_iv (EV, UNLOOP_ONE)
442     const_iv (EV, UNLOOP_ALL)
443     #endif
444 root 1.1 };
445    
446 root 1.157 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ > const_iv; civ--)
447     newCONSTSUB (stash, (char *)civ[-1].name, newSViv (civ[-1].iv));
448 root 1.1
449 root 1.163 /* since this clashes with perl CHECK blocks, */
450     /* but we are interested in constants, */
451     /* and not blocks, we treat CHECK specially. */
452     {
453     /* the local $^W = 0 takes care of the warning */
454     CV *cv = newCONSTSUB (stash, "CHECK", newSViv (EV_CHECK));
455     /* now we need to re-set the gv, in case it was hijacked */
456     GvCV_set (gv_fetchpv ("EV::CHECK", GV_ADD, SVt_PVCV), cv);
457     }
458    
459 root 1.93 stash_loop = gv_stashpv ("EV::Loop" , 1);
460 root 1.15 stash_watcher = gv_stashpv ("EV::Watcher" , 1);
461 root 1.78 stash_io = gv_stashpv ("EV::IO" , 1);
462 root 1.15 stash_timer = gv_stashpv ("EV::Timer" , 1);
463     stash_periodic = gv_stashpv ("EV::Periodic", 1);
464     stash_signal = gv_stashpv ("EV::Signal" , 1);
465     stash_idle = gv_stashpv ("EV::Idle" , 1);
466 root 1.22 stash_prepare = gv_stashpv ("EV::Prepare" , 1);
467 root 1.15 stash_check = gv_stashpv ("EV::Check" , 1);
468 root 1.23 stash_child = gv_stashpv ("EV::Child" , 1);
469 root 1.80 stash_embed = gv_stashpv ("EV::Embed" , 1);
470     stash_stat = gv_stashpv ("EV::Stat" , 1);
471 root 1.91 stash_fork = gv_stashpv ("EV::Fork" , 1);
472 root 1.145 stash_cleanup = gv_stashpv ("EV::Cleanup" , 1);
473 root 1.106 stash_async = gv_stashpv ("EV::Async" , 1);
474 root 1.11
475     {
476     SV *sv = perl_get_sv ("EV::API", TRUE);
477     perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */
478    
479 root 1.15 /* the poor man's shared library emulator */
480 root 1.91 evapi.ver = EV_API_VERSION;
481     evapi.rev = EV_API_REVISION;
482 root 1.127 evapi.sv_fileno = sv_fileno;
483 root 1.126 evapi.sv_signum = s_signum;
484 root 1.91 evapi.supported_backends = ev_supported_backends ();
485     evapi.recommended_backends = ev_recommended_backends ();
486     evapi.embeddable_backends = ev_embeddable_backends ();
487 root 1.109 evapi.time_ = ev_time;
488     evapi.sleep_ = ev_sleep;
489 root 1.91 evapi.loop_new = ev_loop_new;
490     evapi.loop_destroy = ev_loop_destroy;
491     evapi.loop_fork = ev_loop_fork;
492 root 1.137 evapi.iteration = ev_iteration;
493     evapi.depth = ev_depth;
494 root 1.126 evapi.set_userdata = ev_set_userdata;
495     evapi.userdata = ev_userdata;
496 root 1.91 evapi.now = ev_now;
497 root 1.115 evapi.now_update = ev_now_update;
498 root 1.122 evapi.suspend = ev_suspend;
499     evapi.resume = ev_resume;
500 root 1.91 evapi.backend = ev_backend;
501 root 1.142 evapi.break_ = ev_break;
502 root 1.126 evapi.invoke_pending = ev_invoke_pending;
503 root 1.128 evapi.pending_count = ev_pending_count;
504 root 1.137 evapi.verify = ev_verify;
505 root 1.126 evapi.set_loop_release_cb = ev_set_loop_release_cb;
506     evapi.set_invoke_pending_cb= ev_set_invoke_pending_cb;
507 root 1.91 evapi.ref = ev_ref;
508     evapi.unref = ev_unref;
509 root 1.142 evapi.run = ev_run;
510 root 1.91 evapi.once = ev_once;
511     evapi.io_start = ev_io_start;
512     evapi.io_stop = ev_io_stop;
513     evapi.timer_start = ev_timer_start;
514     evapi.timer_stop = ev_timer_stop;
515     evapi.timer_again = ev_timer_again;
516 root 1.130 evapi.timer_remaining = ev_timer_remaining;
517 root 1.91 evapi.periodic_start = ev_periodic_start;
518     evapi.periodic_stop = ev_periodic_stop;
519     evapi.signal_start = ev_signal_start;
520     evapi.signal_stop = ev_signal_stop;
521     evapi.idle_start = ev_idle_start;
522     evapi.idle_stop = ev_idle_stop;
523     evapi.prepare_start = ev_prepare_start;
524     evapi.prepare_stop = ev_prepare_stop;
525     evapi.check_start = ev_check_start;
526     evapi.check_stop = ev_check_stop;
527 root 1.139 #if EV_CHILD_ENABLE
528 root 1.91 evapi.child_start = ev_child_start;
529     evapi.child_stop = ev_child_stop;
530 root 1.139 #endif
531 root 1.91 evapi.stat_start = ev_stat_start;
532     evapi.stat_stop = ev_stat_stop;
533     evapi.stat_stat = ev_stat_stat;
534     evapi.embed_start = ev_embed_start;
535     evapi.embed_stop = ev_embed_stop;
536     evapi.embed_sweep = ev_embed_sweep;
537     evapi.fork_start = ev_fork_start;
538     evapi.fork_stop = ev_fork_stop;
539 root 1.145 evapi.cleanup_start = ev_cleanup_start;
540     evapi.cleanup_stop = ev_cleanup_stop;
541 root 1.105 evapi.async_start = ev_async_start;
542     evapi.async_stop = ev_async_stop;
543     evapi.async_send = ev_async_send;
544 root 1.91 evapi.clear_pending = ev_clear_pending;
545     evapi.invoke = ev_invoke;
546 root 1.11
547     sv_setiv (sv, (IV)&evapi);
548     SvREADONLY_on (sv);
549     }
550 root 1.159 #if !defined _WIN32 && !defined _MINIX
551 root 1.162 #if __linux
552     int __register_atfork(void (*prepare) (void), void (*parent) (void), void (*child) (void), void * __dso_handle);
553     __register_atfork (0, 0, default_fork, 0);
554     #else
555 root 1.147 pthread_atfork (0, 0, default_fork);
556 root 1.56 #endif
557 root 1.162 #endif
558 root 1.1 }
559    
560 root 1.97 SV *ev_default_loop (unsigned int flags = 0)
561 root 1.91 CODE:
562     {
563 root 1.93 if (!default_loop_sv)
564     {
565     evapi.default_loop = ev_default_loop (flags);
566    
567     if (!evapi.default_loop)
568     XSRETURN_UNDEF;
569    
570     default_loop_sv = sv_bless (newRV_noinc (newSViv (PTR2IV (evapi.default_loop))), stash_loop);
571     }
572 root 1.1
573 root 1.93 RETVAL = newSVsv (default_loop_sv);
574 root 1.91 }
575     OUTPUT:
576     RETVAL
577 root 1.1
578 root 1.102 void ev_default_destroy ()
579     CODE:
580 root 1.144 ev_loop_destroy (EV_DEFAULT_UC);
581 root 1.102 SvREFCNT_dec (default_loop_sv);
582     default_loop_sv = 0;
583    
584     unsigned int ev_supported_backends ()
585    
586     unsigned int ev_recommended_backends ()
587    
588     unsigned int ev_embeddable_backends ()
589    
590 root 1.117 void ev_sleep (NV interval)
591    
592 root 1.15 NV ev_time ()
593 root 1.1
594 root 1.154 void ev_feed_signal (SV *signal)
595     CODE:
596     {
597     Signal signum = s_signum (signal);
598     CHECK_SIG (signal, signum);
599    
600     ev_feed_signal (signum);
601     }
602    
603 root 1.91 NV ev_now ()
604     C_ARGS: evapi.default_loop
605    
606 root 1.115 void ev_now_update ()
607     C_ARGS: evapi.default_loop
608    
609 root 1.122 void ev_suspend ()
610     C_ARGS: evapi.default_loop
611    
612     void ev_resume ()
613     C_ARGS: evapi.default_loop
614    
615 root 1.91 unsigned int ev_backend ()
616     C_ARGS: evapi.default_loop
617 root 1.1
618 root 1.137 void ev_verify ()
619 root 1.142 ALIAS:
620     loop_verify = 1
621 root 1.125 C_ARGS: evapi.default_loop
622    
623 root 1.137 unsigned int ev_iteration ()
624 root 1.142 ALIAS:
625     loop_count = 1
626 root 1.91 C_ARGS: evapi.default_loop
627 root 1.86
628 root 1.137 unsigned int ev_depth ()
629 root 1.142 ALIAS:
630     loop_depth = 1
631 root 1.125 C_ARGS: evapi.default_loop
632    
633 root 1.101 void ev_set_io_collect_interval (NV interval)
634     C_ARGS: evapi.default_loop, interval
635    
636     void ev_set_timeout_collect_interval (NV interval)
637     C_ARGS: evapi.default_loop, interval
638    
639 root 1.162 int ev_run (int flags = 0)
640 root 1.142 ALIAS:
641     loop = 1
642 root 1.91 C_ARGS: evapi.default_loop, flags
643 root 1.1
644 root 1.142 void ev_break (int how = EVBREAK_ONE)
645     ALIAS:
646     unloop = 1
647 root 1.91 C_ARGS: evapi.default_loop, how
648 root 1.1
649 root 1.89 void ev_feed_fd_event (int fd, int revents = EV_NONE)
650 root 1.91 C_ARGS: evapi.default_loop, fd, revents
651 root 1.89
652     void ev_feed_signal_event (SV *signal)
653     CODE:
654     {
655 root 1.162 Signal signum = s_signum (signal);
656 root 1.89 CHECK_SIG (signal, signum);
657    
658 root 1.91 ev_feed_signal_event (evapi.default_loop, signum);
659 root 1.89 }
660    
661 root 1.129 unsigned int ev_pending_count ()
662     C_ARGS: evapi.default_loop
663    
664     void ev_invoke_pending ()
665     C_ARGS: evapi.default_loop
666    
667 root 1.78 ev_io *io (SV *fh, int events, SV *cb)
668 root 1.15 ALIAS:
669     io_ns = 1
670 root 1.133 _ae_io = 2
671 root 1.1 CODE:
672 root 1.31 {
673 root 1.126 int fd = s_fileno (fh, events & EV_WRITE);
674 root 1.31 CHECK_FD (fh, fd);
675 root 1.164 RETVAL = e_new (sizeof (ev_io), cb, default_loop_sv);
676     e_fh (RETVAL) = newSVsv (fh);
677 root 1.31
678 root 1.133 if (ix == 2)
679     {
680     events = events ? EV_WRITE : EV_READ;
681 root 1.164 e_flags (RETVAL) |= WFLAG_NOARGS;
682 root 1.133 }
683    
684 root 1.31 ev_io_set (RETVAL, fd, events);
685 root 1.164 if (ix != 1) START (io, RETVAL);
686 root 1.31 }
687 root 1.1 OUTPUT:
688     RETVAL
689    
690 root 1.78 ev_timer *timer (NV after, NV repeat, SV *cb)
691 root 1.1 ALIAS:
692 root 1.15 timer_ns = 1
693 root 1.18 INIT:
694     CHECK_REPEAT (repeat);
695 root 1.1 CODE:
696 root 1.93 RETVAL = e_new (sizeof (ev_timer), cb, default_loop_sv);
697 root 1.29 ev_timer_set (RETVAL, after, repeat);
698 root 1.78 if (!ix) START (timer, RETVAL);
699 root 1.1 OUTPUT:
700     RETVAL
701    
702 root 1.59 SV *periodic (NV at, NV interval, SV *reschedule_cb, SV *cb)
703 root 1.9 ALIAS:
704 root 1.15 periodic_ns = 1
705 root 1.18 INIT:
706     CHECK_REPEAT (interval);
707 root 1.9 CODE:
708 root 1.59 {
709 root 1.78 ev_periodic *w;
710 root 1.93 w = e_new (sizeof (ev_periodic), cb, default_loop_sv);
711 root 1.138 e_fh (w) = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
712     ev_periodic_set (w, at, interval, e_fh (w) ? e_periodic_cb : 0);
713 root 1.78 RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
714     if (!ix) START (periodic, w);
715 root 1.59 }
716 root 1.9 OUTPUT:
717     RETVAL
718    
719 root 1.80 ev_signal *signal (SV *signal, SV *cb)
720 root 1.1 ALIAS:
721 root 1.15 signal_ns = 1
722 root 1.1 CODE:
723 root 1.80 {
724 root 1.126 Signal signum = s_signum (signal);
725 root 1.80 CHECK_SIG (signal, signum);
726    
727 root 1.93 RETVAL = e_new (sizeof (ev_signal), cb, default_loop_sv);
728 root 1.29 ev_signal_set (RETVAL, signum);
729 root 1.132 if (!ix) START_SIGNAL (RETVAL);
730 root 1.80 }
731 root 1.1 OUTPUT:
732     RETVAL
733    
734 root 1.78 ev_idle *idle (SV *cb)
735 root 1.1 ALIAS:
736 root 1.15 idle_ns = 1
737 root 1.1 CODE:
738 root 1.93 RETVAL = e_new (sizeof (ev_idle), cb, default_loop_sv);
739 root 1.29 ev_idle_set (RETVAL);
740 root 1.78 if (!ix) START (idle, RETVAL);
741 root 1.1 OUTPUT:
742     RETVAL
743    
744 root 1.78 ev_prepare *prepare (SV *cb)
745 root 1.22 ALIAS:
746     prepare_ns = 1
747     CODE:
748 root 1.93 RETVAL = e_new (sizeof (ev_prepare), cb, default_loop_sv);
749 root 1.29 ev_prepare_set (RETVAL);
750 root 1.78 if (!ix) START (prepare, RETVAL);
751 root 1.22 OUTPUT:
752     RETVAL
753    
754 root 1.78 ev_check *check (SV *cb)
755 root 1.1 ALIAS:
756 root 1.15 check_ns = 1
757 root 1.1 CODE:
758 root 1.93 RETVAL = e_new (sizeof (ev_check), cb, default_loop_sv);
759 root 1.29 ev_check_set (RETVAL);
760 root 1.78 if (!ix) START (check, RETVAL);
761 root 1.1 OUTPUT:
762     RETVAL
763    
764 root 1.91 ev_fork *fork (SV *cb)
765     ALIAS:
766     fork_ns = 1
767     CODE:
768 root 1.93 RETVAL = e_new (sizeof (ev_fork), cb, default_loop_sv);
769 root 1.91 ev_fork_set (RETVAL);
770     if (!ix) START (fork, RETVAL);
771     OUTPUT:
772     RETVAL
773    
774 root 1.160 #if CLEANUP_ENABLED
775    
776 root 1.145 ev_cleanup *cleanup (SV *cb)
777     ALIAS:
778     cleanup_ns = 1
779     CODE:
780     RETVAL = e_new (sizeof (ev_cleanup), cb, default_loop_sv);
781 root 1.160 SvREFCNT_dec (RETVAL->loop); /* must not keep loop object alive */
782 root 1.145 ev_cleanup_set (RETVAL);
783     if (!ix) START (cleanup, RETVAL);
784     OUTPUT:
785     RETVAL
786 root 1.139
787 root 1.160 #endif
788    
789 root 1.104 ev_child *child (int pid, int trace, SV *cb)
790 root 1.23 ALIAS:
791 root 1.69 child_ns = 1
792 root 1.23 CODE:
793 root 1.140 #if EV_CHILD_ENABLE
794 root 1.93 RETVAL = e_new (sizeof (ev_child), cb, default_loop_sv);
795 root 1.104 ev_child_set (RETVAL, pid, trace);
796 root 1.78 if (!ix) START (child, RETVAL);
797 root 1.140 #else
798     croak ("EV::child watchers not supported on this platform");
799     #endif
800 root 1.23 OUTPUT:
801     RETVAL
802    
803 root 1.139
804 root 1.80 ev_stat *stat (SV *path, NV interval, SV *cb)
805     ALIAS:
806     stat_ns = 1
807     CODE:
808 root 1.93 RETVAL = e_new (sizeof (ev_stat), cb, default_loop_sv);
809 root 1.138 e_fh (RETVAL) = newSVsv (path);
810     ev_stat_set (RETVAL, SvPVbyte_nolen (e_fh (RETVAL)), interval);
811 root 1.80 if (!ix) START (stat, RETVAL);
812     OUTPUT:
813     RETVAL
814    
815 root 1.150 #ifndef EV_NO_LOOPS
816    
817 root 1.114 ev_embed *embed (struct ev_loop *loop, SV *cb = 0)
818 root 1.93 ALIAS:
819     embed_ns = 1
820     CODE:
821 root 1.95 {
822     if (!(ev_backend (loop) & ev_embeddable_backends ()))
823     croak ("passed loop is not embeddable via EV::embed,");
824    
825 root 1.93 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
826 root 1.138 e_fh (RETVAL) = newSVsv (ST (0));
827 root 1.93 ev_embed_set (RETVAL, loop);
828     if (!ix) START (embed, RETVAL);
829 root 1.95 }
830 root 1.93 OUTPUT:
831     RETVAL
832    
833 root 1.150 #endif
834    
835 root 1.106 ev_async *async (SV *cb)
836     ALIAS:
837     async_ns = 1
838     CODE:
839     RETVAL = e_new (sizeof (ev_async), cb, default_loop_sv);
840     ev_async_set (RETVAL);
841     if (!ix) START (async, RETVAL);
842     OUTPUT:
843     RETVAL
844    
845 root 1.76 void once (SV *fh, int events, SV *timeout, SV *cb)
846 root 1.75 CODE:
847 root 1.76 ev_once (
848 root 1.91 evapi.default_loop,
849 root 1.126 s_fileno (fh, events & EV_WRITE), events,
850 root 1.76 SvOK (timeout) ? SvNV (timeout) : -1.,
851     e_once_cb,
852     newSVsv (cb)
853     );
854 root 1.15
855 root 1.1 PROTOTYPES: DISABLE
856    
857 root 1.15 MODULE = EV PACKAGE = EV::Watcher PREFIX = ev_
858 root 1.1
859 root 1.78 int ev_is_active (ev_watcher *w)
860 root 1.1
861 root 1.78 int ev_is_pending (ev_watcher *w)
862    
863 root 1.89 void ev_invoke (ev_watcher *w, int revents = EV_NONE)
864 root 1.93 C_ARGS: e_loop (w), w, revents
865 root 1.89
866     int ev_clear_pending (ev_watcher *w)
867 root 1.93 C_ARGS: e_loop (w), w
868 root 1.89
869     void ev_feed_event (ev_watcher *w, int revents = EV_NONE)
870 root 1.93 C_ARGS: e_loop (w), w, revents
871 root 1.89
872 root 1.78 int keepalive (ev_watcher *w, int new_value = 0)
873     CODE:
874     {
875 root 1.104 RETVAL = w->e_flags & WFLAG_KEEPALIVE;
876 root 1.78 new_value = new_value ? WFLAG_KEEPALIVE : 0;
877    
878 root 1.104 if (items > 1 && ((new_value ^ w->e_flags) & WFLAG_KEEPALIVE))
879 root 1.78 {
880 root 1.121 w->e_flags = (w->e_flags & ~WFLAG_KEEPALIVE) | new_value;
881 root 1.78 REF (w);
882     UNREF (w);
883     }
884     }
885     OUTPUT:
886     RETVAL
887    
888     SV *cb (ev_watcher *w, SV *new_cb = 0)
889 root 1.1 CODE:
890 root 1.15 {
891     if (items > 1)
892 root 1.112 {
893 root 1.126 new_cb = s_get_cv_croak (new_cb);
894 root 1.112 RETVAL = newRV_noinc (w->cb_sv);
895     w->cb_sv = SvREFCNT_inc (new_cb);
896     }
897     else
898     RETVAL = newRV_inc (w->cb_sv);
899 root 1.15 }
900 root 1.1 OUTPUT:
901     RETVAL
902    
903 root 1.78 SV *data (ev_watcher *w, SV *new_data = 0)
904 root 1.60 CODE:
905     {
906     RETVAL = w->data ? newSVsv (w->data) : &PL_sv_undef;
907 root 1.79
908     if (items > 1)
909     {
910     SvREFCNT_dec (w->data);
911     w->data = newSVsv (new_data);
912     }
913 root 1.60 }
914     OUTPUT:
915     RETVAL
916    
917 root 1.99 SV *loop (ev_watcher *w)
918     CODE:
919     RETVAL = newRV_inc (w->loop);
920     OUTPUT:
921     RETVAL
922    
923 root 1.78 int priority (ev_watcher *w, int new_priority = 0)
924 root 1.41 CODE:
925     {
926     RETVAL = w->priority;
927    
928     if (items > 1)
929     {
930     int active = ev_is_active (w);
931    
932     if (active)
933     {
934     /* grrr. */
935     PUSHMARK (SP);
936     XPUSHs (ST (0));
937 root 1.87 PUTBACK;
938 root 1.41 call_method ("stop", G_DISCARD | G_VOID);
939     }
940    
941     ev_set_priority (w, new_priority);
942    
943     if (active)
944     {
945     PUSHMARK (SP);
946     XPUSHs (ST (0));
947 root 1.87 PUTBACK;
948 root 1.41 call_method ("start", G_DISCARD | G_VOID);
949     }
950     }
951     }
952     OUTPUT:
953     RETVAL
954    
955 root 1.78 MODULE = EV PACKAGE = EV::IO PREFIX = ev_io_
956 root 1.1
957 root 1.78 void ev_io_start (ev_io *w)
958     CODE:
959     START (io, w);
960 root 1.1
961 root 1.78 void ev_io_stop (ev_io *w)
962     CODE:
963     STOP (io, w);
964 root 1.15
965 root 1.78 void DESTROY (ev_io *w)
966 root 1.26 CODE:
967 root 1.78 STOP (io, w);
968 root 1.34 e_destroy (w);
969 root 1.26
970 root 1.78 void set (ev_io *w, SV *fh, int events)
971 root 1.1 CODE:
972     {
973 root 1.126 int fd = s_fileno (fh, events & EV_WRITE);
974 root 1.31 CHECK_FD (fh, fd);
975    
976 root 1.138 sv_setsv (e_fh (w), fh);
977 root 1.80 RESET (io, w, (w, fd, events));
978 root 1.15 }
979 root 1.1
980 root 1.78 SV *fh (ev_io *w, SV *new_fh = 0)
981 root 1.1 CODE:
982 root 1.15 {
983     if (items > 1)
984     {
985 root 1.126 int fd = s_fileno (new_fh, w->events & EV_WRITE);
986 root 1.80 CHECK_FD (new_fh, fd);
987 root 1.1
988 root 1.138 RETVAL = e_fh (w);
989     e_fh (w) = newSVsv (new_fh);
990 root 1.1
991 root 1.80 RESET (io, w, (w, fd, w->events));
992 root 1.15 }
993 root 1.80 else
994 root 1.138 RETVAL = newSVsv (e_fh (w));
995 root 1.15 }
996 root 1.1 OUTPUT:
997     RETVAL
998    
999 root 1.78 int events (ev_io *w, int new_events = EV_UNDEF)
1000 root 1.1 CODE:
1001 root 1.15 {
1002     RETVAL = w->events;
1003    
1004     if (items > 1)
1005 root 1.80 RESET (io, w, (w, w->fd, new_events));
1006 root 1.15 }
1007 root 1.1 OUTPUT:
1008     RETVAL
1009    
1010 root 1.29 MODULE = EV PACKAGE = EV::Signal PREFIX = ev_signal_
1011 root 1.15
1012 root 1.78 void ev_signal_start (ev_signal *w)
1013     CODE:
1014 root 1.132 START_SIGNAL (w);
1015 root 1.15
1016 root 1.78 void ev_signal_stop (ev_signal *w)
1017     CODE:
1018     STOP (signal, w);
1019 root 1.15
1020 root 1.78 void DESTROY (ev_signal *w)
1021 root 1.26 CODE:
1022 root 1.78 STOP (signal, w);
1023 root 1.34 e_destroy (w);
1024 root 1.26
1025 root 1.78 void set (ev_signal *w, SV *signal)
1026 root 1.1 CODE:
1027 root 1.15 {
1028 root 1.126 Signal signum = s_signum (signal);
1029 root 1.80 CHECK_SIG (signal, signum);
1030 root 1.39
1031 root 1.132 RESET_SIGNAL (w, (w, signum));
1032 root 1.15 }
1033    
1034 root 1.78 int signal (ev_signal *w, SV *new_signal = 0)
1035 root 1.39 CODE:
1036     {
1037     RETVAL = w->signum;
1038    
1039     if (items > 1)
1040     {
1041 root 1.126 Signal signum = s_signum (new_signal);
1042 root 1.80 CHECK_SIG (new_signal, signum);
1043 root 1.39
1044 root 1.132 RESET_SIGNAL (w, (w, signum));
1045 root 1.39 }
1046     }
1047     OUTPUT:
1048     RETVAL
1049    
1050 root 1.29 MODULE = EV PACKAGE = EV::Timer PREFIX = ev_timer_
1051 root 1.15
1052 root 1.78 void ev_timer_start (ev_timer *w)
1053 root 1.18 INIT:
1054     CHECK_REPEAT (w->repeat);
1055 root 1.78 CODE:
1056     START (timer, w);
1057 root 1.15
1058 root 1.78 void ev_timer_stop (ev_timer *w)
1059     CODE:
1060     STOP (timer, w);
1061 root 1.1
1062 root 1.78 void ev_timer_again (ev_timer *w)
1063 root 1.18 INIT:
1064     CHECK_REPEAT (w->repeat);
1065 root 1.78 CODE:
1066 root 1.93 ev_timer_again (e_loop (w), w);
1067 root 1.78 UNREF (w);
1068 root 1.17
1069 root 1.130 NV ev_timer_remaining (ev_timer *w)
1070     C_ARGS: e_loop (w), w
1071    
1072 root 1.78 void DESTROY (ev_timer *w)
1073 root 1.26 CODE:
1074 root 1.78 STOP (timer, w);
1075 root 1.34 e_destroy (w);
1076 root 1.26
1077 root 1.78 void set (ev_timer *w, NV after, NV repeat = 0.)
1078 root 1.18 INIT:
1079     CHECK_REPEAT (repeat);
1080 root 1.1 CODE:
1081 root 1.80 RESET (timer, w, (w, after, repeat));
1082 root 1.1
1083 root 1.29 MODULE = EV PACKAGE = EV::Periodic PREFIX = ev_periodic_
1084 root 1.15
1085 root 1.78 void ev_periodic_start (ev_periodic *w)
1086 root 1.18 INIT:
1087     CHECK_REPEAT (w->interval);
1088 root 1.78 CODE:
1089     START (periodic, w);
1090 root 1.1
1091 root 1.78 void ev_periodic_stop (ev_periodic *w)
1092     CODE:
1093     STOP (periodic, w);
1094 root 1.1
1095 root 1.78 void ev_periodic_again (ev_periodic *w)
1096     CODE:
1097 root 1.93 ev_periodic_again (e_loop (w), w);
1098 root 1.78 UNREF (w);
1099 root 1.59
1100 root 1.78 void DESTROY (ev_periodic *w)
1101 root 1.26 CODE:
1102 root 1.78 STOP (periodic, w);
1103 root 1.34 e_destroy (w);
1104 root 1.26
1105 root 1.78 void set (ev_periodic *w, NV at, NV interval = 0., SV *reschedule_cb = &PL_sv_undef)
1106 root 1.18 INIT:
1107     CHECK_REPEAT (interval);
1108 root 1.10 CODE:
1109     {
1110 root 1.138 SvREFCNT_dec (e_fh (w));
1111     e_fh (w) = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
1112 root 1.39
1113 root 1.138 RESET (periodic, w, (w, at, interval, e_fh (w) ? e_periodic_cb : 0));
1114 root 1.15 }
1115 root 1.10
1116 root 1.90 NV at (ev_periodic *w)
1117     CODE:
1118 root 1.111 RETVAL = ev_periodic_at (w);
1119 root 1.90 OUTPUT:
1120     RETVAL
1121    
1122 root 1.29 MODULE = EV PACKAGE = EV::Idle PREFIX = ev_idle_
1123 root 1.10
1124 root 1.78 void ev_idle_start (ev_idle *w)
1125     CODE:
1126     START (idle, w);
1127 root 1.10
1128 root 1.78 void ev_idle_stop (ev_idle *w)
1129     CODE:
1130     STOP (idle, w);
1131 root 1.10
1132 root 1.78 void DESTROY (ev_idle *w)
1133 root 1.26 CODE:
1134 root 1.78 STOP (idle, w);
1135 root 1.34 e_destroy (w);
1136 root 1.26
1137 root 1.100 MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_prepare_
1138 root 1.22
1139 root 1.78 void ev_prepare_start (ev_prepare *w)
1140     CODE:
1141     START (prepare, w);
1142 root 1.22
1143 root 1.78 void ev_prepare_stop (ev_prepare *w)
1144     CODE:
1145     STOP (prepare, w);
1146 root 1.22
1147 root 1.78 void DESTROY (ev_prepare *w)
1148 root 1.26 CODE:
1149 root 1.78 STOP (prepare, w);
1150 root 1.34 e_destroy (w);
1151 root 1.26
1152 root 1.29 MODULE = EV PACKAGE = EV::Check PREFIX = ev_check_
1153 root 1.1
1154 root 1.78 void ev_check_start (ev_check *w)
1155     CODE:
1156     START (check, w);
1157 root 1.1
1158 root 1.78 void ev_check_stop (ev_check *w)
1159     CODE:
1160     STOP (check, w);
1161 root 1.1
1162 root 1.78 void DESTROY (ev_check *w)
1163 root 1.26 CODE:
1164 root 1.78 STOP (check, w);
1165 root 1.34 e_destroy (w);
1166 root 1.26
1167 root 1.91 MODULE = EV PACKAGE = EV::Fork PREFIX = ev_fork_
1168    
1169     void ev_fork_start (ev_fork *w)
1170     CODE:
1171     START (fork, w);
1172    
1173     void ev_fork_stop (ev_fork *w)
1174     CODE:
1175     STOP (fork, w);
1176    
1177     void DESTROY (ev_fork *w)
1178     CODE:
1179     STOP (fork, w);
1180     e_destroy (w);
1181    
1182 root 1.160 #if CLEANUP_ENABLED
1183    
1184 root 1.145 MODULE = EV PACKAGE = EV::Cleanup PREFIX = ev_cleanup_
1185    
1186     void ev_cleanup_start (ev_cleanup *w)
1187     CODE:
1188     START (cleanup, w);
1189    
1190     void ev_cleanup_stop (ev_cleanup *w)
1191     CODE:
1192     STOP (cleanup, w);
1193    
1194     void DESTROY (ev_cleanup *w)
1195     CODE:
1196     STOP (cleanup, w);
1197 root 1.160 SvREFCNT_inc (w->loop); /* has been dec'ed on creation */
1198 root 1.145 e_destroy (w);
1199    
1200 root 1.160 int keepalive (ev_watcher *w, SV *new_value = 0)
1201 root 1.146 CODE:
1202 root 1.160 RETVAL = 1;
1203 root 1.146 OUTPUT:
1204     RETVAL
1205    
1206 root 1.160 #endif
1207    
1208 root 1.29 MODULE = EV PACKAGE = EV::Child PREFIX = ev_child_
1209 root 1.23
1210 root 1.139 #if EV_CHILD_ENABLE
1211    
1212 root 1.78 void ev_child_start (ev_child *w)
1213     CODE:
1214     START (child, w);
1215 root 1.23
1216 root 1.78 void ev_child_stop (ev_child *w)
1217     CODE:
1218     STOP (child, w);
1219 root 1.23
1220 root 1.78 void DESTROY (ev_child *w)
1221 root 1.26 CODE:
1222 root 1.78 STOP (child, w);
1223 root 1.34 e_destroy (w);
1224 root 1.26
1225 root 1.104 void set (ev_child *w, int pid, int trace)
1226 root 1.23 CODE:
1227 root 1.104 RESET (child, w, (w, pid, trace));
1228 root 1.23
1229 root 1.104 int pid (ev_child *w)
1230 root 1.45 ALIAS:
1231 root 1.104 rpid = 1
1232     rstatus = 2
1233 root 1.24 CODE:
1234 root 1.104 RETVAL = ix == 0 ? w->pid
1235     : ix == 1 ? w->rpid
1236     : w->rstatus;
1237 root 1.24 OUTPUT:
1238     RETVAL
1239    
1240 root 1.139 #endif
1241    
1242 root 1.80 MODULE = EV PACKAGE = EV::Stat PREFIX = ev_stat_
1243    
1244     void ev_stat_start (ev_stat *w)
1245     CODE:
1246     START (stat, w);
1247    
1248     void ev_stat_stop (ev_stat *w)
1249     CODE:
1250     STOP (stat, w);
1251    
1252     void DESTROY (ev_stat *w)
1253     CODE:
1254     STOP (stat, w);
1255     e_destroy (w);
1256    
1257     void set (ev_stat *w, SV *path, NV interval)
1258     CODE:
1259     {
1260 root 1.138 sv_setsv (e_fh (w), path);
1261     RESET (stat, w, (w, SvPVbyte_nolen (e_fh (w)), interval));
1262 root 1.80 }
1263    
1264     SV *path (ev_stat *w, SV *new_path = 0)
1265     CODE:
1266     {
1267 root 1.138 RETVAL = SvREFCNT_inc (e_fh (w));
1268 root 1.80
1269     if (items > 1)
1270     {
1271 root 1.138 SvREFCNT_dec (e_fh (w));
1272     e_fh (w) = newSVsv (new_path);
1273     RESET (stat, w, (w, SvPVbyte_nolen (e_fh (w)), w->interval));
1274 root 1.80 }
1275     }
1276     OUTPUT:
1277     RETVAL
1278    
1279     NV interval (ev_stat *w, NV new_interval = 0.)
1280     CODE:
1281     {
1282     RETVAL = w->interval;
1283    
1284     if (items > 1)
1285 root 1.138 RESET (stat, w, (w, SvPVbyte_nolen (e_fh (w)), new_interval));
1286 root 1.80 }
1287     OUTPUT:
1288     RETVAL
1289    
1290 root 1.82 void prev (ev_stat *w)
1291     ALIAS:
1292     stat = 1
1293     attr = 2
1294     PPCODE:
1295     {
1296     ev_statdata *s = ix ? &w->attr : &w->prev;
1297    
1298     if (ix == 1)
1299 root 1.93 ev_stat_stat (e_loop (w), w);
1300 root 1.82 else if (!s->st_nlink)
1301     errno = ENOENT;
1302    
1303     PL_statcache.st_dev = s->st_nlink;
1304     PL_statcache.st_ino = s->st_ino;
1305     PL_statcache.st_mode = s->st_mode;
1306     PL_statcache.st_nlink = s->st_nlink;
1307     PL_statcache.st_uid = s->st_uid;
1308     PL_statcache.st_gid = s->st_gid;
1309     PL_statcache.st_rdev = s->st_rdev;
1310     PL_statcache.st_size = s->st_size;
1311     PL_statcache.st_atime = s->st_atime;
1312     PL_statcache.st_mtime = s->st_mtime;
1313     PL_statcache.st_ctime = s->st_ctime;
1314    
1315     if (GIMME_V == G_SCALAR)
1316     XPUSHs (boolSV (s->st_nlink));
1317     else if (GIMME_V == G_ARRAY && s->st_nlink)
1318     {
1319     EXTEND (SP, 13);
1320     PUSHs (sv_2mortal (newSViv (s->st_dev)));
1321     PUSHs (sv_2mortal (newSViv (s->st_ino)));
1322     PUSHs (sv_2mortal (newSVuv (s->st_mode)));
1323     PUSHs (sv_2mortal (newSVuv (s->st_nlink)));
1324     PUSHs (sv_2mortal (newSViv (s->st_uid)));
1325     PUSHs (sv_2mortal (newSViv (s->st_gid)));
1326     PUSHs (sv_2mortal (newSViv (s->st_rdev)));
1327     PUSHs (sv_2mortal (newSVnv ((NV)s->st_size)));
1328     PUSHs (sv_2mortal (newSVnv (s->st_atime)));
1329     PUSHs (sv_2mortal (newSVnv (s->st_mtime)));
1330     PUSHs (sv_2mortal (newSVnv (s->st_ctime)));
1331     PUSHs (sv_2mortal (newSVuv (4096)));
1332     PUSHs (sv_2mortal (newSVnv ((NV)((s->st_size + 4095) / 4096))));
1333     }
1334     }
1335    
1336 root 1.93 MODULE = EV PACKAGE = EV::Embed PREFIX = ev_embed_
1337 root 1.5
1338 root 1.93 void ev_embed_start (ev_embed *w)
1339     CODE:
1340     START (embed, w);
1341 root 1.5
1342 root 1.93 void ev_embed_stop (ev_embed *w)
1343     CODE:
1344     STOP (embed, w);
1345 root 1.5
1346 root 1.93 void DESTROY (ev_embed *w)
1347     CODE:
1348     STOP (embed, w);
1349     e_destroy (w);
1350 root 1.5
1351 root 1.93 void set (ev_embed *w, struct ev_loop *loop)
1352     CODE:
1353     {
1354 root 1.138 sv_setsv (e_fh (w), ST (1));
1355 root 1.93 RESET (embed, w, (w, loop));
1356 root 1.5 }
1357    
1358 root 1.96 SV *other (ev_embed *w)
1359     CODE:
1360 root 1.138 RETVAL = newSVsv (e_fh (w));
1361 root 1.96 OUTPUT:
1362     RETVAL
1363    
1364 root 1.107 void ev_embed_sweep (ev_embed *w)
1365     C_ARGS: e_loop (w), w
1366    
1367 root 1.106 MODULE = EV PACKAGE = EV::Async PREFIX = ev_async_
1368    
1369     void ev_async_start (ev_async *w)
1370     CODE:
1371     START (async, w);
1372    
1373     void ev_async_stop (ev_async *w)
1374     CODE:
1375     STOP (async, w);
1376    
1377     void DESTROY (ev_async *w)
1378     CODE:
1379     STOP (async, w);
1380     e_destroy (w);
1381    
1382 root 1.107 void ev_async_send (ev_async *w)
1383     C_ARGS: e_loop (w), w
1384    
1385 root 1.110 SV *ev_async_async_pending (ev_async *w)
1386     CODE:
1387     RETVAL = boolSV (ev_async_pending (w));
1388     OUTPUT:
1389     RETVAL
1390    
1391 root 1.150 #ifndef EV_NO_LOOPS
1392 root 1.149
1393 root 1.98 MODULE = EV PACKAGE = EV::Loop PREFIX = ev_
1394 root 1.5
1395 root 1.97 SV *new (SV *klass, unsigned int flags = 0)
1396 root 1.93 CODE:
1397     {
1398     struct ev_loop *loop = ev_loop_new (flags);
1399 root 1.5
1400 root 1.93 if (!loop)
1401     XSRETURN_UNDEF;
1402 root 1.5
1403 root 1.95 RETVAL = sv_bless (newRV_noinc (newSViv (PTR2IV (loop))), stash_loop);
1404 root 1.93 }
1405     OUTPUT:
1406     RETVAL
1407 root 1.5
1408 root 1.93 void DESTROY (struct ev_loop *loop)
1409     CODE:
1410 root 1.160 /* 1. the default loop shouldn't be freed by destroying it's perl loop object */
1411 root 1.143 /* 2. not doing so helps avoid many global destruction bugs in perl, too */
1412     if (loop != evapi.default_loop)
1413 root 1.93 ev_loop_destroy (loop);
1414 root 1.5
1415 root 1.98 void ev_loop_fork (struct ev_loop *loop)
1416    
1417     NV ev_now (struct ev_loop *loop)
1418    
1419 root 1.115 void ev_now_update (struct ev_loop *loop)
1420    
1421 root 1.122 void ev_suspend (struct ev_loop *loop)
1422    
1423     void ev_resume (struct ev_loop *loop)
1424    
1425 root 1.101 void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1426    
1427     void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1428    
1429 root 1.98 unsigned int ev_backend (struct ev_loop *loop)
1430    
1431 root 1.142 void ev_verify (struct ev_loop *loop)
1432     ALIAS:
1433     loop_verify = 1
1434    
1435 root 1.137 unsigned int ev_iteration (struct ev_loop *loop)
1436 root 1.142 ALIAS:
1437     loop_count = 1
1438 root 1.98
1439 root 1.137 unsigned int ev_depth (struct ev_loop *loop)
1440 root 1.142 ALIAS:
1441     loop_depth = 1
1442 root 1.125
1443 root 1.162 int ev_run (struct ev_loop *loop, int flags = 0)
1444 root 1.142 ALIAS:
1445     loop = 1
1446 root 1.98
1447 root 1.142 void ev_break (struct ev_loop *loop, int how = 1)
1448     ALIAS:
1449     unloop = 1
1450 root 1.98
1451     void ev_feed_fd_event (struct ev_loop *loop, int fd, int revents = EV_NONE)
1452    
1453 root 1.129 unsigned int ev_pending_count (struct ev_loop *loop)
1454    
1455     void ev_invoke_pending (struct ev_loop *loop)
1456    
1457 root 1.98 #if 0
1458    
1459     void ev_feed_signal_event (struct ev_loop *loop, SV *signal)
1460     CODE:
1461     {
1462 root 1.160 Signal signum = s_signum (signal);
1463 root 1.98 CHECK_SIG (signal, signum);
1464    
1465     ev_feed_signal_event (loop, signum);
1466     }
1467    
1468     #endif
1469    
1470 root 1.94 ev_io *io (struct ev_loop *loop, SV *fh, int events, SV *cb)
1471     ALIAS:
1472     io_ns = 1
1473     CODE:
1474     {
1475 root 1.126 int fd = s_fileno (fh, events & EV_WRITE);
1476 root 1.94 CHECK_FD (fh, fd);
1477    
1478     RETVAL = e_new (sizeof (ev_io), cb, ST (0));
1479 root 1.138 e_fh (RETVAL) = newSVsv (fh);
1480 root 1.94 ev_io_set (RETVAL, fd, events);
1481     if (!ix) START (io, RETVAL);
1482     }
1483     OUTPUT:
1484     RETVAL
1485    
1486 root 1.98 ev_timer *timer (struct ev_loop *loop, NV after, NV repeat, SV *cb)
1487     ALIAS:
1488     timer_ns = 1
1489     INIT:
1490     CHECK_REPEAT (repeat);
1491     CODE:
1492     RETVAL = e_new (sizeof (ev_timer), cb, ST (0));
1493     ev_timer_set (RETVAL, after, repeat);
1494     if (!ix) START (timer, RETVAL);
1495     OUTPUT:
1496     RETVAL
1497    
1498     SV *periodic (struct ev_loop *loop, NV at, NV interval, SV *reschedule_cb, SV *cb)
1499     ALIAS:
1500     periodic_ns = 1
1501     INIT:
1502     CHECK_REPEAT (interval);
1503     CODE:
1504     {
1505 root 1.160 ev_periodic *w;
1506 root 1.98 w = e_new (sizeof (ev_periodic), cb, ST (0));
1507 root 1.138 e_fh (w) = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
1508     ev_periodic_set (w, at, interval, e_fh (w) ? e_periodic_cb : 0);
1509 root 1.98 RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
1510     if (!ix) START (periodic, w);
1511     }
1512     OUTPUT:
1513     RETVAL
1514    
1515     ev_signal *signal (struct ev_loop *loop, SV *signal, SV *cb)
1516     ALIAS:
1517     signal_ns = 1
1518     CODE:
1519     {
1520 root 1.160 Signal signum = s_signum (signal);
1521 root 1.98 CHECK_SIG (signal, signum);
1522    
1523     RETVAL = e_new (sizeof (ev_signal), cb, ST (0));
1524     ev_signal_set (RETVAL, signum);
1525 root 1.132 if (!ix) START_SIGNAL (RETVAL);
1526 root 1.98 }
1527     OUTPUT:
1528     RETVAL
1529    
1530     ev_idle *idle (struct ev_loop *loop, SV *cb)
1531     ALIAS:
1532     idle_ns = 1
1533     CODE:
1534     RETVAL = e_new (sizeof (ev_idle), cb, ST (0));
1535     ev_idle_set (RETVAL);
1536     if (!ix) START (idle, RETVAL);
1537     OUTPUT:
1538     RETVAL
1539    
1540     ev_prepare *prepare (struct ev_loop *loop, SV *cb)
1541     ALIAS:
1542     prepare_ns = 1
1543     CODE:
1544     RETVAL = e_new (sizeof (ev_prepare), cb, ST (0));
1545     ev_prepare_set (RETVAL);
1546     if (!ix) START (prepare, RETVAL);
1547     OUTPUT:
1548     RETVAL
1549    
1550     ev_check *check (struct ev_loop *loop, SV *cb)
1551     ALIAS:
1552     check_ns = 1
1553     CODE:
1554     RETVAL = e_new (sizeof (ev_check), cb, ST (0));
1555     ev_check_set (RETVAL);
1556     if (!ix) START (check, RETVAL);
1557     OUTPUT:
1558     RETVAL
1559    
1560     ev_fork *fork (struct ev_loop *loop, SV *cb)
1561     ALIAS:
1562     fork_ns = 1
1563     CODE:
1564     RETVAL = e_new (sizeof (ev_fork), cb, ST (0));
1565     ev_fork_set (RETVAL);
1566     if (!ix) START (fork, RETVAL);
1567     OUTPUT:
1568     RETVAL
1569    
1570 root 1.160 #if CLEANUP_ENABLED
1571    
1572 root 1.145 ev_cleanup *cleanup (struct ev_loop *loop, SV *cb)
1573     ALIAS:
1574     cleanup_ns = 1
1575     CODE:
1576     RETVAL = e_new (sizeof (ev_cleanup), cb, ST (0));
1577 root 1.160 SvREFCNT_dec (RETVAL->loop); /* must not keep loop object alive */
1578 root 1.145 ev_cleanup_set (RETVAL);
1579     if (!ix) START (cleanup, RETVAL);
1580     OUTPUT:
1581     RETVAL
1582 root 1.139
1583 root 1.160 #endif
1584    
1585 root 1.104 ev_child *child (struct ev_loop *loop, int pid, int trace, SV *cb)
1586 root 1.98 ALIAS:
1587     child_ns = 1
1588     CODE:
1589 root 1.140 #if EV_CHILD_ENABLE
1590 root 1.98 RETVAL = e_new (sizeof (ev_child), cb, ST (0));
1591 root 1.104 ev_child_set (RETVAL, pid, trace);
1592 root 1.98 if (!ix) START (child, RETVAL);
1593 root 1.140 #else
1594     croak ("EV::child watchers not supported on this platform");
1595     #endif
1596 root 1.98 OUTPUT:
1597     RETVAL
1598    
1599     ev_stat *stat (struct ev_loop *loop, SV *path, NV interval, SV *cb)
1600     ALIAS:
1601     stat_ns = 1
1602     CODE:
1603     RETVAL = e_new (sizeof (ev_stat), cb, ST (0));
1604 root 1.138 e_fh (RETVAL) = newSVsv (path);
1605     ev_stat_set (RETVAL, SvPVbyte_nolen (e_fh (RETVAL)), interval);
1606 root 1.98 if (!ix) START (stat, RETVAL);
1607     OUTPUT:
1608     RETVAL
1609    
1610 root 1.114 ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = 0)
1611 root 1.98 ALIAS:
1612     embed_ns = 1
1613     CODE:
1614     {
1615     if (!(ev_backend (other) & ev_embeddable_backends ()))
1616     croak ("passed loop is not embeddable via EV::embed,");
1617    
1618     RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
1619 root 1.138 e_fh (RETVAL) = newSVsv (ST (1));
1620 root 1.98 ev_embed_set (RETVAL, other);
1621     if (!ix) START (embed, RETVAL);
1622     }
1623     OUTPUT:
1624     RETVAL
1625    
1626 root 1.106 ev_async *async (struct ev_loop *loop, SV *cb)
1627     ALIAS:
1628     async_ns = 1
1629     CODE:
1630     RETVAL = e_new (sizeof (ev_async), cb, ST (0));
1631     ev_async_set (RETVAL);
1632     if (!ix) START (async, RETVAL);
1633     OUTPUT:
1634     RETVAL
1635    
1636 root 1.98 void once (struct ev_loop *loop, SV *fh, int events, SV *timeout, SV *cb)
1637     CODE:
1638     ev_once (
1639     loop,
1640 root 1.126 s_fileno (fh, events & EV_WRITE), events,
1641 root 1.98 SvOK (timeout) ? SvNV (timeout) : -1.,
1642     e_once_cb,
1643     newSVsv (cb)
1644     );
1645    
1646 root 1.149 #endif
1647