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