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

Comparing EV/EV.xs (file contents):
Revision 1.60 by root, Thu Nov 8 02:19:36 2007 UTC vs.
Revision 1.113 by root, Thu May 22 02:44:57 2008 UTC

2#include "perl.h" 2#include "perl.h"
3#include "XSUB.h" 3#include "XSUB.h"
4 4
5/*#include <netinet/in.h>*/ 5/*#include <netinet/in.h>*/
6 6
7#define EV_PROTOTYPES 1
8#include "EV/EVAPI.h"
9
10/* fix perl api breakage */ 7/* fix perl api breakage */
11#undef signal 8#undef signal
12#undef sigaction 9#undef sigaction
13 10
11#define EV_PROTOTYPES 1
12#define EV_USE_NANOSLEEP EV_USE_MONOTONIC
13#define EV_H <ev.h>
14#include "EV/EVAPI.h"
15
14#define EV_SELECT_USE_WIN32_HANDLES 0 16#define EV_SELECT_IS_WINSOCKET 0
17#ifdef _WIN32
15#define EV_SELECT_USE_FD_SET 0 18# define EV_SELECT_USE_FD_SET 0
19# define NFDBITS PERL_NFDBITS
20# define fd_mask Perl_fd_mask
21#endif
16/* due to bugs in OS X we have to use libev/ explicitly here */ 22/* due to bugs in OS X we have to use libev/ explicitly here */
17#include "libev/ev.c" 23#include "libev/ev.c"
18#include "event.c"
19 24
20#ifndef WIN32 25#ifndef _WIN32
21#define DNS_USE_GETTIMEOFDAY_FOR_ID 1
22#if !defined (WIN32) && !defined(__CYGWIN__)
23# define HAVE_STRUCT_IN6_ADDR 1
24#endif
25#undef HAVE_STRTOK_R
26#undef strtok_r
27#define strtok_r fake_strtok_r
28#include "evdns.c"
29#endif
30
31#ifndef WIN32
32# include <pthread.h> 26# include <pthread.h>
33#endif 27#endif
34 28
29#define e_loop(w) INT2PTR (struct ev_loop *, SvIVX ((w)->loop))
30
31#define WFLAG_KEEPALIVE 1
32
33#define UNREF(w) \
34 if (!((w)->e_flags & WFLAG_KEEPALIVE) \
35 && !ev_is_active (w)) \
36 ev_unref (e_loop (w));
37
38#define REF(w) \
39 if (!((w)->e_flags & WFLAG_KEEPALIVE) \
40 && ev_is_active (w)) \
41 ev_ref (e_loop (w));
42
43#define START(type,w) \
44 do { \
45 UNREF (w); \
46 ev_ ## type ## _start (e_loop (w), w); \
47 } while (0)
48
49#define STOP(type,w) \
50 do { \
51 REF (w); \
52 ev_ ## type ## _stop (e_loop (w), w); \
53 } while (0)
54
55#define RESET(type,w,seta) \
56 do { \
57 int active = ev_is_active (w); \
58 if (active) STOP (type, w); \
59 ev_ ## type ## _set seta; \
60 if (active) START (type, w); \
61 } while (0)
62
35typedef int Signal; 63typedef int Signal;
36 64
65static SV *default_loop_sv;
66
37static struct EVAPI evapi; 67static struct EVAPI evapi;
38 68
39static HV 69static HV
70 *stash_loop,
40 *stash_watcher, 71 *stash_watcher,
41 *stash_io, 72 *stash_io,
42 *stash_timer, 73 *stash_timer,
43 *stash_periodic, 74 *stash_periodic,
44 *stash_signal, 75 *stash_signal,
76 *stash_child,
77 *stash_stat,
45 *stash_idle, 78 *stash_idle,
46 *stash_prepare, 79 *stash_prepare,
47 *stash_check, 80 *stash_check,
48 *stash_child; 81 *stash_embed,
82 *stash_fork,
83 *stash_async;
49 84
50#ifndef SIG_SIZE 85#ifndef SIG_SIZE
51/* kudos to Slaven Rezic for the idea */ 86/* kudos to Slaven Rezic for the idea */
52static char sig_size [] = { SIG_NUM }; 87static char sig_size [] = { SIG_NUM };
53# define SIG_SIZE (sizeof (sig_size) + 1) 88# define SIG_SIZE (sizeof (sig_size) + 1)
54#endif 89#endif
55 90
56static int 91static Signal
57sv_signum (SV *sig) 92sv_signum (SV *sig)
58{ 93{
59 int signum; 94 Signal signum;
60 95
61 SvGETMAGIC (sig); 96 SvGETMAGIC (sig);
62 97
63 for (signum = 1; signum < SIG_SIZE; ++signum) 98 for (signum = 1; signum < SIG_SIZE; ++signum)
64 if (strEQ (SvPV_nolen (sig), PL_sig_name [signum])) 99 if (strEQ (SvPV_nolen (sig), PL_sig_name [signum]))
65 return signum; 100 return signum;
66 101
67 if (SvIV (sig) > 0) 102 signum = SvIV (sig);
103
104 if (signum > 0 && signum < SIG_SIZE)
68 return SvIV (sig); 105 return signum;
69 106
70 return -1; 107 return -1;
71} 108}
72 109
73///////////////////////////////////////////////////////////////////////////// 110/////////////////////////////////////////////////////////////////////////////
74// Event 111// Event
75 112
76static void e_cb (struct ev_watcher *w, int revents); 113static void e_cb (EV_P_ ev_watcher *w, int revents);
77 114
78static int 115static int
79sv_fileno (SV *fh) 116sv_fileno (SV *fh)
80{ 117{
81 SvGETMAGIC (fh); 118 SvGETMAGIC (fh);
84 fh = SvRV (fh); 121 fh = SvRV (fh);
85 122
86 if (SvTYPE (fh) == SVt_PVGV) 123 if (SvTYPE (fh) == SVt_PVGV)
87 return PerlIO_fileno (IoIFP (sv_2io (fh))); 124 return PerlIO_fileno (IoIFP (sv_2io (fh)));
88 125
89 if ((SvIV (fh) >= 0) && (SvIV (fh) < 0x7ffffff)) 126 if (SvOK (fh) && (SvIV (fh) >= 0) && (SvIV (fh) < 0x7fffffffL))
90 return SvIV (fh); 127 return SvIV (fh);
91 128
92 return -1; 129 return -1;
93} 130}
94 131
132static SV *
133e_get_cv (SV *cb_sv)
134{
135 HV *st;
136 GV *gvp;
137 CV *cv = sv_2cv (cb_sv, &st, &gvp, 0);
138
139 if (!cv)
140 croak ("EV watcher callback must be a CODE reference");
141
142 return (SV *)cv;
143}
144
95static void * 145static void *
96e_new (int size, SV *cb_sv) 146e_new (int size, SV *cb_sv, SV *loop)
97{ 147{
148 SV *cv = e_get_cv (cb_sv);
98 struct ev_watcher *w; 149 ev_watcher *w;
99 SV *self = NEWSV (0, size); 150 SV *self = NEWSV (0, size);
100 SvPOK_only (self); 151 SvPOK_only (self);
101 SvCUR_set (self, size); 152 SvCUR_set (self, size);
102 153
103 w = (struct ev_watcher *)SvPVX (self); 154 w = (ev_watcher *)SvPVX (self);
104 155
105 ev_watcher_init (w, e_cb); 156 ev_init (w, e_cb);
106 157
158 w->loop = SvREFCNT_inc (SvRV (loop));
159 w->e_flags = WFLAG_KEEPALIVE;
160 w->data = 0;
107 w->fh = 0; 161 w->fh = 0;
108 w->cb_sv = newSVsv (cb_sv); 162 w->cb_sv = SvREFCNT_inc (cv);
109 w->self = self; 163 w->self = self;
110 164
111 return (void *)w; 165 return (void *)w;
112} 166}
113 167
114static void 168static void
115e_destroy (void *w_) 169e_destroy (void *w_)
116{ 170{
117 struct ev_watcher *w = (struct ev_watcher *)w_; 171 ev_watcher *w = (ev_watcher *)w_;
118 172
173 SvREFCNT_dec (w->loop ); w->loop = 0;
119 SvREFCNT_dec (w->fh ); w->fh = 0; 174 SvREFCNT_dec (w->fh ); w->fh = 0;
120 SvREFCNT_dec (w->cb_sv); w->cb_sv = 0; 175 SvREFCNT_dec (w->cb_sv); w->cb_sv = 0;
121 SvREFCNT_dec (w->data ); w->data = 0; 176 SvREFCNT_dec (w->data ); w->data = 0;
122} 177}
123 178
124static SV * 179static SV *
125e_bless (struct ev_watcher *w, HV *stash) 180e_bless (ev_watcher *w, HV *stash)
126{ 181{
127 SV *rv; 182 SV *rv;
128 183
129 if (SvOBJECT (w->self)) 184 if (SvOBJECT (w->self))
130 rv = newRV_inc (w->self); 185 rv = newRV_inc (w->self);
136 } 191 }
137 192
138 return rv; 193 return rv;
139} 194}
140 195
196static SV *sv_events_cache;
197
141static void 198static void
142e_cb (struct ev_watcher *w, int revents) 199e_cb (EV_P_ ev_watcher *w, int revents)
143{ 200{
144 dSP; 201 dSP;
145 I32 mark = SP - PL_stack_base; 202 I32 mark = SP - PL_stack_base;
146 SV *sv_self, *sv_events, *sv_status = 0; 203 SV *sv_self, *sv_events;
147 static SV *sv_events_cache;
148 204
149 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */ 205 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */
150 206
151 if (sv_events_cache) 207 if (sv_events_cache)
152 { 208 {
161 PUSHs (sv_self); 217 PUSHs (sv_self);
162 PUSHs (sv_events); 218 PUSHs (sv_events);
163 219
164 PUTBACK; 220 PUTBACK;
165 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL); 221 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
166 SP = PL_stack_base + mark; PUTBACK;
167 222
168 SvREFCNT_dec (sv_self); 223 SvREFCNT_dec (sv_self);
169 SvREFCNT_dec (sv_status);
170 224
171 if (sv_events_cache) 225 if (sv_events_cache)
172 SvREFCNT_dec (sv_events); 226 SvREFCNT_dec (sv_events);
173 else 227 else
174 sv_events_cache = sv_events; 228 sv_events_cache = sv_events;
175 229
176 if (SvTRUE (ERRSV)) 230 if (SvTRUE (ERRSV))
177 { 231 {
232 SPAGAIN;
178 PUSHMARK (SP); 233 PUSHMARK (SP);
179 PUTBACK; 234 PUTBACK;
180 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR); 235 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
181 SP = PL_stack_base + mark; PUTBACK;
182 } 236 }
237
238 SP = PL_stack_base + mark;
239 PUTBACK;
240}
241
242static void
243e_once_cb (int revents, void *arg)
244{
245 dSP;
246 I32 mark = SP - PL_stack_base;
247 SV *sv_events;
248
249 if (sv_events_cache)
250 {
251 sv_events = sv_events_cache; sv_events_cache = 0;
252 SvIV_set (sv_events, revents);
253 }
254 else
255 sv_events = newSViv (revents);
256
257 PUSHMARK (SP);
258 XPUSHs (sv_events);
259
260 PUTBACK;
261 call_sv ((SV *)arg, G_DISCARD | G_VOID | G_EVAL);
262
263 SvREFCNT_dec ((SV *)arg);
264
265 if (sv_events_cache)
266 SvREFCNT_dec (sv_events);
267 else
268 sv_events_cache = sv_events;
269
270 if (SvTRUE (ERRSV))
271 {
272 SPAGAIN;
273 PUSHMARK (SP);
274 PUTBACK;
275 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
276 }
277
278 SP = PL_stack_base + mark;
279 PUTBACK;
183} 280}
184 281
185static ev_tstamp 282static ev_tstamp
186e_periodic_cb (struct ev_periodic *w, ev_tstamp now) 283e_periodic_cb (ev_periodic *w, ev_tstamp now)
187{ 284{
188 ev_tstamp retval; 285 ev_tstamp retval;
189 int count; 286 int count;
190 dSP; 287 dSP;
191 288
223 LEAVE; 320 LEAVE;
224 321
225 return retval; 322 return retval;
226} 323}
227 324
228/////////////////////////////////////////////////////////////////////////////
229// DNS
230
231#ifndef WIN32
232static void
233dns_cb (int result, char type, int count, int ttl, void *addresses, void *arg)
234{
235 dSP;
236 SV *cb = (SV *)arg;
237
238 ENTER;
239 SAVETMPS;
240 PUSHMARK (SP);
241 EXTEND (SP, count + 3);
242 PUSHs (sv_2mortal (newSViv (result)));
243
244 if (result == DNS_ERR_NONE && ttl >= 0)
245 {
246 int i;
247
248 PUSHs (sv_2mortal (newSViv (type)));
249 PUSHs (sv_2mortal (newSViv (ttl)));
250
251 for (i = 0; i < count; ++i)
252 switch (type)
253 {
254 case DNS_IPv6_AAAA:
255 PUSHs (sv_2mortal (newSVpvn (i * 16 + (char *)addresses, 16)));
256 break;
257 case DNS_IPv4_A:
258 PUSHs (sv_2mortal (newSVpvn (i * 4 + (char *)addresses, 4)));
259 break;
260 case DNS_PTR:
261 PUSHs (sv_2mortal (newSVpv (*(char **)addresses, 0)));
262 break;
263 }
264 }
265
266 PUTBACK;
267 call_sv (sv_2mortal (cb), G_DISCARD | G_VOID | G_EVAL);
268
269 FREETMPS;
270
271 if (SvTRUE (ERRSV))
272 {
273 PUSHMARK (SP);
274 PUTBACK;
275 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
276 }
277
278 LEAVE;
279}
280#endif
281
282#define CHECK_REPEAT(repeat) if (repeat < 0.) \ 325#define CHECK_REPEAT(repeat) if (repeat < 0.) \
283 croak (# repeat " value must be >= 0"); 326 croak (# repeat " value must be >= 0");
284 327
285#define CHECK_FD(fh,fd) if ((fd) < 0) \ 328#define CHECK_FD(fh,fd) if ((fd) < 0) \
286 croak ("illegal file descriptor or filehandle (either no attached file descriptor or illegal value): %s", SvPV_nolen (fh)); 329 croak ("illegal file descriptor or filehandle (either no attached file descriptor or illegal value): %s", SvPV_nolen (fh));
330
331#define CHECK_SIG(sv,num) if ((num) < 0) \
332 croak ("illegal signal number or name: %s", SvPV_nolen (sv));
287 333
288///////////////////////////////////////////////////////////////////////////// 334/////////////////////////////////////////////////////////////////////////////
289// XS interface functions 335// XS interface functions
290 336
291MODULE = EV PACKAGE = EV PREFIX = ev_ 337MODULE = EV PACKAGE = EV PREFIX = ev_
314 const_iv (EV_, CHECK) 360 const_iv (EV_, CHECK)
315 const_iv (EV_, ERROR) 361 const_iv (EV_, ERROR)
316 362
317 const_iv (EV, LOOP_ONESHOT) 363 const_iv (EV, LOOP_ONESHOT)
318 const_iv (EV, LOOP_NONBLOCK) 364 const_iv (EV, LOOP_NONBLOCK)
365 const_iv (EV, UNLOOP_ONE)
366 const_iv (EV, UNLOOP_ALL)
319 367
320 const_iv (EV, METHOD_AUTO)
321 const_iv (EV, METHOD_SELECT) 368 const_iv (EV, BACKEND_SELECT)
322 const_iv (EV, METHOD_POLL) 369 const_iv (EV, BACKEND_POLL)
323 const_iv (EV, METHOD_EPOLL) 370 const_iv (EV, BACKEND_EPOLL)
324 const_iv (EV, METHOD_KQUEUE) 371 const_iv (EV, BACKEND_KQUEUE)
325 const_iv (EV, METHOD_DEVPOLL) 372 const_iv (EV, BACKEND_DEVPOLL)
326 const_iv (EV, METHOD_PORT) 373 const_iv (EV, BACKEND_PORT)
327 const_iv (EV, METHOD_ANY) 374 const_iv (EV, FLAG_AUTO)
375 const_iv (EV, FLAG_NOENV)
376 const_iv (EV, FLAG_FORKCHECK)
328 }; 377 };
329 378
330 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; ) 379 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
331 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv)); 380 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
332 381
382 stash_loop = gv_stashpv ("EV::Loop" , 1);
333 stash_watcher = gv_stashpv ("EV::Watcher" , 1); 383 stash_watcher = gv_stashpv ("EV::Watcher" , 1);
334 stash_io = gv_stashpv ("EV::Io" , 1); 384 stash_io = gv_stashpv ("EV::IO" , 1);
335 stash_timer = gv_stashpv ("EV::Timer" , 1); 385 stash_timer = gv_stashpv ("EV::Timer" , 1);
336 stash_periodic = gv_stashpv ("EV::Periodic", 1); 386 stash_periodic = gv_stashpv ("EV::Periodic", 1);
337 stash_signal = gv_stashpv ("EV::Signal" , 1); 387 stash_signal = gv_stashpv ("EV::Signal" , 1);
338 stash_idle = gv_stashpv ("EV::Idle" , 1); 388 stash_idle = gv_stashpv ("EV::Idle" , 1);
339 stash_prepare = gv_stashpv ("EV::Prepare" , 1); 389 stash_prepare = gv_stashpv ("EV::Prepare" , 1);
340 stash_check = gv_stashpv ("EV::Check" , 1); 390 stash_check = gv_stashpv ("EV::Check" , 1);
341 stash_child = gv_stashpv ("EV::Child" , 1); 391 stash_child = gv_stashpv ("EV::Child" , 1);
392 stash_embed = gv_stashpv ("EV::Embed" , 1);
393 stash_stat = gv_stashpv ("EV::Stat" , 1);
394 stash_fork = gv_stashpv ("EV::Fork" , 1);
395 stash_async = gv_stashpv ("EV::Async" , 1);
342 396
343 { 397 {
344 SV *sv = perl_get_sv ("EV::API", TRUE); 398 SV *sv = perl_get_sv ("EV::API", TRUE);
345 perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */ 399 perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */
346 400
347 /* the poor man's shared library emulator */ 401 /* the poor man's shared library emulator */
348 evapi.ver = EV_API_VERSION; 402 evapi.ver = EV_API_VERSION;
349 evapi.rev = EV_API_REVISION; 403 evapi.rev = EV_API_REVISION;
350 evapi.sv_fileno = sv_fileno; 404 evapi.sv_fileno = sv_fileno;
351 evapi.sv_signum = sv_signum; 405 evapi.sv_signum = sv_signum;
406 evapi.supported_backends = ev_supported_backends ();
407 evapi.recommended_backends = ev_recommended_backends ();
408 evapi.embeddable_backends = ev_embeddable_backends ();
409 evapi.time_ = ev_time;
410 evapi.sleep_ = ev_sleep;
411 evapi.loop_new = ev_loop_new;
412 evapi.loop_destroy = ev_loop_destroy;
413 evapi.loop_fork = ev_loop_fork;
414 evapi.loop_count = ev_loop_count;
352 evapi.now = ev_now; 415 evapi.now = ev_now;
353 evapi.method = ev_method; 416 evapi.backend = ev_backend;
354 evapi.unloop = ev_unloop; 417 evapi.unloop = ev_unloop;
355 evapi.time = ev_time; 418 evapi.ref = ev_ref;
419 evapi.unref = ev_unref;
356 evapi.loop = ev_loop; 420 evapi.loop = ev_loop;
357 evapi.once = ev_once; 421 evapi.once = ev_once;
358 evapi.io_start = ev_io_start; 422 evapi.io_start = ev_io_start;
359 evapi.io_stop = ev_io_stop; 423 evapi.io_stop = ev_io_stop;
360 evapi.timer_start = ev_timer_start; 424 evapi.timer_start = ev_timer_start;
361 evapi.timer_stop = ev_timer_stop; 425 evapi.timer_stop = ev_timer_stop;
362 evapi.timer_again = ev_timer_again; 426 evapi.timer_again = ev_timer_again;
363 evapi.periodic_start = ev_periodic_start; 427 evapi.periodic_start = ev_periodic_start;
364 evapi.periodic_stop = ev_periodic_stop; 428 evapi.periodic_stop = ev_periodic_stop;
365 evapi.signal_start = ev_signal_start; 429 evapi.signal_start = ev_signal_start;
366 evapi.signal_stop = ev_signal_stop; 430 evapi.signal_stop = ev_signal_stop;
367 evapi.idle_start = ev_idle_start; 431 evapi.idle_start = ev_idle_start;
368 evapi.idle_stop = ev_idle_stop; 432 evapi.idle_stop = ev_idle_stop;
369 evapi.prepare_start = ev_prepare_start; 433 evapi.prepare_start = ev_prepare_start;
370 evapi.prepare_stop = ev_prepare_stop; 434 evapi.prepare_stop = ev_prepare_stop;
371 evapi.check_start = ev_check_start; 435 evapi.check_start = ev_check_start;
372 evapi.check_stop = ev_check_stop; 436 evapi.check_stop = ev_check_stop;
373 evapi.child_start = ev_child_start; 437 evapi.child_start = ev_child_start;
374 evapi.child_stop = ev_child_stop; 438 evapi.child_stop = ev_child_stop;
439 evapi.stat_start = ev_stat_start;
440 evapi.stat_stop = ev_stat_stop;
441 evapi.stat_stat = ev_stat_stat;
442 evapi.embed_start = ev_embed_start;
443 evapi.embed_stop = ev_embed_stop;
444 evapi.embed_sweep = ev_embed_sweep;
445 evapi.fork_start = ev_fork_start;
446 evapi.fork_stop = ev_fork_stop;
447 evapi.async_start = ev_async_start;
448 evapi.async_stop = ev_async_stop;
449 evapi.async_send = ev_async_send;
450 evapi.clear_pending = ev_clear_pending;
451 evapi.invoke = ev_invoke;
375 452
376 sv_setiv (sv, (IV)&evapi); 453 sv_setiv (sv, (IV)&evapi);
377 SvREADONLY_on (sv); 454 SvREADONLY_on (sv);
378 } 455 }
379#ifndef WIN32 456#ifndef _WIN32
380 pthread_atfork (0, 0, ev_default_fork); 457 pthread_atfork (0, 0, ev_default_fork);
381#endif 458#endif
382} 459}
383 460
461SV *ev_default_loop (unsigned int flags = 0)
462 CODE:
463{
464 if (!default_loop_sv)
465 {
466 evapi.default_loop = ev_default_loop (flags);
467
468 if (!evapi.default_loop)
469 XSRETURN_UNDEF;
470
471 default_loop_sv = sv_bless (newRV_noinc (newSViv (PTR2IV (evapi.default_loop))), stash_loop);
472 }
473
474 RETVAL = newSVsv (default_loop_sv);
475}
476 OUTPUT:
477 RETVAL
478
479void ev_default_destroy ()
480 CODE:
481 ev_default_destroy ();
482 SvREFCNT_dec (default_loop_sv);
483 default_loop_sv = 0;
484
485unsigned int ev_supported_backends ()
486
487unsigned int ev_recommended_backends ()
488
489unsigned int ev_embeddable_backends ()
490
491NV ev_time ()
492
384NV ev_now () 493NV ev_now ()
494 C_ARGS: evapi.default_loop
385 495
386int ev_method () 496unsigned int ev_backend ()
497 C_ARGS: evapi.default_loop
387 498
388NV ev_time () 499unsigned int ev_loop_count ()
500 C_ARGS: evapi.default_loop
389 501
390int ev_default_loop (int methods = EVMETHOD_AUTO) 502void ev_set_io_collect_interval (NV interval)
503 C_ARGS: evapi.default_loop, interval
504
505void ev_set_timeout_collect_interval (NV interval)
506 C_ARGS: evapi.default_loop, interval
391 507
392void ev_loop (int flags = 0) 508void ev_loop (int flags = 0)
509 C_ARGS: evapi.default_loop, flags
393 510
394void ev_unloop (int how = 1) 511void ev_unloop (int how = EVUNLOOP_ONE)
512 C_ARGS: evapi.default_loop, how
395 513
514void ev_feed_fd_event (int fd, int revents = EV_NONE)
515 C_ARGS: evapi.default_loop, fd, revents
516
517void ev_feed_signal_event (SV *signal)
518 CODE:
519{
520 Signal signum = sv_signum (signal);
521 CHECK_SIG (signal, signum);
522
523 ev_feed_signal_event (evapi.default_loop, signum);
524}
525
396struct ev_io *io (SV *fh, int events, SV *cb) 526ev_io *io (SV *fh, int events, SV *cb)
397 ALIAS: 527 ALIAS:
398 io_ns = 1 528 io_ns = 1
399 CODE: 529 CODE:
400{ 530{
401 int fd = sv_fileno (fh); 531 int fd = sv_fileno (fh);
402 CHECK_FD (fh, fd); 532 CHECK_FD (fh, fd);
403 533
404 RETVAL = e_new (sizeof (struct ev_io), cb); 534 RETVAL = e_new (sizeof (ev_io), cb, default_loop_sv);
405 RETVAL->fh = newSVsv (fh); 535 RETVAL->fh = newSVsv (fh);
406 ev_io_set (RETVAL, fd, events); 536 ev_io_set (RETVAL, fd, events);
407 if (!ix) ev_io_start (RETVAL); 537 if (!ix) START (io, RETVAL);
408} 538}
409 OUTPUT: 539 OUTPUT:
410 RETVAL 540 RETVAL
411 541
412struct ev_timer *timer (NV after, NV repeat, SV *cb) 542ev_timer *timer (NV after, NV repeat, SV *cb)
413 ALIAS: 543 ALIAS:
414 timer_ns = 1 544 timer_ns = 1
415 INIT: 545 INIT:
416 CHECK_REPEAT (repeat); 546 CHECK_REPEAT (repeat);
417 CODE: 547 CODE:
418 RETVAL = e_new (sizeof (struct ev_timer), cb); 548 RETVAL = e_new (sizeof (ev_timer), cb, default_loop_sv);
419 ev_timer_set (RETVAL, after, repeat); 549 ev_timer_set (RETVAL, after, repeat);
420 if (!ix) ev_timer_start (RETVAL); 550 if (!ix) START (timer, RETVAL);
421 OUTPUT: 551 OUTPUT:
422 RETVAL 552 RETVAL
423 553
424SV *periodic (NV at, NV interval, SV *reschedule_cb, SV *cb) 554SV *periodic (NV at, NV interval, SV *reschedule_cb, SV *cb)
425 ALIAS: 555 ALIAS:
426 periodic_ns = 1 556 periodic_ns = 1
427 INIT: 557 INIT:
428 CHECK_REPEAT (interval); 558 CHECK_REPEAT (interval);
429 CODE: 559 CODE:
430{ 560{
431 struct ev_periodic *w; 561 ev_periodic *w;
432 w = e_new (sizeof (struct ev_periodic), cb); 562 w = e_new (sizeof (ev_periodic), cb, default_loop_sv);
433 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0; 563 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
434 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0); 564 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0);
435 RETVAL = e_bless ((struct ev_watcher *)w, stash_periodic); 565 RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
436 if (!ix) ev_periodic_start (w); 566 if (!ix) START (periodic, w);
437} 567}
438 OUTPUT: 568 OUTPUT:
439 RETVAL 569 RETVAL
440 570
441struct ev_signal *signal (Signal signum, SV *cb) 571ev_signal *signal (SV *signal, SV *cb)
442 ALIAS: 572 ALIAS:
443 signal_ns = 1 573 signal_ns = 1
444 CODE: 574 CODE:
575{
576 Signal signum = sv_signum (signal);
577 CHECK_SIG (signal, signum);
578
445 RETVAL = e_new (sizeof (struct ev_signal), cb); 579 RETVAL = e_new (sizeof (ev_signal), cb, default_loop_sv);
446 ev_signal_set (RETVAL, signum); 580 ev_signal_set (RETVAL, signum);
447 if (!ix) ev_signal_start (RETVAL); 581 if (!ix) START (signal, RETVAL);
582}
448 OUTPUT: 583 OUTPUT:
449 RETVAL 584 RETVAL
450 585
451struct ev_idle *idle (SV *cb) 586ev_idle *idle (SV *cb)
452 ALIAS: 587 ALIAS:
453 idle_ns = 1 588 idle_ns = 1
454 CODE: 589 CODE:
455 RETVAL = e_new (sizeof (struct ev_idle), cb); 590 RETVAL = e_new (sizeof (ev_idle), cb, default_loop_sv);
456 ev_idle_set (RETVAL); 591 ev_idle_set (RETVAL);
457 if (!ix) ev_idle_start (RETVAL); 592 if (!ix) START (idle, RETVAL);
458 OUTPUT: 593 OUTPUT:
459 RETVAL 594 RETVAL
460 595
461struct ev_prepare *prepare (SV *cb) 596ev_prepare *prepare (SV *cb)
462 ALIAS: 597 ALIAS:
463 prepare_ns = 1 598 prepare_ns = 1
464 CODE: 599 CODE:
465 RETVAL = e_new (sizeof (struct ev_prepare), cb); 600 RETVAL = e_new (sizeof (ev_prepare), cb, default_loop_sv);
466 ev_prepare_set (RETVAL); 601 ev_prepare_set (RETVAL);
467 if (!ix) ev_prepare_start (RETVAL); 602 if (!ix) START (prepare, RETVAL);
468 OUTPUT: 603 OUTPUT:
469 RETVAL 604 RETVAL
470 605
471struct ev_check *check (SV *cb) 606ev_check *check (SV *cb)
472 ALIAS: 607 ALIAS:
473 check_ns = 1 608 check_ns = 1
474 CODE: 609 CODE:
475 RETVAL = e_new (sizeof (struct ev_check), cb); 610 RETVAL = e_new (sizeof (ev_check), cb, default_loop_sv);
476 ev_check_set (RETVAL); 611 ev_check_set (RETVAL);
477 if (!ix) ev_check_start (RETVAL); 612 if (!ix) START (check, RETVAL);
478 OUTPUT: 613 OUTPUT:
479 RETVAL 614 RETVAL
480 615
616ev_fork *fork (SV *cb)
617 ALIAS:
618 fork_ns = 1
619 CODE:
620 RETVAL = e_new (sizeof (ev_fork), cb, default_loop_sv);
621 ev_fork_set (RETVAL);
622 if (!ix) START (fork, RETVAL);
623 OUTPUT:
624 RETVAL
625
481struct ev_child *child (int pid, SV *cb) 626ev_child *child (int pid, int trace, SV *cb)
482 ALIAS: 627 ALIAS:
483 check_ns = 1 628 child_ns = 1
484 CODE: 629 CODE:
485 RETVAL = e_new (sizeof (struct ev_child), cb); 630 RETVAL = e_new (sizeof (ev_child), cb, default_loop_sv);
486 ev_child_set (RETVAL, pid); 631 ev_child_set (RETVAL, pid, trace);
487 if (!ix) ev_child_start (RETVAL); 632 if (!ix) START (child, RETVAL);
488 OUTPUT: 633 OUTPUT:
489 RETVAL 634 RETVAL
490 635
636ev_stat *stat (SV *path, NV interval, SV *cb)
637 ALIAS:
638 stat_ns = 1
639 CODE:
640 RETVAL = e_new (sizeof (ev_stat), cb, default_loop_sv);
641 RETVAL->fh = newSVsv (path);
642 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
643 if (!ix) START (stat, RETVAL);
644 OUTPUT:
645 RETVAL
646
647ev_embed *embed (struct ev_loop *loop, SV *cb = &PL_sv_undef)
648 ALIAS:
649 embed_ns = 1
650 CODE:
651{
652 if (!(ev_backend (loop) & ev_embeddable_backends ()))
653 croak ("passed loop is not embeddable via EV::embed,");
654
655 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
656 RETVAL->fh = newSVsv (ST (0));
657 ev_embed_set (RETVAL, loop);
658
659 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
660
661 if (!ix) START (embed, RETVAL);
662}
663 OUTPUT:
664 RETVAL
665
666ev_async *async (SV *cb)
667 ALIAS:
668 async_ns = 1
669 CODE:
670 RETVAL = e_new (sizeof (ev_async), cb, default_loop_sv);
671 ev_async_set (RETVAL);
672 if (!ix) START (async, RETVAL);
673 OUTPUT:
674 RETVAL
675
676void once (SV *fh, int events, SV *timeout, SV *cb)
677 CODE:
678 ev_once (
679 evapi.default_loop,
680 sv_fileno (fh), events,
681 SvOK (timeout) ? SvNV (timeout) : -1.,
682 e_once_cb,
683 newSVsv (cb)
684 );
491 685
492PROTOTYPES: DISABLE 686PROTOTYPES: DISABLE
493 687
494MODULE = EV PACKAGE = EV::Watcher PREFIX = ev_ 688MODULE = EV PACKAGE = EV::Watcher PREFIX = ev_
495 689
496int ev_is_active (struct ev_watcher *w) 690int ev_is_active (ev_watcher *w)
497 691
692int ev_is_pending (ev_watcher *w)
693
694void ev_invoke (ev_watcher *w, int revents = EV_NONE)
695 C_ARGS: e_loop (w), w, revents
696
697int ev_clear_pending (ev_watcher *w)
698 C_ARGS: e_loop (w), w
699
700void ev_feed_event (ev_watcher *w, int revents = EV_NONE)
701 C_ARGS: e_loop (w), w, revents
702
703int keepalive (ev_watcher *w, int new_value = 0)
704 CODE:
705{
706 RETVAL = w->e_flags & WFLAG_KEEPALIVE;
707 new_value = new_value ? WFLAG_KEEPALIVE : 0;
708
709 if (items > 1 && ((new_value ^ w->e_flags) & WFLAG_KEEPALIVE))
710 {
711 REF (w);
712 w->e_flags = (w->e_flags & ~WFLAG_KEEPALIVE) | new_value;
713 UNREF (w);
714 }
715}
716 OUTPUT:
717 RETVAL
718
498SV *cb (struct ev_watcher *w, SV *new_cb = 0) 719SV *cb (ev_watcher *w, SV *new_cb = 0)
499 CODE: 720 CODE:
500{ 721{
501 RETVAL = newSVsv (w->cb_sv);
502
503 if (items > 1) 722 if (items > 1)
504 sv_setsv (w->cb_sv, new_cb); 723 {
724 new_cb = e_get_cv (new_cb);
725 RETVAL = newRV_noinc (w->cb_sv);
726 w->cb_sv = SvREFCNT_inc (new_cb);
727 }
728 else
729 RETVAL = newRV_inc (w->cb_sv);
505} 730}
506 OUTPUT: 731 OUTPUT:
507 RETVAL 732 RETVAL
508 733
509SV *data (struct ev_watcher *w, SV *new_data = 0) 734SV *data (ev_watcher *w, SV *new_data = 0)
510 CODE: 735 CODE:
511{ 736{
512 RETVAL = w->data ? newSVsv (w->data) : &PL_sv_undef; 737 RETVAL = w->data ? newSVsv (w->data) : &PL_sv_undef;
513}
514 OUTPUT:
515 RETVAL
516 738
517void trigger (struct ev_watcher *w, int revents = EV_NONE) 739 if (items > 1)
518 CODE: 740 {
519 w->cb (w, revents); 741 SvREFCNT_dec (w->data);
742 w->data = newSVsv (new_data);
743 }
744}
745 OUTPUT:
746 RETVAL
520 747
748SV *loop (ev_watcher *w)
749 CODE:
750 RETVAL = newRV_inc (w->loop);
751 OUTPUT:
752 RETVAL
753
521int priority (struct ev_watcher *w, int new_priority = 0) 754int priority (ev_watcher *w, int new_priority = 0)
522 CODE: 755 CODE:
523{ 756{
524 RETVAL = w->priority; 757 RETVAL = w->priority;
525 758
526 if (items > 1) 759 if (items > 1)
527 { 760 {
528 int active = ev_is_active (w); 761 int active = ev_is_active (w);
529
530 if (new_priority < EV_MINPRI || new_priority > EV_MAXPRI)
531 croak ("watcher priority out of range, value must be between %d and %d, inclusive", EV_MINPRI, EV_MAXPRI);
532 762
533 if (active) 763 if (active)
534 { 764 {
535 /* grrr. */ 765 /* grrr. */
536 PUSHMARK (SP); 766 PUSHMARK (SP);
537 XPUSHs (ST (0)); 767 XPUSHs (ST (0));
768 PUTBACK;
538 call_method ("stop", G_DISCARD | G_VOID); 769 call_method ("stop", G_DISCARD | G_VOID);
539 } 770 }
540 771
541 ev_set_priority (w, new_priority); 772 ev_set_priority (w, new_priority);
542 773
543 if (active) 774 if (active)
544 { 775 {
545 PUSHMARK (SP); 776 PUSHMARK (SP);
546 XPUSHs (ST (0)); 777 XPUSHs (ST (0));
778 PUTBACK;
547 call_method ("start", G_DISCARD | G_VOID); 779 call_method ("start", G_DISCARD | G_VOID);
548 } 780 }
549 } 781 }
550} 782}
551 OUTPUT: 783 OUTPUT:
552 RETVAL 784 RETVAL
553 785
554MODULE = EV PACKAGE = EV::Io PREFIX = ev_io_ 786MODULE = EV PACKAGE = EV::IO PREFIX = ev_io_
555 787
556void ev_io_start (struct ev_io *w) 788void ev_io_start (ev_io *w)
789 CODE:
790 START (io, w);
557 791
558void ev_io_stop (struct ev_io *w) 792void ev_io_stop (ev_io *w)
793 CODE:
794 STOP (io, w);
559 795
560void DESTROY (struct ev_io *w) 796void DESTROY (ev_io *w)
561 CODE: 797 CODE:
562 ev_io_stop (w); 798 STOP (io, w);
563 e_destroy (w); 799 e_destroy (w);
564 800
565void set (struct ev_io *w, SV *fh, int events) 801void set (ev_io *w, SV *fh, int events)
566 CODE: 802 CODE:
567{ 803{
568 int active = ev_is_active (w);
569 int fd = sv_fileno (fh); 804 int fd = sv_fileno (fh);
570 CHECK_FD (fh, fd); 805 CHECK_FD (fh, fd);
571 806
572 if (active) ev_io_stop (w);
573
574 sv_setsv (w->fh, fh); 807 sv_setsv (w->fh, fh);
575 ev_io_set (w, fd, events); 808 RESET (io, w, (w, fd, events));
576
577 if (active) ev_io_start (w);
578} 809}
579 810
580SV *fh (struct ev_io *w, SV *new_fh = 0) 811SV *fh (ev_io *w, SV *new_fh = 0)
581 CODE: 812 CODE:
582{ 813{
583 RETVAL = newSVsv (w->fh);
584
585 if (items > 1) 814 if (items > 1)
586 { 815 {
587 int active = ev_is_active (w); 816 int fd = sv_fileno (new_fh);
588 if (active) ev_io_stop (w); 817 CHECK_FD (new_fh, fd);
589 818
590 sv_setsv (w->fh, new_fh); 819 RETVAL = w->fh;
591 ev_io_set (w, sv_fileno (w->fh), w->events); 820 w->fh = newSVsv (new_fh);
592 821
593 if (active) ev_io_start (w); 822 RESET (io, w, (w, fd, w->events));
594 } 823 }
824 else
825 RETVAL = newSVsv (w->fh);
595} 826}
596 OUTPUT: 827 OUTPUT:
597 RETVAL 828 RETVAL
598 829
599int events (struct ev_io *w, int new_events = EV_UNDEF) 830int events (ev_io *w, int new_events = EV_UNDEF)
600 CODE: 831 CODE:
601{ 832{
602 RETVAL = w->events; 833 RETVAL = w->events;
834
835 if (items > 1)
836 RESET (io, w, (w, w->fd, new_events));
837}
838 OUTPUT:
839 RETVAL
840
841MODULE = EV PACKAGE = EV::Signal PREFIX = ev_signal_
842
843void ev_signal_start (ev_signal *w)
844 CODE:
845 START (signal, w);
846
847void ev_signal_stop (ev_signal *w)
848 CODE:
849 STOP (signal, w);
850
851void DESTROY (ev_signal *w)
852 CODE:
853 STOP (signal, w);
854 e_destroy (w);
855
856void set (ev_signal *w, SV *signal)
857 CODE:
858{
859 Signal signum = sv_signum (signal);
860 CHECK_SIG (signal, signum);
861
862 RESET (signal, w, (w, signum));
863}
864
865int signal (ev_signal *w, SV *new_signal = 0)
866 CODE:
867{
868 RETVAL = w->signum;
603 869
604 if (items > 1) 870 if (items > 1)
605 { 871 {
606 int active = ev_is_active (w); 872 Signal signum = sv_signum (new_signal);
607 if (active) ev_io_stop (w); 873 CHECK_SIG (new_signal, signum);
608 874
609 ev_io_set (w, w->fd, new_events); 875 RESET (signal, w, (w, signum));
610
611 if (active) ev_io_start (w);
612 } 876 }
613} 877}
614 OUTPUT: 878 OUTPUT:
615 RETVAL 879 RETVAL
616 880
617MODULE = EV PACKAGE = EV::Signal PREFIX = ev_signal_ 881MODULE = EV PACKAGE = EV::Timer PREFIX = ev_timer_
618 882
619void ev_signal_start (struct ev_signal *w) 883void ev_timer_start (ev_timer *w)
620 884 INIT:
621void ev_signal_stop (struct ev_signal *w) 885 CHECK_REPEAT (w->repeat);
622
623void DESTROY (struct ev_signal *w)
624 CODE: 886 CODE:
625 ev_signal_stop (w); 887 START (timer, w);
888
889void ev_timer_stop (ev_timer *w)
890 CODE:
891 STOP (timer, w);
892
893void ev_timer_again (ev_timer *w)
894 INIT:
895 CHECK_REPEAT (w->repeat);
896 CODE:
897 REF (w);
898 ev_timer_again (e_loop (w), w);
899 UNREF (w);
900
901void DESTROY (ev_timer *w)
902 CODE:
903 STOP (timer, w);
626 e_destroy (w); 904 e_destroy (w);
627 905
628void set (struct ev_signal *w, SV *signal) 906void set (ev_timer *w, NV after, NV repeat = 0.)
907 INIT:
908 CHECK_REPEAT (repeat);
629 CODE: 909 CODE:
630{ 910 RESET (timer, w, (w, after, repeat));
631 Signal signum = sv_signum (signal); /* may croak here */
632 int active = ev_is_active (w);
633 911
634 if (active) ev_signal_stop (w); 912MODULE = EV PACKAGE = EV::Periodic PREFIX = ev_periodic_
635 913
636 ev_signal_set (w, signum); 914void ev_periodic_start (ev_periodic *w)
637 915 INIT:
638 if (active) ev_signal_start (w); 916 CHECK_REPEAT (w->interval);
639}
640
641int signal (struct ev_signal *w, SV *new_signal = 0)
642 CODE: 917 CODE:
918 START (periodic, w);
919
920void ev_periodic_stop (ev_periodic *w)
921 CODE:
922 STOP (periodic, w);
923
924void ev_periodic_again (ev_periodic *w)
925 CODE:
926 REF (w);
927 ev_periodic_again (e_loop (w), w);
928 UNREF (w);
929
930void DESTROY (ev_periodic *w)
931 CODE:
932 STOP (periodic, w);
933 e_destroy (w);
934
935void set (ev_periodic *w, NV at, NV interval = 0., SV *reschedule_cb = &PL_sv_undef)
936 INIT:
937 CHECK_REPEAT (interval);
938 CODE:
643{ 939{
644 RETVAL = w->signum; 940 SvREFCNT_dec (w->fh);
941 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
942
943 RESET (periodic, w, (w, at, interval, w->fh ? e_periodic_cb : 0));
944}
945
946NV at (ev_periodic *w)
947 CODE:
948 RETVAL = ev_periodic_at (w);
949 OUTPUT:
950 RETVAL
951
952MODULE = EV PACKAGE = EV::Idle PREFIX = ev_idle_
953
954void ev_idle_start (ev_idle *w)
955 CODE:
956 START (idle, w);
957
958void ev_idle_stop (ev_idle *w)
959 CODE:
960 STOP (idle, w);
961
962void DESTROY (ev_idle *w)
963 CODE:
964 STOP (idle, w);
965 e_destroy (w);
966
967MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_prepare_
968
969void ev_prepare_start (ev_prepare *w)
970 CODE:
971 START (prepare, w);
972
973void ev_prepare_stop (ev_prepare *w)
974 CODE:
975 STOP (prepare, w);
976
977void DESTROY (ev_prepare *w)
978 CODE:
979 STOP (prepare, w);
980 e_destroy (w);
981
982MODULE = EV PACKAGE = EV::Check PREFIX = ev_check_
983
984void ev_check_start (ev_check *w)
985 CODE:
986 START (check, w);
987
988void ev_check_stop (ev_check *w)
989 CODE:
990 STOP (check, w);
991
992void DESTROY (ev_check *w)
993 CODE:
994 STOP (check, w);
995 e_destroy (w);
996
997MODULE = EV PACKAGE = EV::Fork PREFIX = ev_fork_
998
999void ev_fork_start (ev_fork *w)
1000 CODE:
1001 START (fork, w);
1002
1003void ev_fork_stop (ev_fork *w)
1004 CODE:
1005 STOP (fork, w);
1006
1007void DESTROY (ev_fork *w)
1008 CODE:
1009 STOP (fork, w);
1010 e_destroy (w);
1011
1012MODULE = EV PACKAGE = EV::Child PREFIX = ev_child_
1013
1014void ev_child_start (ev_child *w)
1015 CODE:
1016 START (child, w);
1017
1018void ev_child_stop (ev_child *w)
1019 CODE:
1020 STOP (child, w);
1021
1022void DESTROY (ev_child *w)
1023 CODE:
1024 STOP (child, w);
1025 e_destroy (w);
1026
1027void set (ev_child *w, int pid, int trace)
1028 CODE:
1029 RESET (child, w, (w, pid, trace));
1030
1031int pid (ev_child *w)
1032 ALIAS:
1033 rpid = 1
1034 rstatus = 2
1035 CODE:
1036 RETVAL = ix == 0 ? w->pid
1037 : ix == 1 ? w->rpid
1038 : w->rstatus;
1039 OUTPUT:
1040 RETVAL
1041
1042MODULE = EV PACKAGE = EV::Stat PREFIX = ev_stat_
1043
1044void ev_stat_start (ev_stat *w)
1045 CODE:
1046 START (stat, w);
1047
1048void ev_stat_stop (ev_stat *w)
1049 CODE:
1050 STOP (stat, w);
1051
1052void DESTROY (ev_stat *w)
1053 CODE:
1054 STOP (stat, w);
1055 e_destroy (w);
1056
1057void set (ev_stat *w, SV *path, NV interval)
1058 CODE:
1059{
1060 sv_setsv (w->fh, path);
1061 RESET (stat, w, (w, SvPVbyte_nolen (w->fh), interval));
1062}
1063
1064SV *path (ev_stat *w, SV *new_path = 0)
1065 CODE:
1066{
1067 RETVAL = SvREFCNT_inc (w->fh);
645 1068
646 if (items > 1) 1069 if (items > 1)
647 { 1070 {
648 Signal signum = sv_signum (new_signal); /* may croak here */ 1071 SvREFCNT_dec (w->fh);
649 int active = ev_is_active (w); 1072 w->fh = newSVsv (new_path);
650 if (active) ev_signal_stop (w); 1073 RESET (stat, w, (w, SvPVbyte_nolen (w->fh), w->interval));
651
652 ev_signal_set (w, signum);
653
654 if (active) ev_signal_start (w);
655 } 1074 }
656} 1075}
657 OUTPUT: 1076 OUTPUT:
658 RETVAL 1077 RETVAL
659 1078
1079NV interval (ev_stat *w, NV new_interval = 0.)
1080 CODE:
1081{
1082 RETVAL = w->interval;
1083
1084 if (items > 1)
1085 RESET (stat, w, (w, SvPVbyte_nolen (w->fh), new_interval));
1086}
1087 OUTPUT:
1088 RETVAL
1089
1090void prev (ev_stat *w)
1091 ALIAS:
1092 stat = 1
1093 attr = 2
1094 PPCODE:
1095{
1096 ev_statdata *s = ix ? &w->attr : &w->prev;
1097
1098 if (ix == 1)
1099 ev_stat_stat (e_loop (w), w);
1100 else if (!s->st_nlink)
1101 errno = ENOENT;
1102
1103 PL_statcache.st_dev = s->st_nlink;
1104 PL_statcache.st_ino = s->st_ino;
1105 PL_statcache.st_mode = s->st_mode;
1106 PL_statcache.st_nlink = s->st_nlink;
1107 PL_statcache.st_uid = s->st_uid;
1108 PL_statcache.st_gid = s->st_gid;
1109 PL_statcache.st_rdev = s->st_rdev;
1110 PL_statcache.st_size = s->st_size;
1111 PL_statcache.st_atime = s->st_atime;
1112 PL_statcache.st_mtime = s->st_mtime;
1113 PL_statcache.st_ctime = s->st_ctime;
1114
1115 if (GIMME_V == G_SCALAR)
1116 XPUSHs (boolSV (s->st_nlink));
1117 else if (GIMME_V == G_ARRAY && s->st_nlink)
1118 {
1119 EXTEND (SP, 13);
1120 PUSHs (sv_2mortal (newSViv (s->st_dev)));
1121 PUSHs (sv_2mortal (newSViv (s->st_ino)));
1122 PUSHs (sv_2mortal (newSVuv (s->st_mode)));
1123 PUSHs (sv_2mortal (newSVuv (s->st_nlink)));
1124 PUSHs (sv_2mortal (newSViv (s->st_uid)));
1125 PUSHs (sv_2mortal (newSViv (s->st_gid)));
1126 PUSHs (sv_2mortal (newSViv (s->st_rdev)));
1127 PUSHs (sv_2mortal (newSVnv ((NV)s->st_size)));
1128 PUSHs (sv_2mortal (newSVnv (s->st_atime)));
1129 PUSHs (sv_2mortal (newSVnv (s->st_mtime)));
1130 PUSHs (sv_2mortal (newSVnv (s->st_ctime)));
1131 PUSHs (sv_2mortal (newSVuv (4096)));
1132 PUSHs (sv_2mortal (newSVnv ((NV)((s->st_size + 4095) / 4096))));
1133 }
1134}
1135
660MODULE = EV PACKAGE = EV::Timer PREFIX = ev_timer_ 1136MODULE = EV PACKAGE = EV::Embed PREFIX = ev_embed_
661 1137
662void ev_timer_start (struct ev_timer *w) 1138void ev_embed_start (ev_embed *w)
663 INIT: 1139 CODE:
664 CHECK_REPEAT (w->repeat); 1140 START (embed, w);
665 1141
666void ev_timer_stop (struct ev_timer *w) 1142void ev_embed_stop (ev_embed *w)
1143 CODE:
1144 STOP (embed, w);
667 1145
668void ev_timer_again (struct ev_timer *w)
669 INIT:
670 CHECK_REPEAT (w->repeat);
671
672void DESTROY (struct ev_timer *w) 1146void DESTROY (ev_embed *w)
673 CODE: 1147 CODE:
674 ev_timer_stop (w); 1148 STOP (embed, w);
675 e_destroy (w); 1149 e_destroy (w);
676 1150
677void set (struct ev_timer *w, NV after, NV repeat = 0.) 1151void set (ev_embed *w, struct ev_loop *loop)
1152 CODE:
1153{
1154 sv_setsv (w->fh, ST (1));
1155 RESET (embed, w, (w, loop));
1156}
1157
1158SV *other (ev_embed *w)
1159 CODE:
1160 RETVAL = newSVsv (w->fh);
1161 OUTPUT:
1162 RETVAL
1163
1164void ev_embed_sweep (ev_embed *w)
1165 C_ARGS: e_loop (w), w
1166
1167MODULE = EV PACKAGE = EV::Async PREFIX = ev_async_
1168
1169void ev_async_start (ev_async *w)
1170 CODE:
1171 START (async, w);
1172
1173void ev_async_stop (ev_async *w)
1174 CODE:
1175 STOP (async, w);
1176
1177void DESTROY (ev_async *w)
1178 CODE:
1179 STOP (async, w);
1180 e_destroy (w);
1181
1182void ev_async_send (ev_async *w)
1183 C_ARGS: e_loop (w), w
1184
1185SV *ev_async_async_pending (ev_async *w)
1186 CODE:
1187 RETVAL = boolSV (ev_async_pending (w));
1188 OUTPUT:
1189 RETVAL
1190
1191MODULE = EV PACKAGE = EV::Loop PREFIX = ev_
1192
1193SV *new (SV *klass, unsigned int flags = 0)
1194 CODE:
1195{
1196 struct ev_loop *loop = ev_loop_new (flags);
1197
1198 if (!loop)
1199 XSRETURN_UNDEF;
1200
1201 RETVAL = sv_bless (newRV_noinc (newSViv (PTR2IV (loop))), stash_loop);
1202}
1203 OUTPUT:
1204 RETVAL
1205
1206void DESTROY (struct ev_loop *loop)
1207 CODE:
1208 if (loop != evapi.default_loop) /* global destruction sucks */
1209 ev_loop_destroy (loop);
1210
1211void ev_loop_fork (struct ev_loop *loop)
1212
1213void ev_loop_verify (struct ev_loop *loop)
1214
1215NV ev_now (struct ev_loop *loop)
1216
1217void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1218
1219void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1220
1221unsigned int ev_backend (struct ev_loop *loop)
1222
1223unsigned int ev_loop_count (struct ev_loop *loop)
1224
1225void ev_loop (struct ev_loop *loop, int flags = 0)
1226
1227void ev_unloop (struct ev_loop *loop, int how = 1)
1228
1229void ev_feed_fd_event (struct ev_loop *loop, int fd, int revents = EV_NONE)
1230
1231#if 0
1232
1233void ev_feed_signal_event (struct ev_loop *loop, SV *signal)
1234 CODE:
1235{
1236 Signal signum = sv_signum (signal);
1237 CHECK_SIG (signal, signum);
1238
1239 ev_feed_signal_event (loop, signum);
1240}
1241
1242#endif
1243
1244ev_io *io (struct ev_loop *loop, SV *fh, int events, SV *cb)
1245 ALIAS:
1246 io_ns = 1
1247 CODE:
1248{
1249 int fd = sv_fileno (fh);
1250 CHECK_FD (fh, fd);
1251
1252 RETVAL = e_new (sizeof (ev_io), cb, ST (0));
1253 RETVAL->fh = newSVsv (fh);
1254 ev_io_set (RETVAL, fd, events);
1255 if (!ix) START (io, RETVAL);
1256}
1257 OUTPUT:
1258 RETVAL
1259
1260ev_timer *timer (struct ev_loop *loop, NV after, NV repeat, SV *cb)
1261 ALIAS:
1262 timer_ns = 1
678 INIT: 1263 INIT:
679 CHECK_REPEAT (repeat); 1264 CHECK_REPEAT (repeat);
680 CODE: 1265 CODE:
681{ 1266 RETVAL = e_new (sizeof (ev_timer), cb, ST (0));
682 int active = ev_is_active (w);
683 if (active) ev_timer_stop (w);
684 ev_timer_set (w, after, repeat); 1267 ev_timer_set (RETVAL, after, repeat);
685 if (active) ev_timer_start (w); 1268 if (!ix) START (timer, RETVAL);
686} 1269 OUTPUT:
1270 RETVAL
687 1271
688MODULE = EV PACKAGE = EV::Periodic PREFIX = ev_periodic_ 1272SV *periodic (struct ev_loop *loop, NV at, NV interval, SV *reschedule_cb, SV *cb)
689 1273 ALIAS:
690void ev_periodic_start (struct ev_periodic *w) 1274 periodic_ns = 1
691 INIT:
692 CHECK_REPEAT (w->interval);
693
694void ev_periodic_stop (struct ev_periodic *w)
695
696void ev_periodic_again (struct ev_periodic *w)
697
698void DESTROY (struct ev_periodic *w)
699 CODE:
700 ev_periodic_stop (w);
701 e_destroy (w);
702
703void set (struct ev_periodic *w, NV at, NV interval = 0., SV *reschedule_cb = &PL_sv_undef)
704 INIT: 1275 INIT:
705 CHECK_REPEAT (interval); 1276 CHECK_REPEAT (interval);
706 CODE: 1277 CODE:
707{ 1278{
708 int active = ev_is_active (w); 1279 ev_periodic *w;
709 if (active) ev_periodic_stop (w); 1280 w = e_new (sizeof (ev_periodic), cb, ST (0));
710
711 SvREFCNT_dec (w->fh);
712 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0; 1281 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
713 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0); 1282 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0);
714 1283 RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
715 if (active) ev_periodic_start (w); 1284 if (!ix) START (periodic, w);
716} 1285}
717
718MODULE = EV PACKAGE = EV::Idle PREFIX = ev_idle_
719
720void ev_idle_start (struct ev_idle *w)
721
722void ev_idle_stop (struct ev_idle *w)
723
724void DESTROY (struct ev_idle *w)
725 CODE:
726 ev_idle_stop (w);
727 e_destroy (w);
728
729MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_check_
730
731void ev_prepare_start (struct ev_prepare *w)
732
733void ev_prepare_stop (struct ev_prepare *w)
734
735void DESTROY (struct ev_prepare *w)
736 CODE:
737 ev_prepare_stop (w);
738 e_destroy (w);
739
740MODULE = EV PACKAGE = EV::Check PREFIX = ev_check_
741
742void ev_check_start (struct ev_check *w)
743
744void ev_check_stop (struct ev_check *w)
745
746void DESTROY (struct ev_check *w)
747 CODE:
748 ev_check_stop (w);
749 e_destroy (w);
750
751MODULE = EV PACKAGE = EV::Child PREFIX = ev_child_
752
753void ev_child_start (struct ev_child *w)
754
755void ev_child_stop (struct ev_child *w)
756
757void DESTROY (struct ev_child *w)
758 CODE:
759 ev_child_stop (w);
760 e_destroy (w);
761
762void set (struct ev_child *w, int pid)
763 CODE:
764{
765 int active = ev_is_active (w);
766 if (active) ev_child_stop (w);
767
768 ev_child_set (w, pid);
769
770 if (active) ev_child_start (w);
771}
772
773int pid (struct ev_child *w, int new_pid = 0)
774 CODE:
775{
776 RETVAL = w->pid;
777
778 if (items > 1)
779 {
780 int active = ev_is_active (w);
781 if (active) ev_child_stop (w);
782
783 ev_child_set (w, new_pid);
784
785 if (active) ev_child_start (w);
786 }
787}
788 OUTPUT: 1286 OUTPUT:
789 RETVAL
790
791
792int rstatus (struct ev_child *w)
793 ALIAS:
794 rpid = 1
795 CODE:
796 RETVAL = ix ? w->rpid : w->rstatus;
797 OUTPUT:
798 RETVAL
799
800#ifndef WIN32
801
802MODULE = EV PACKAGE = EV::DNS PREFIX = evdns_
803
804BOOT:
805{
806 HV *stash = gv_stashpv ("EV::DNS", 1);
807
808 static const struct {
809 const char *name;
810 IV iv;
811 } *civ, const_iv[] = {
812# define const_iv(pfx, name) { # name, (IV) pfx ## name },
813 const_iv (DNS_, ERR_NONE)
814 const_iv (DNS_, ERR_FORMAT)
815 const_iv (DNS_, ERR_SERVERFAILED)
816 const_iv (DNS_, ERR_NOTEXIST)
817 const_iv (DNS_, ERR_NOTIMPL)
818 const_iv (DNS_, ERR_REFUSED)
819 const_iv (DNS_, ERR_TRUNCATED)
820 const_iv (DNS_, ERR_UNKNOWN)
821 const_iv (DNS_, ERR_TIMEOUT)
822 const_iv (DNS_, ERR_SHUTDOWN)
823 const_iv (DNS_, IPv4_A)
824 const_iv (DNS_, PTR)
825 const_iv (DNS_, IPv6_AAAA)
826 const_iv (DNS_, QUERY_NO_SEARCH)
827 const_iv (DNS_, OPTION_SEARCH)
828 const_iv (DNS_, OPTION_NAMESERVERS)
829 const_iv (DNS_, OPTION_MISC)
830 const_iv (DNS_, OPTIONS_ALL)
831 const_iv (DNS_, NO_SEARCH)
832 };
833
834 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
835 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
836}
837
838int evdns_init ()
839
840void evdns_shutdown (int fail_requests = 1)
841
842const char *evdns_err_to_string (int err)
843
844int evdns_nameserver_add (U32 address)
845
846int evdns_count_nameservers ()
847
848int evdns_clear_nameservers_and_suspend ()
849
850int evdns_resume ()
851
852int evdns_nameserver_ip_add (char *ip_as_string)
853
854int evdns_resolve_ipv4 (const char *name, int flags, SV *cb)
855 C_ARGS: name, flags, dns_cb, (void *)SvREFCNT_inc (cb)
856
857int evdns_resolve_ipv6 (const char *name, int flags, SV *cb)
858 C_ARGS: name, flags, dns_cb, (void *)SvREFCNT_inc (cb)
859
860int evdns_resolve_reverse (SV *addr, int flags, SV *cb)
861 ALIAS:
862 evdns_resolve_reverse_ipv6 = 1
863 CODE:
864{
865 STRLEN len;
866 char *data = SvPVbyte (addr, len);
867 if (len != (ix ? 16 : 4))
868 croak ("ipv4/ipv6 address to be resolved must be given as 4/16 byte octet string");
869
870 RETVAL = ix 1287 RETVAL
871 ? evdns_resolve_reverse_ipv6 ((struct in6_addr *)data, flags, dns_cb, (void *)SvREFCNT_inc (cb))
872 : evdns_resolve_reverse ((struct in_addr *)data, flags, dns_cb, (void *)SvREFCNT_inc (cb));
873}
874 OUTPUT:
875 RETVAL
876 1288
877int evdns_set_option (char *option, char *val, int flags) 1289#if 0
878 1290
879int evdns_resolv_conf_parse (int flags, const char *filename) 1291ev_signal *signal (struct ev_loop *loop, SV *signal, SV *cb)
1292 ALIAS:
1293 signal_ns = 1
1294 CODE:
1295{
1296 Signal signum = sv_signum (signal);
1297 CHECK_SIG (signal, signum);
880 1298
881#ifdef MS_WINDOWS 1299 RETVAL = e_new (sizeof (ev_signal), cb, ST (0));
882 1300 ev_signal_set (RETVAL, signum);
883int evdns_config_windows_nameservers () 1301 if (!ix) START (signal, RETVAL);
1302}
1303 OUTPUT:
1304 RETVAL
884 1305
885#endif 1306#endif
886 1307
887void evdns_search_clear () 1308ev_idle *idle (struct ev_loop *loop, SV *cb)
1309 ALIAS:
1310 idle_ns = 1
1311 CODE:
1312 RETVAL = e_new (sizeof (ev_idle), cb, ST (0));
1313 ev_idle_set (RETVAL);
1314 if (!ix) START (idle, RETVAL);
1315 OUTPUT:
1316 RETVAL
888 1317
889void evdns_search_add (char *domain) 1318ev_prepare *prepare (struct ev_loop *loop, SV *cb)
1319 ALIAS:
1320 prepare_ns = 1
1321 CODE:
1322 RETVAL = e_new (sizeof (ev_prepare), cb, ST (0));
1323 ev_prepare_set (RETVAL);
1324 if (!ix) START (prepare, RETVAL);
1325 OUTPUT:
1326 RETVAL
890 1327
891void evdns_search_ndots_set (int ndots) 1328ev_check *check (struct ev_loop *loop, SV *cb)
1329 ALIAS:
1330 check_ns = 1
1331 CODE:
1332 RETVAL = e_new (sizeof (ev_check), cb, ST (0));
1333 ev_check_set (RETVAL);
1334 if (!ix) START (check, RETVAL);
1335 OUTPUT:
1336 RETVAL
892 1337
893#if 0 1338ev_fork *fork (struct ev_loop *loop, SV *cb)
1339 ALIAS:
1340 fork_ns = 1
1341 CODE:
1342 RETVAL = e_new (sizeof (ev_fork), cb, ST (0));
1343 ev_fork_set (RETVAL);
1344 if (!ix) START (fork, RETVAL);
1345 OUTPUT:
1346 RETVAL
894 1347
895MODULE = EV PACKAGE = EV::HTTP PREFIX = evhttp_ 1348ev_child *child (struct ev_loop *loop, int pid, int trace, SV *cb)
1349 ALIAS:
1350 child_ns = 1
1351 CODE:
1352 RETVAL = e_new (sizeof (ev_child), cb, ST (0));
1353 ev_child_set (RETVAL, pid, trace);
1354 if (!ix) START (child, RETVAL);
1355 OUTPUT:
1356 RETVAL
896 1357
897BOOT: 1358ev_stat *stat (struct ev_loop *loop, SV *path, NV interval, SV *cb)
898{ 1359 ALIAS:
899 HV *stash = gv_stashpv ("EV::HTTP", 1); 1360 stat_ns = 1
1361 CODE:
1362 RETVAL = e_new (sizeof (ev_stat), cb, ST (0));
1363 RETVAL->fh = newSVsv (path);
1364 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
1365 if (!ix) START (stat, RETVAL);
1366 OUTPUT:
1367 RETVAL
900 1368
901 static const struct { 1369ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = &PL_sv_undef)
902 const char *name; 1370 ALIAS:
903 IV iv; 1371 embed_ns = 1
904 } *civ, const_iv[] = { 1372 CODE:
905# define const_iv(pfx, name) { # name, (IV) pfx ## name }, 1373{
906 const_iv (HTTP_, OK) 1374 if (!(ev_backend (other) & ev_embeddable_backends ()))
907 const_iv (HTTP_, NOCONTENT) 1375 croak ("passed loop is not embeddable via EV::embed,");
908 const_iv (HTTP_, MOVEPERM)
909 const_iv (HTTP_, MOVETEMP)
910 const_iv (HTTP_, NOTMODIFIED)
911 const_iv (HTTP_, BADREQUEST)
912 const_iv (HTTP_, NOTFOUND)
913 const_iv (HTTP_, SERVUNAVAIL)
914 const_iv (EVHTTP_, REQ_OWN_CONNECTION)
915 const_iv (EVHTTP_, PROXY_REQUEST)
916 const_iv (EVHTTP_, REQ_GET)
917 const_iv (EVHTTP_, REQ_POST)
918 const_iv (EVHTTP_, REQ_HEAD)
919 const_iv (EVHTTP_, REQUEST)
920 const_iv (EVHTTP_, RESPONSE)
921 };
922 1376
923 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; ) 1377 RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
924 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv)); 1378 RETVAL->fh = newSVsv (ST (1));
925} 1379 ev_embed_set (RETVAL, other);
926 1380
927MODULE = EV PACKAGE = EV::HTTP::Request PREFIX = evhttp_request_ 1381 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
928 1382
929#HttpRequest new (SV *klass, SV *cb) 1383 if (!ix) START (embed, RETVAL);
1384}
1385 OUTPUT:
1386 RETVAL
930 1387
931#void DESTROY (struct evhttp_request *req); 1388ev_async *async (struct ev_loop *loop, SV *cb)
1389 ALIAS:
1390 async_ns = 1
1391 CODE:
1392 RETVAL = e_new (sizeof (ev_async), cb, ST (0));
1393 ev_async_set (RETVAL);
1394 if (!ix) START (async, RETVAL);
1395 OUTPUT:
1396 RETVAL
932 1397
933#endif 1398void once (struct ev_loop *loop, SV *fh, int events, SV *timeout, SV *cb)
1399 CODE:
1400 ev_once (
1401 loop,
1402 sv_fileno (fh), events,
1403 SvOK (timeout) ? SvNV (timeout) : -1.,
1404 e_once_cb,
1405 newSVsv (cb)
1406 );
934 1407
935#endif
936
937
938
939
940
941
942

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines