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

Comparing EV/EV.xs (file contents):
Revision 1.91 by root, Thu Dec 20 07:12:57 2007 UTC vs.
Revision 1.116 by root, Tue Oct 28 08:08:28 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
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"
13 15
14#define EV_SELECT_IS_WINSOCKET 0 16#define EV_SELECT_IS_WINSOCKET 0
15#ifdef _WIN32 17#ifdef _WIN32
16# define EV_SELECT_USE_FD_SET 0 18# define EV_SELECT_USE_FD_SET 0
17# define NFDBITS PERL_NFDBITS 19# define NFDBITS PERL_NFDBITS
18# define fd_mask Perl_fd_mask 20# define fd_mask Perl_fd_mask
19#endif 21#endif
20/* 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 */
21#include "libev/ev.c" 23#include "libev/ev.c"
22#include "event.c"
23 24
24#ifndef _WIN32 25#ifndef _WIN32
25# include <pthread.h> 26# include <pthread.h>
26#endif 27#endif
27 28
29/* 5.10.0 */
30#ifndef SvREFCNT_inc_NN
31# define SvREFCNT_inc_NN(sv) SvREFCNT_inc (sv)
32#endif
33
34#if __GNUC__ >= 3
35# define expect(expr,value) __builtin_expect ((expr),(value))
36#else
37# define expect(expr,value) (expr)
38#endif
39
40#define expect_false(expr) expect ((expr) != 0, 0)
41#define expect_true(expr) expect ((expr) != 0, 1)
42
43#define e_loop(w) INT2PTR (struct ev_loop *, SvIVX ((w)->loop))
44
28#define WFLAG_KEEPALIVE 1 45#define WFLAG_KEEPALIVE 1
29 46
30#define UNREF(w) \ 47#define UNREF(w) \
31 if (!((w)->flags & WFLAG_KEEPALIVE) \ 48 if (!((w)->e_flags & WFLAG_KEEPALIVE) \
32 && !ev_is_active (w)) \ 49 && !ev_is_active (w)) \
33 ev_unref (w->loop); 50 ev_unref (e_loop (w));
34 51
35#define REF(w) \ 52#define REF(w) \
36 if (!((w)->flags & WFLAG_KEEPALIVE) \ 53 if (!((w)->e_flags & WFLAG_KEEPALIVE) \
37 && ev_is_active (w)) \ 54 && ev_is_active (w)) \
38 ev_ref (w->loop); 55 ev_ref (e_loop (w));
39 56
40#define START(type,w) \ 57#define START(type,w) \
41 do { \ 58 do { \
42 UNREF (w); \ 59 UNREF (w); \
43 ev_ ## type ## _start (w->loop, w); \ 60 ev_ ## type ## _start (e_loop (w), w); \
44 } while (0) 61 } while (0)
45 62
46#define STOP(type,w) \ 63#define STOP(type,w) \
47 do { \ 64 do { \
48 REF (w); \ 65 REF (w); \
49 ev_ ## type ## _stop (w->loop, w); \ 66 ev_ ## type ## _stop (e_loop (w), w); \
50 } while (0) 67 } while (0)
51 68
52#define RESET(type,w,seta) \ 69#define RESET(type,w,seta) \
53 do { \ 70 do { \
54 int active = ev_is_active (w); \ 71 int active = ev_is_active (w); \
57 if (active) START (type, w); \ 74 if (active) START (type, w); \
58 } while (0) 75 } while (0)
59 76
60typedef int Signal; 77typedef int Signal;
61 78
79static SV *default_loop_sv;
80
62static struct EVAPI evapi; 81static struct EVAPI evapi;
63 82
64static HV 83static HV
84 *stash_loop,
65 *stash_watcher, 85 *stash_watcher,
66 *stash_io, 86 *stash_io,
67 *stash_timer, 87 *stash_timer,
68 *stash_periodic, 88 *stash_periodic,
69 *stash_signal, 89 *stash_signal,
71 *stash_stat, 91 *stash_stat,
72 *stash_idle, 92 *stash_idle,
73 *stash_prepare, 93 *stash_prepare,
74 *stash_check, 94 *stash_check,
75 *stash_embed, 95 *stash_embed,
76 *stash_fork; 96 *stash_fork,
97 *stash_async;
77 98
78#ifndef SIG_SIZE 99#ifndef SIG_SIZE
79/* kudos to Slaven Rezic for the idea */ 100/* kudos to Slaven Rezic for the idea */
80static char sig_size [] = { SIG_NUM }; 101static char sig_size [] = { SIG_NUM };
81# define SIG_SIZE (sizeof (sig_size) + 1) 102# define SIG_SIZE (sizeof (sig_size) + 1)
120 return SvIV (fh); 141 return SvIV (fh);
121 142
122 return -1; 143 return -1;
123} 144}
124 145
146static SV *
147e_get_cv (SV *cb_sv)
148{
149 HV *st;
150 GV *gvp;
151 CV *cv = sv_2cv (cb_sv, &st, &gvp, 0);
152
153 if (!cv)
154 croak ("EV watcher callback must be a CODE reference");
155
156 return (SV *)cv;
157}
158
125static void * 159static void *
126e_new (int size, SV *cb_sv) 160e_new (int size, SV *cb_sv, SV *loop)
127{ 161{
162 SV *cv = cb_sv ? e_get_cv (cb_sv) : 0;
128 ev_watcher *w; 163 ev_watcher *w;
129 SV *self = NEWSV (0, size); 164 SV *self = NEWSV (0, size);
130 SvPOK_only (self); 165 SvPOK_only (self);
131 SvCUR_set (self, size); 166 SvCUR_set (self, size);
132 167
133 w = (ev_watcher *)SvPVX (self); 168 w = (ev_watcher *)SvPVX (self);
134 169
135 ev_init (w, e_cb); 170 ev_init (w, cv ? e_cb : 0);
136 171
137 w->loop = EV_DEFAULT; 172 w->loop = SvREFCNT_inc (SvRV (loop));
138 w->flags = WFLAG_KEEPALIVE; 173 w->e_flags = WFLAG_KEEPALIVE;
139 w->data = 0; 174 w->data = 0;
140 w->fh = 0; 175 w->fh = 0;
141 w->cb_sv = newSVsv (cb_sv); 176 w->cb_sv = SvREFCNT_inc (cv);
142 w->self = self; 177 w->self = self;
143 178
144 return (void *)w; 179 return (void *)w;
145} 180}
146 181
147static void 182static void
148e_destroy (void *w_) 183e_destroy (void *w_)
149{ 184{
150 ev_watcher *w = (ev_watcher *)w_; 185 ev_watcher *w = (ev_watcher *)w_;
151 186
187 SvREFCNT_dec (w->loop ); w->loop = 0;
152 SvREFCNT_dec (w->fh ); w->fh = 0; 188 SvREFCNT_dec (w->fh ); w->fh = 0;
153 SvREFCNT_dec (w->cb_sv); w->cb_sv = 0; 189 SvREFCNT_dec (w->cb_sv); w->cb_sv = 0;
154 SvREFCNT_dec (w->data ); w->data = 0; 190 SvREFCNT_dec (w->data ); w->data = 0;
155} 191}
156 192
169 } 205 }
170 206
171 return rv; 207 return rv;
172} 208}
173 209
174static SV *sv_events_cache; 210static SV *sv_self_cache, *sv_events_cache;
175 211
176static void 212static void
177e_cb (EV_P_ ev_watcher *w, int revents) 213e_cb (EV_P_ ev_watcher *w, int revents)
178{ 214{
179 dSP; 215 dSP;
180 I32 mark = SP - PL_stack_base; 216 I32 mark = SP - PL_stack_base;
181 SV *sv_self, *sv_events; 217 SV *sv_self, *sv_events;
182 218
219 if (expect_true (sv_self_cache))
220 {
221 sv_self = sv_self_cache; sv_self_cache = 0;
222 SvRV_set (sv_self, SvREFCNT_inc_NN (w->self));
223 }
224 else
225 {
183 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */ 226 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */
227 SvREADONLY_on (sv_self);
228 }
184 229
185 if (sv_events_cache) 230 if (expect_true (sv_events_cache))
186 { 231 {
187 sv_events = sv_events_cache; sv_events_cache = 0; 232 sv_events = sv_events_cache; sv_events_cache = 0;
188 SvIV_set (sv_events, revents); 233 SvIV_set (sv_events, revents);
189 } 234 }
190 else 235 else
236 {
191 sv_events = newSViv (revents); 237 sv_events = newSViv (revents);
238 SvREADONLY_on (sv_events);
239 }
192 240
193 PUSHMARK (SP); 241 PUSHMARK (SP);
194 EXTEND (SP, 2); 242 EXTEND (SP, 2);
195 PUSHs (sv_self); 243 PUSHs (sv_self);
196 PUSHs (sv_events); 244 PUSHs (sv_events);
197 245
198 PUTBACK; 246 PUTBACK;
199 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL); 247 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
200 248
249 if (expect_false (sv_self_cache))
201 SvREFCNT_dec (sv_self); 250 SvREFCNT_dec (sv_self);
251 else
252 {
253 SvREFCNT_dec (SvRV (sv_self));
254 SvRV_set (sv_self, &PL_sv_undef);
255 sv_self_cache = sv_self;
256 }
202 257
203 if (sv_events_cache) 258 if (expect_false (sv_events_cache))
204 SvREFCNT_dec (sv_events); 259 SvREFCNT_dec (sv_events);
205 else 260 else
206 sv_events_cache = sv_events; 261 sv_events_cache = sv_events;
207 262
208 if (SvTRUE (ERRSV)) 263 if (SvTRUE (ERRSV))
355 }; 410 };
356 411
357 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; ) 412 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
358 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv)); 413 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
359 414
415 stash_loop = gv_stashpv ("EV::Loop" , 1);
360 stash_watcher = gv_stashpv ("EV::Watcher" , 1); 416 stash_watcher = gv_stashpv ("EV::Watcher" , 1);
361 stash_io = gv_stashpv ("EV::IO" , 1); 417 stash_io = gv_stashpv ("EV::IO" , 1);
362 stash_timer = gv_stashpv ("EV::Timer" , 1); 418 stash_timer = gv_stashpv ("EV::Timer" , 1);
363 stash_periodic = gv_stashpv ("EV::Periodic", 1); 419 stash_periodic = gv_stashpv ("EV::Periodic", 1);
364 stash_signal = gv_stashpv ("EV::Signal" , 1); 420 stash_signal = gv_stashpv ("EV::Signal" , 1);
367 stash_check = gv_stashpv ("EV::Check" , 1); 423 stash_check = gv_stashpv ("EV::Check" , 1);
368 stash_child = gv_stashpv ("EV::Child" , 1); 424 stash_child = gv_stashpv ("EV::Child" , 1);
369 stash_embed = gv_stashpv ("EV::Embed" , 1); 425 stash_embed = gv_stashpv ("EV::Embed" , 1);
370 stash_stat = gv_stashpv ("EV::Stat" , 1); 426 stash_stat = gv_stashpv ("EV::Stat" , 1);
371 stash_fork = gv_stashpv ("EV::Fork" , 1); 427 stash_fork = gv_stashpv ("EV::Fork" , 1);
428 stash_async = gv_stashpv ("EV::Async" , 1);
372 429
373 { 430 {
374 SV *sv = perl_get_sv ("EV::API", TRUE); 431 SV *sv = perl_get_sv ("EV::API", TRUE);
375 perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */ 432 perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */
376 433
380 evapi.sv_fileno = sv_fileno; 437 evapi.sv_fileno = sv_fileno;
381 evapi.sv_signum = sv_signum; 438 evapi.sv_signum = sv_signum;
382 evapi.supported_backends = ev_supported_backends (); 439 evapi.supported_backends = ev_supported_backends ();
383 evapi.recommended_backends = ev_recommended_backends (); 440 evapi.recommended_backends = ev_recommended_backends ();
384 evapi.embeddable_backends = ev_embeddable_backends (); 441 evapi.embeddable_backends = ev_embeddable_backends ();
385 evapi.time = ev_time; 442 evapi.time_ = ev_time;
443 evapi.sleep_ = ev_sleep;
386 evapi.loop_new = ev_loop_new; 444 evapi.loop_new = ev_loop_new;
387 evapi.loop_destroy = ev_loop_destroy; 445 evapi.loop_destroy = ev_loop_destroy;
388 evapi.loop_fork = ev_loop_fork; 446 evapi.loop_fork = ev_loop_fork;
389 evapi.loop_count = ev_loop_count; 447 evapi.loop_count = ev_loop_count;
390 evapi.now = ev_now; 448 evapi.now = ev_now;
449 evapi.now_update = ev_now_update;
391 evapi.backend = ev_backend; 450 evapi.backend = ev_backend;
392 evapi.unloop = ev_unloop; 451 evapi.unloop = ev_unloop;
393 evapi.ref = ev_ref; 452 evapi.ref = ev_ref;
394 evapi.unref = ev_unref; 453 evapi.unref = ev_unref;
395 evapi.loop = ev_loop; 454 evapi.loop = ev_loop;
417 evapi.embed_start = ev_embed_start; 476 evapi.embed_start = ev_embed_start;
418 evapi.embed_stop = ev_embed_stop; 477 evapi.embed_stop = ev_embed_stop;
419 evapi.embed_sweep = ev_embed_sweep; 478 evapi.embed_sweep = ev_embed_sweep;
420 evapi.fork_start = ev_fork_start; 479 evapi.fork_start = ev_fork_start;
421 evapi.fork_stop = ev_fork_stop; 480 evapi.fork_stop = ev_fork_stop;
481 evapi.async_start = ev_async_start;
482 evapi.async_stop = ev_async_stop;
483 evapi.async_send = ev_async_send;
422 evapi.clear_pending = ev_clear_pending; 484 evapi.clear_pending = ev_clear_pending;
423 evapi.invoke = ev_invoke; 485 evapi.invoke = ev_invoke;
424 486
425 sv_setiv (sv, (IV)&evapi); 487 sv_setiv (sv, (IV)&evapi);
426 SvREADONLY_on (sv); 488 SvREADONLY_on (sv);
428#ifndef _WIN32 490#ifndef _WIN32
429 pthread_atfork (0, 0, ev_default_fork); 491 pthread_atfork (0, 0, ev_default_fork);
430#endif 492#endif
431} 493}
432 494
433SV *ev_default_loop (unsigned int flags = ev_supported_backends ()) 495SV *ev_default_loop (unsigned int flags = 0)
434 CODE: 496 CODE:
435{ 497{
498 if (!default_loop_sv)
499 {
436 evapi.default_loop = ev_default_loop (flags); 500 evapi.default_loop = ev_default_loop (flags);
501
437 if (!evapi.default_loop) 502 if (!evapi.default_loop)
438 XSRETURN_UNDEF; 503 XSRETURN_UNDEF;
439 504
440 RETVAL = sv_bless (newRV_noinc (newSViv (PTR2IV (ev_default_loop (flags)))), 505 default_loop_sv = sv_bless (newRV_noinc (newSViv (PTR2IV (evapi.default_loop))), stash_loop);
441 gv_stashpv ("EV::Loop::Default", 1)); 506 }
507
508 RETVAL = newSVsv (default_loop_sv);
442} 509}
443 OUTPUT: 510 OUTPUT:
444 RETVAL 511 RETVAL
512
513void ev_default_destroy ()
514 CODE:
515 ev_default_destroy ();
516 SvREFCNT_dec (default_loop_sv);
517 default_loop_sv = 0;
518
519unsigned int ev_supported_backends ()
520
521unsigned int ev_recommended_backends ()
522
523unsigned int ev_embeddable_backends ()
445 524
446NV ev_time () 525NV ev_time ()
447 526
448NV ev_now () 527NV ev_now ()
449 C_ARGS: evapi.default_loop 528 C_ARGS: evapi.default_loop
450 529
530void ev_now_update ()
531 C_ARGS: evapi.default_loop
532
451unsigned int ev_backend () 533unsigned int ev_backend ()
452 C_ARGS: evapi.default_loop 534 C_ARGS: evapi.default_loop
453 535
454unsigned int ev_loop_count () 536unsigned int ev_loop_count ()
455 C_ARGS: evapi.default_loop 537 C_ARGS: evapi.default_loop
456 538
539void ev_set_io_collect_interval (NV interval)
540 C_ARGS: evapi.default_loop, interval
541
542void ev_set_timeout_collect_interval (NV interval)
543 C_ARGS: evapi.default_loop, interval
544
457void ev_loop (int flags = 0) 545void ev_loop (int flags = 0)
458 C_ARGS: evapi.default_loop, flags 546 C_ARGS: evapi.default_loop, flags
459 547
460void ev_unloop (int how = 1) 548void ev_unloop (int how = EVUNLOOP_ONE)
461 C_ARGS: evapi.default_loop, how 549 C_ARGS: evapi.default_loop, how
462 550
463void ev_feed_fd_event (int fd, int revents = EV_NONE) 551void ev_feed_fd_event (int fd, int revents = EV_NONE)
464 C_ARGS: evapi.default_loop, fd, revents 552 C_ARGS: evapi.default_loop, fd, revents
465 553
478 CODE: 566 CODE:
479{ 567{
480 int fd = sv_fileno (fh); 568 int fd = sv_fileno (fh);
481 CHECK_FD (fh, fd); 569 CHECK_FD (fh, fd);
482 570
483 RETVAL = e_new (sizeof (ev_io), cb); 571 RETVAL = e_new (sizeof (ev_io), cb, default_loop_sv);
484 RETVAL->fh = newSVsv (fh); 572 RETVAL->fh = newSVsv (fh);
485 ev_io_set (RETVAL, fd, events); 573 ev_io_set (RETVAL, fd, events);
486 if (!ix) START (io, RETVAL); 574 if (!ix) START (io, RETVAL);
487} 575}
488 OUTPUT: 576 OUTPUT:
492 ALIAS: 580 ALIAS:
493 timer_ns = 1 581 timer_ns = 1
494 INIT: 582 INIT:
495 CHECK_REPEAT (repeat); 583 CHECK_REPEAT (repeat);
496 CODE: 584 CODE:
497 RETVAL = e_new (sizeof (ev_timer), cb); 585 RETVAL = e_new (sizeof (ev_timer), cb, default_loop_sv);
498 ev_timer_set (RETVAL, after, repeat); 586 ev_timer_set (RETVAL, after, repeat);
499 if (!ix) START (timer, RETVAL); 587 if (!ix) START (timer, RETVAL);
500 OUTPUT: 588 OUTPUT:
501 RETVAL 589 RETVAL
502 590
506 INIT: 594 INIT:
507 CHECK_REPEAT (interval); 595 CHECK_REPEAT (interval);
508 CODE: 596 CODE:
509{ 597{
510 ev_periodic *w; 598 ev_periodic *w;
511 w = e_new (sizeof (ev_periodic), cb); 599 w = e_new (sizeof (ev_periodic), cb, default_loop_sv);
512 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0; 600 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
513 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0); 601 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0);
514 RETVAL = e_bless ((ev_watcher *)w, stash_periodic); 602 RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
515 if (!ix) START (periodic, w); 603 if (!ix) START (periodic, w);
516} 604}
523 CODE: 611 CODE:
524{ 612{
525 Signal signum = sv_signum (signal); 613 Signal signum = sv_signum (signal);
526 CHECK_SIG (signal, signum); 614 CHECK_SIG (signal, signum);
527 615
528 RETVAL = e_new (sizeof (ev_signal), cb); 616 RETVAL = e_new (sizeof (ev_signal), cb, default_loop_sv);
529 ev_signal_set (RETVAL, signum); 617 ev_signal_set (RETVAL, signum);
530 if (!ix) START (signal, RETVAL); 618 if (!ix) START (signal, RETVAL);
531} 619}
532 OUTPUT: 620 OUTPUT:
533 RETVAL 621 RETVAL
534 622
535ev_idle *idle (SV *cb) 623ev_idle *idle (SV *cb)
536 ALIAS: 624 ALIAS:
537 idle_ns = 1 625 idle_ns = 1
538 CODE: 626 CODE:
539 RETVAL = e_new (sizeof (ev_idle), cb); 627 RETVAL = e_new (sizeof (ev_idle), cb, default_loop_sv);
540 ev_idle_set (RETVAL); 628 ev_idle_set (RETVAL);
541 if (!ix) START (idle, RETVAL); 629 if (!ix) START (idle, RETVAL);
542 OUTPUT: 630 OUTPUT:
543 RETVAL 631 RETVAL
544 632
545ev_prepare *prepare (SV *cb) 633ev_prepare *prepare (SV *cb)
546 ALIAS: 634 ALIAS:
547 prepare_ns = 1 635 prepare_ns = 1
548 CODE: 636 CODE:
549 RETVAL = e_new (sizeof (ev_prepare), cb); 637 RETVAL = e_new (sizeof (ev_prepare), cb, default_loop_sv);
550 ev_prepare_set (RETVAL); 638 ev_prepare_set (RETVAL);
551 if (!ix) START (prepare, RETVAL); 639 if (!ix) START (prepare, RETVAL);
552 OUTPUT: 640 OUTPUT:
553 RETVAL 641 RETVAL
554 642
555ev_check *check (SV *cb) 643ev_check *check (SV *cb)
556 ALIAS: 644 ALIAS:
557 check_ns = 1 645 check_ns = 1
558 CODE: 646 CODE:
559 RETVAL = e_new (sizeof (ev_check), cb); 647 RETVAL = e_new (sizeof (ev_check), cb, default_loop_sv);
560 ev_check_set (RETVAL); 648 ev_check_set (RETVAL);
561 if (!ix) START (check, RETVAL); 649 if (!ix) START (check, RETVAL);
562 OUTPUT: 650 OUTPUT:
563 RETVAL 651 RETVAL
564 652
565ev_fork *fork (SV *cb) 653ev_fork *fork (SV *cb)
566 ALIAS: 654 ALIAS:
567 fork_ns = 1 655 fork_ns = 1
568 CODE: 656 CODE:
569 RETVAL = e_new (sizeof (ev_fork), cb); 657 RETVAL = e_new (sizeof (ev_fork), cb, default_loop_sv);
570 ev_fork_set (RETVAL); 658 ev_fork_set (RETVAL);
571 if (!ix) START (fork, RETVAL); 659 if (!ix) START (fork, RETVAL);
572 OUTPUT: 660 OUTPUT:
573 RETVAL 661 RETVAL
574 662
575ev_child *child (int pid, SV *cb) 663ev_child *child (int pid, int trace, SV *cb)
576 ALIAS: 664 ALIAS:
577 child_ns = 1 665 child_ns = 1
578 CODE: 666 CODE:
579 RETVAL = e_new (sizeof (ev_child), cb); 667 RETVAL = e_new (sizeof (ev_child), cb, default_loop_sv);
580 ev_child_set (RETVAL, pid); 668 ev_child_set (RETVAL, pid, trace);
581 if (!ix) START (child, RETVAL); 669 if (!ix) START (child, RETVAL);
582 OUTPUT: 670 OUTPUT:
583 RETVAL 671 RETVAL
584 672
585ev_stat *stat (SV *path, NV interval, SV *cb) 673ev_stat *stat (SV *path, NV interval, SV *cb)
586 ALIAS: 674 ALIAS:
587 stat_ns = 1 675 stat_ns = 1
588 CODE: 676 CODE:
589 RETVAL = e_new (sizeof (ev_stat), cb); 677 RETVAL = e_new (sizeof (ev_stat), cb, default_loop_sv);
590 RETVAL->fh = newSVsv (path); 678 RETVAL->fh = newSVsv (path);
591 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 679 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
592 if (!ix) START (stat, RETVAL); 680 if (!ix) START (stat, RETVAL);
681 OUTPUT:
682 RETVAL
683
684ev_embed *embed (struct ev_loop *loop, SV *cb = 0)
685 ALIAS:
686 embed_ns = 1
687 CODE:
688{
689 if (!(ev_backend (loop) & ev_embeddable_backends ()))
690 croak ("passed loop is not embeddable via EV::embed,");
691
692 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
693 RETVAL->fh = newSVsv (ST (0));
694 ev_embed_set (RETVAL, loop);
695 if (!ix) START (embed, RETVAL);
696}
697 OUTPUT:
698 RETVAL
699
700ev_async *async (SV *cb)
701 ALIAS:
702 async_ns = 1
703 CODE:
704 RETVAL = e_new (sizeof (ev_async), cb, default_loop_sv);
705 ev_async_set (RETVAL);
706 if (!ix) START (async, RETVAL);
593 OUTPUT: 707 OUTPUT:
594 RETVAL 708 RETVAL
595 709
596void once (SV *fh, int events, SV *timeout, SV *cb) 710void once (SV *fh, int events, SV *timeout, SV *cb)
597 CODE: 711 CODE:
610int ev_is_active (ev_watcher *w) 724int ev_is_active (ev_watcher *w)
611 725
612int ev_is_pending (ev_watcher *w) 726int ev_is_pending (ev_watcher *w)
613 727
614void ev_invoke (ev_watcher *w, int revents = EV_NONE) 728void ev_invoke (ev_watcher *w, int revents = EV_NONE)
615 C_ARGS: w->loop, w, revents 729 C_ARGS: e_loop (w), w, revents
616 730
617int ev_clear_pending (ev_watcher *w) 731int ev_clear_pending (ev_watcher *w)
618 C_ARGS: w->loop, w 732 C_ARGS: e_loop (w), w
619 733
620void ev_feed_event (ev_watcher *w, int revents = EV_NONE) 734void ev_feed_event (ev_watcher *w, int revents = EV_NONE)
621 C_ARGS: w->loop, w, revents 735 C_ARGS: e_loop (w), w, revents
622 736
623int keepalive (ev_watcher *w, int new_value = 0) 737int keepalive (ev_watcher *w, int new_value = 0)
624 CODE: 738 CODE:
625{ 739{
626 RETVAL = w->flags & WFLAG_KEEPALIVE; 740 RETVAL = w->e_flags & WFLAG_KEEPALIVE;
627 new_value = new_value ? WFLAG_KEEPALIVE : 0; 741 new_value = new_value ? WFLAG_KEEPALIVE : 0;
628 742
629 if (items > 1 && ((new_value ^ w->flags) & WFLAG_KEEPALIVE)) 743 if (items > 1 && ((new_value ^ w->e_flags) & WFLAG_KEEPALIVE))
630 { 744 {
631 REF (w); 745 REF (w);
632 w->flags = (w->flags & ~WFLAG_KEEPALIVE) | new_value; 746 w->e_flags = (w->e_flags & ~WFLAG_KEEPALIVE) | new_value;
633 UNREF (w); 747 UNREF (w);
634 } 748 }
635} 749}
636 OUTPUT: 750 OUTPUT:
637 RETVAL 751 RETVAL
638 752
639SV *cb (ev_watcher *w, SV *new_cb = 0) 753SV *cb (ev_watcher *w, SV *new_cb = 0)
640 CODE: 754 CODE:
641{ 755{
642 RETVAL = newSVsv (w->cb_sv);
643
644 if (items > 1) 756 if (items > 1)
645 sv_setsv (w->cb_sv, new_cb); 757 {
758 new_cb = e_get_cv (new_cb);
759 RETVAL = newRV_noinc (w->cb_sv);
760 w->cb_sv = SvREFCNT_inc (new_cb);
761 }
762 else
763 RETVAL = newRV_inc (w->cb_sv);
646} 764}
647 OUTPUT: 765 OUTPUT:
648 RETVAL 766 RETVAL
649 767
650SV *data (ev_watcher *w, SV *new_data = 0) 768SV *data (ev_watcher *w, SV *new_data = 0)
656 { 774 {
657 SvREFCNT_dec (w->data); 775 SvREFCNT_dec (w->data);
658 w->data = newSVsv (new_data); 776 w->data = newSVsv (new_data);
659 } 777 }
660} 778}
779 OUTPUT:
780 RETVAL
781
782SV *loop (ev_watcher *w)
783 CODE:
784 RETVAL = newRV_inc (w->loop);
661 OUTPUT: 785 OUTPUT:
662 RETVAL 786 RETVAL
663 787
664int priority (ev_watcher *w, int new_priority = 0) 788int priority (ev_watcher *w, int new_priority = 0)
665 CODE: 789 CODE:
803void ev_timer_again (ev_timer *w) 927void ev_timer_again (ev_timer *w)
804 INIT: 928 INIT:
805 CHECK_REPEAT (w->repeat); 929 CHECK_REPEAT (w->repeat);
806 CODE: 930 CODE:
807 REF (w); 931 REF (w);
808 ev_timer_again (w->loop, w); 932 ev_timer_again (e_loop (w), w);
809 UNREF (w); 933 UNREF (w);
810 934
811void DESTROY (ev_timer *w) 935void DESTROY (ev_timer *w)
812 CODE: 936 CODE:
813 STOP (timer, w); 937 STOP (timer, w);
817 INIT: 941 INIT:
818 CHECK_REPEAT (repeat); 942 CHECK_REPEAT (repeat);
819 CODE: 943 CODE:
820 RESET (timer, w, (w, after, repeat)); 944 RESET (timer, w, (w, after, repeat));
821 945
822NV at (ev_timer *w)
823 CODE:
824 RETVAL = w->at;
825 OUTPUT:
826 RETVAL
827
828MODULE = EV PACKAGE = EV::Periodic PREFIX = ev_periodic_ 946MODULE = EV PACKAGE = EV::Periodic PREFIX = ev_periodic_
829 947
830void ev_periodic_start (ev_periodic *w) 948void ev_periodic_start (ev_periodic *w)
831 INIT: 949 INIT:
832 CHECK_REPEAT (w->interval); 950 CHECK_REPEAT (w->interval);
838 STOP (periodic, w); 956 STOP (periodic, w);
839 957
840void ev_periodic_again (ev_periodic *w) 958void ev_periodic_again (ev_periodic *w)
841 CODE: 959 CODE:
842 REF (w); 960 REF (w);
843 ev_periodic_again (w->loop, w); 961 ev_periodic_again (e_loop (w), w);
844 UNREF (w); 962 UNREF (w);
845 963
846void DESTROY (ev_periodic *w) 964void DESTROY (ev_periodic *w)
847 CODE: 965 CODE:
848 STOP (periodic, w); 966 STOP (periodic, w);
859 RESET (periodic, w, (w, at, interval, w->fh ? e_periodic_cb : 0)); 977 RESET (periodic, w, (w, at, interval, w->fh ? e_periodic_cb : 0));
860} 978}
861 979
862NV at (ev_periodic *w) 980NV at (ev_periodic *w)
863 CODE: 981 CODE:
864 RETVAL = w->at; 982 RETVAL = ev_periodic_at (w);
865 OUTPUT: 983 OUTPUT:
866 RETVAL 984 RETVAL
867 985
868MODULE = EV PACKAGE = EV::Idle PREFIX = ev_idle_ 986MODULE = EV PACKAGE = EV::Idle PREFIX = ev_idle_
869 987
878void DESTROY (ev_idle *w) 996void DESTROY (ev_idle *w)
879 CODE: 997 CODE:
880 STOP (idle, w); 998 STOP (idle, w);
881 e_destroy (w); 999 e_destroy (w);
882 1000
883MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_check_ 1001MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_prepare_
884 1002
885void ev_prepare_start (ev_prepare *w) 1003void ev_prepare_start (ev_prepare *w)
886 CODE: 1004 CODE:
887 START (prepare, w); 1005 START (prepare, w);
888 1006
938void DESTROY (ev_child *w) 1056void DESTROY (ev_child *w)
939 CODE: 1057 CODE:
940 STOP (child, w); 1058 STOP (child, w);
941 e_destroy (w); 1059 e_destroy (w);
942 1060
943void set (ev_child *w, int pid) 1061void set (ev_child *w, int pid, int trace)
944 CODE: 1062 CODE:
945 RESET (child, w, (w, pid)); 1063 RESET (child, w, (w, pid, trace));
946 1064
947int pid (ev_child *w, int new_pid = 0)
948 CODE:
949{
950 RETVAL = w->pid;
951
952 if (items > 1)
953 RESET (child, w, (w, new_pid));
954}
955 OUTPUT:
956 RETVAL
957
958
959int rstatus (ev_child *w) 1065int pid (ev_child *w)
960 ALIAS: 1066 ALIAS:
961 rpid = 1 1067 rpid = 1
1068 rstatus = 2
962 CODE: 1069 CODE:
963 RETVAL = ix ? w->rpid : w->rstatus; 1070 RETVAL = ix == 0 ? w->pid
1071 : ix == 1 ? w->rpid
1072 : w->rstatus;
964 OUTPUT: 1073 OUTPUT:
965 RETVAL 1074 RETVAL
966 1075
967MODULE = EV PACKAGE = EV::Stat PREFIX = ev_stat_ 1076MODULE = EV PACKAGE = EV::Stat PREFIX = ev_stat_
968 1077
1019 PPCODE: 1128 PPCODE:
1020{ 1129{
1021 ev_statdata *s = ix ? &w->attr : &w->prev; 1130 ev_statdata *s = ix ? &w->attr : &w->prev;
1022 1131
1023 if (ix == 1) 1132 if (ix == 1)
1024 ev_stat_stat (w->loop, w); 1133 ev_stat_stat (e_loop (w), w);
1025 else if (!s->st_nlink) 1134 else if (!s->st_nlink)
1026 errno = ENOENT; 1135 errno = ENOENT;
1027 1136
1028 PL_statcache.st_dev = s->st_nlink; 1137 PL_statcache.st_dev = s->st_nlink;
1029 PL_statcache.st_ino = s->st_ino; 1138 PL_statcache.st_ino = s->st_ino;
1056 PUSHs (sv_2mortal (newSVuv (4096))); 1165 PUSHs (sv_2mortal (newSVuv (4096)));
1057 PUSHs (sv_2mortal (newSVnv ((NV)((s->st_size + 4095) / 4096)))); 1166 PUSHs (sv_2mortal (newSVnv ((NV)((s->st_size + 4095) / 4096))));
1058 } 1167 }
1059} 1168}
1060 1169
1170MODULE = EV PACKAGE = EV::Embed PREFIX = ev_embed_
1171
1172void ev_embed_start (ev_embed *w)
1173 CODE:
1174 START (embed, w);
1175
1176void ev_embed_stop (ev_embed *w)
1177 CODE:
1178 STOP (embed, w);
1179
1180void DESTROY (ev_embed *w)
1181 CODE:
1182 STOP (embed, w);
1183 e_destroy (w);
1184
1185void set (ev_embed *w, struct ev_loop *loop)
1186 CODE:
1187{
1188 sv_setsv (w->fh, ST (1));
1189 RESET (embed, w, (w, loop));
1190}
1191
1192SV *other (ev_embed *w)
1193 CODE:
1194 RETVAL = newSVsv (w->fh);
1195 OUTPUT:
1196 RETVAL
1197
1198void ev_embed_sweep (ev_embed *w)
1199 C_ARGS: e_loop (w), w
1200
1201MODULE = EV PACKAGE = EV::Async PREFIX = ev_async_
1202
1203void ev_async_start (ev_async *w)
1204 CODE:
1205 START (async, w);
1206
1207void ev_async_stop (ev_async *w)
1208 CODE:
1209 STOP (async, w);
1210
1211void DESTROY (ev_async *w)
1212 CODE:
1213 STOP (async, w);
1214 e_destroy (w);
1215
1216void ev_async_send (ev_async *w)
1217 C_ARGS: e_loop (w), w
1218
1219SV *ev_async_async_pending (ev_async *w)
1220 CODE:
1221 RETVAL = boolSV (ev_async_pending (w));
1222 OUTPUT:
1223 RETVAL
1224
1225MODULE = EV PACKAGE = EV::Loop PREFIX = ev_
1226
1227SV *new (SV *klass, unsigned int flags = 0)
1228 CODE:
1229{
1230 struct ev_loop *loop = ev_loop_new (flags);
1231
1232 if (!loop)
1233 XSRETURN_UNDEF;
1234
1235 RETVAL = sv_bless (newRV_noinc (newSViv (PTR2IV (loop))), stash_loop);
1236}
1237 OUTPUT:
1238 RETVAL
1239
1240void DESTROY (struct ev_loop *loop)
1241 CODE:
1242 if (loop != evapi.default_loop) /* global destruction sucks */
1243 ev_loop_destroy (loop);
1244
1245void ev_loop_fork (struct ev_loop *loop)
1246
1247void ev_loop_verify (struct ev_loop *loop)
1248
1249NV ev_now (struct ev_loop *loop)
1250
1251void ev_now_update (struct ev_loop *loop)
1252
1253void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1254
1255void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1256
1257unsigned int ev_backend (struct ev_loop *loop)
1258
1259unsigned int ev_loop_count (struct ev_loop *loop)
1260
1261void ev_loop (struct ev_loop *loop, int flags = 0)
1262
1263void ev_unloop (struct ev_loop *loop, int how = 1)
1264
1265void ev_feed_fd_event (struct ev_loop *loop, int fd, int revents = EV_NONE)
1266
1061#if 0 1267#if 0
1062 1268
1063MODULE = EV PACKAGE = EV::HTTP PREFIX = evhttp_ 1269void ev_feed_signal_event (struct ev_loop *loop, SV *signal)
1064 1270 CODE:
1065BOOT:
1066{ 1271{
1067 HV *stash = gv_stashpv ("EV::HTTP", 1); 1272 Signal signum = sv_signum (signal);
1273 CHECK_SIG (signal, signum);
1068 1274
1069 static const struct { 1275 ev_feed_signal_event (loop, signum);
1070 const char *name;
1071 IV iv;
1072 } *civ, const_iv[] = {
1073# define const_iv(pfx, name) { # name, (IV) pfx ## name },
1074 const_iv (HTTP_, OK)
1075 const_iv (HTTP_, NOCONTENT)
1076 const_iv (HTTP_, MOVEPERM)
1077 const_iv (HTTP_, MOVETEMP)
1078 const_iv (HTTP_, NOTMODIFIED)
1079 const_iv (HTTP_, BADREQUEST)
1080 const_iv (HTTP_, NOTFOUND)
1081 const_iv (HTTP_, SERVUNAVAIL)
1082 const_iv (EVHTTP_, REQ_OWN_CONNECTION)
1083 const_iv (EVHTTP_, PROXY_REQUEST)
1084 const_iv (EVHTTP_, REQ_GET)
1085 const_iv (EVHTTP_, REQ_POST)
1086 const_iv (EVHTTP_, REQ_HEAD)
1087 const_iv (EVHTTP_, REQUEST)
1088 const_iv (EVHTTP_, RESPONSE)
1089 };
1090
1091 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
1092 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
1093} 1276}
1094
1095MODULE = EV PACKAGE = EV::HTTP::Request PREFIX = evhttp_request_
1096
1097#HttpRequest new (SV *klass, SV *cb)
1098
1099#void DESTROY (struct evhttp_request *req);
1100 1277
1101#endif 1278#endif
1102 1279
1280ev_io *io (struct ev_loop *loop, SV *fh, int events, SV *cb)
1281 ALIAS:
1282 io_ns = 1
1283 CODE:
1284{
1285 int fd = sv_fileno (fh);
1286 CHECK_FD (fh, fd);
1103 1287
1288 RETVAL = e_new (sizeof (ev_io), cb, ST (0));
1289 RETVAL->fh = newSVsv (fh);
1290 ev_io_set (RETVAL, fd, events);
1291 if (!ix) START (io, RETVAL);
1292}
1293 OUTPUT:
1294 RETVAL
1104 1295
1296ev_timer *timer (struct ev_loop *loop, NV after, NV repeat, SV *cb)
1297 ALIAS:
1298 timer_ns = 1
1299 INIT:
1300 CHECK_REPEAT (repeat);
1301 CODE:
1302 RETVAL = e_new (sizeof (ev_timer), cb, ST (0));
1303 ev_timer_set (RETVAL, after, repeat);
1304 if (!ix) START (timer, RETVAL);
1305 OUTPUT:
1306 RETVAL
1105 1307
1308SV *periodic (struct ev_loop *loop, NV at, NV interval, SV *reschedule_cb, SV *cb)
1309 ALIAS:
1310 periodic_ns = 1
1311 INIT:
1312 CHECK_REPEAT (interval);
1313 CODE:
1314{
1315 ev_periodic *w;
1316 w = e_new (sizeof (ev_periodic), cb, ST (0));
1317 w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
1318 ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0);
1319 RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
1320 if (!ix) START (periodic, w);
1321}
1322 OUTPUT:
1323 RETVAL
1106 1324
1325#if 0
1107 1326
1327ev_signal *signal (struct ev_loop *loop, SV *signal, SV *cb)
1328 ALIAS:
1329 signal_ns = 1
1330 CODE:
1331{
1332 Signal signum = sv_signum (signal);
1333 CHECK_SIG (signal, signum);
1108 1334
1335 RETVAL = e_new (sizeof (ev_signal), cb, ST (0));
1336 ev_signal_set (RETVAL, signum);
1337 if (!ix) START (signal, RETVAL);
1338}
1339 OUTPUT:
1340 RETVAL
1109 1341
1342#endif
1343
1344ev_idle *idle (struct ev_loop *loop, SV *cb)
1345 ALIAS:
1346 idle_ns = 1
1347 CODE:
1348 RETVAL = e_new (sizeof (ev_idle), cb, ST (0));
1349 ev_idle_set (RETVAL);
1350 if (!ix) START (idle, RETVAL);
1351 OUTPUT:
1352 RETVAL
1353
1354ev_prepare *prepare (struct ev_loop *loop, SV *cb)
1355 ALIAS:
1356 prepare_ns = 1
1357 CODE:
1358 RETVAL = e_new (sizeof (ev_prepare), cb, ST (0));
1359 ev_prepare_set (RETVAL);
1360 if (!ix) START (prepare, RETVAL);
1361 OUTPUT:
1362 RETVAL
1363
1364ev_check *check (struct ev_loop *loop, SV *cb)
1365 ALIAS:
1366 check_ns = 1
1367 CODE:
1368 RETVAL = e_new (sizeof (ev_check), cb, ST (0));
1369 ev_check_set (RETVAL);
1370 if (!ix) START (check, RETVAL);
1371 OUTPUT:
1372 RETVAL
1373
1374ev_fork *fork (struct ev_loop *loop, SV *cb)
1375 ALIAS:
1376 fork_ns = 1
1377 CODE:
1378 RETVAL = e_new (sizeof (ev_fork), cb, ST (0));
1379 ev_fork_set (RETVAL);
1380 if (!ix) START (fork, RETVAL);
1381 OUTPUT:
1382 RETVAL
1383
1384ev_child *child (struct ev_loop *loop, int pid, int trace, SV *cb)
1385 ALIAS:
1386 child_ns = 1
1387 CODE:
1388 RETVAL = e_new (sizeof (ev_child), cb, ST (0));
1389 ev_child_set (RETVAL, pid, trace);
1390 if (!ix) START (child, RETVAL);
1391 OUTPUT:
1392 RETVAL
1393
1394ev_stat *stat (struct ev_loop *loop, SV *path, NV interval, SV *cb)
1395 ALIAS:
1396 stat_ns = 1
1397 CODE:
1398 RETVAL = e_new (sizeof (ev_stat), cb, ST (0));
1399 RETVAL->fh = newSVsv (path);
1400 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
1401 if (!ix) START (stat, RETVAL);
1402 OUTPUT:
1403 RETVAL
1404
1405ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = 0)
1406 ALIAS:
1407 embed_ns = 1
1408 CODE:
1409{
1410 if (!(ev_backend (other) & ev_embeddable_backends ()))
1411 croak ("passed loop is not embeddable via EV::embed,");
1412
1413 RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
1414 RETVAL->fh = newSVsv (ST (1));
1415 ev_embed_set (RETVAL, other);
1416 if (!ix) START (embed, RETVAL);
1417}
1418 OUTPUT:
1419 RETVAL
1420
1421ev_async *async (struct ev_loop *loop, SV *cb)
1422 ALIAS:
1423 async_ns = 1
1424 CODE:
1425 RETVAL = e_new (sizeof (ev_async), cb, ST (0));
1426 ev_async_set (RETVAL);
1427 if (!ix) START (async, RETVAL);
1428 OUTPUT:
1429 RETVAL
1430
1431void once (struct ev_loop *loop, SV *fh, int events, SV *timeout, SV *cb)
1432 CODE:
1433 ev_once (
1434 loop,
1435 sv_fileno (fh), events,
1436 SvOK (timeout) ? SvNV (timeout) : -1.,
1437 e_once_cb,
1438 newSVsv (cb)
1439 );
1440

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines