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

Comparing EV/EV.xs (file contents):
Revision 1.112 by root, Tue May 20 23:49:41 2008 UTC vs.
Revision 1.116 by root, Tue Oct 28 08:08:28 2008 UTC

… …
23#include "libev/ev.c" 23#include "libev/ev.c"
24 24
25#ifndef _WIN32 25#ifndef _WIN32
26# include <pthread.h> 26# include <pthread.h>
27#endif 27#endif
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)
28 42
29#define e_loop(w) INT2PTR (struct ev_loop *, SvIVX ((w)->loop)) 43#define e_loop(w) INT2PTR (struct ev_loop *, SvIVX ((w)->loop))
30 44
31#define WFLAG_KEEPALIVE 1 45#define WFLAG_KEEPALIVE 1
32 46
… …
143} 157}
144 158
145static void * 159static void *
146e_new (int size, SV *cb_sv, SV *loop) 160e_new (int size, SV *cb_sv, SV *loop)
147{ 161{
148 SV *cv = e_get_cv (cb_sv); 162 SV *cv = cb_sv ? e_get_cv (cb_sv) : 0;
149 ev_watcher *w; 163 ev_watcher *w;
150 SV *self = NEWSV (0, size); 164 SV *self = NEWSV (0, size);
151 SvPOK_only (self); 165 SvPOK_only (self);
152 SvCUR_set (self, size); 166 SvCUR_set (self, size);
153 167
154 w = (ev_watcher *)SvPVX (self); 168 w = (ev_watcher *)SvPVX (self);
155 169
156 ev_init (w, e_cb); 170 ev_init (w, cv ? e_cb : 0);
157 171
158 w->loop = SvREFCNT_inc (SvRV (loop)); 172 w->loop = SvREFCNT_inc (SvRV (loop));
159 w->e_flags = WFLAG_KEEPALIVE; 173 w->e_flags = WFLAG_KEEPALIVE;
160 w->data = 0; 174 w->data = 0;
161 w->fh = 0; 175 w->fh = 0;
… …
191 } 205 }
192 206
193 return rv; 207 return rv;
194} 208}
195 209
196static SV *sv_events_cache; 210static SV *sv_self_cache, *sv_events_cache;
197 211
198static void 212static void
199e_cb (EV_P_ ev_watcher *w, int revents) 213e_cb (EV_P_ ev_watcher *w, int revents)
200{ 214{
201 dSP; 215 dSP;
202 I32 mark = SP - PL_stack_base; 216 I32 mark = SP - PL_stack_base;
203 SV *sv_self, *sv_events; 217 SV *sv_self, *sv_events;
204 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 {
205 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 }
206 229
207 if (sv_events_cache) 230 if (expect_true (sv_events_cache))
208 { 231 {
209 sv_events = sv_events_cache; sv_events_cache = 0; 232 sv_events = sv_events_cache; sv_events_cache = 0;
210 SvIV_set (sv_events, revents); 233 SvIV_set (sv_events, revents);
211 } 234 }
212 else 235 else
236 {
213 sv_events = newSViv (revents); 237 sv_events = newSViv (revents);
238 SvREADONLY_on (sv_events);
239 }
214 240
215 PUSHMARK (SP); 241 PUSHMARK (SP);
216 EXTEND (SP, 2); 242 EXTEND (SP, 2);
217 PUSHs (sv_self); 243 PUSHs (sv_self);
218 PUSHs (sv_events); 244 PUSHs (sv_events);
219 245
220 PUTBACK; 246 PUTBACK;
221 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL); 247 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
222 248
249 if (expect_false (sv_self_cache))
223 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 }
224 257
225 if (sv_events_cache) 258 if (expect_false (sv_events_cache))
226 SvREFCNT_dec (sv_events); 259 SvREFCNT_dec (sv_events);
227 else 260 else
228 sv_events_cache = sv_events; 261 sv_events_cache = sv_events;
229 262
230 if (SvTRUE (ERRSV)) 263 if (SvTRUE (ERRSV))
… …
411 evapi.loop_new = ev_loop_new; 444 evapi.loop_new = ev_loop_new;
412 evapi.loop_destroy = ev_loop_destroy; 445 evapi.loop_destroy = ev_loop_destroy;
413 evapi.loop_fork = ev_loop_fork; 446 evapi.loop_fork = ev_loop_fork;
414 evapi.loop_count = ev_loop_count; 447 evapi.loop_count = ev_loop_count;
415 evapi.now = ev_now; 448 evapi.now = ev_now;
449 evapi.now_update = ev_now_update;
416 evapi.backend = ev_backend; 450 evapi.backend = ev_backend;
417 evapi.unloop = ev_unloop; 451 evapi.unloop = ev_unloop;
418 evapi.ref = ev_ref; 452 evapi.ref = ev_ref;
419 evapi.unref = ev_unref; 453 evapi.unref = ev_unref;
420 evapi.loop = ev_loop; 454 evapi.loop = ev_loop;
… …
491NV ev_time () 525NV ev_time ()
492 526
493NV ev_now () 527NV ev_now ()
494 C_ARGS: evapi.default_loop 528 C_ARGS: evapi.default_loop
495 529
530void ev_now_update ()
531 C_ARGS: evapi.default_loop
532
496unsigned int ev_backend () 533unsigned int ev_backend ()
497 C_ARGS: evapi.default_loop 534 C_ARGS: evapi.default_loop
498 535
499unsigned int ev_loop_count () 536unsigned int ev_loop_count ()
500 C_ARGS: evapi.default_loop 537 C_ARGS: evapi.default_loop
… …
642 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 679 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
643 if (!ix) START (stat, RETVAL); 680 if (!ix) START (stat, RETVAL);
644 OUTPUT: 681 OUTPUT:
645 RETVAL 682 RETVAL
646 683
647ev_embed *embed (struct ev_loop *loop, SV *cb = &PL_sv_undef) 684ev_embed *embed (struct ev_loop *loop, SV *cb = 0)
648 ALIAS: 685 ALIAS:
649 embed_ns = 1 686 embed_ns = 1
650 CODE: 687 CODE:
651{ 688{
652 if (!(ev_backend (loop) & ev_embeddable_backends ())) 689 if (!(ev_backend (loop) & ev_embeddable_backends ()))
653 croak ("passed loop is not embeddable via EV::embed,"); 690 croak ("passed loop is not embeddable via EV::embed,");
654 691
655 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv); 692 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
656 RETVAL->fh = newSVsv (ST (0)); 693 RETVAL->fh = newSVsv (ST (0));
657 ev_embed_set (RETVAL, loop); 694 ev_embed_set (RETVAL, loop);
658
659 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
660
661 if (!ix) START (embed, RETVAL); 695 if (!ix) START (embed, RETVAL);
662} 696}
663 OUTPUT: 697 OUTPUT:
664 RETVAL 698 RETVAL
665 699
… …
1208 if (loop != evapi.default_loop) /* global destruction sucks */ 1242 if (loop != evapi.default_loop) /* global destruction sucks */
1209 ev_loop_destroy (loop); 1243 ev_loop_destroy (loop);
1210 1244
1211void ev_loop_fork (struct ev_loop *loop) 1245void ev_loop_fork (struct ev_loop *loop)
1212 1246
1247void ev_loop_verify (struct ev_loop *loop)
1248
1213NV ev_now (struct ev_loop *loop) 1249NV ev_now (struct ev_loop *loop)
1250
1251void ev_now_update (struct ev_loop *loop)
1214 1252
1215void ev_set_io_collect_interval (struct ev_loop *loop, NV interval) 1253void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1216 1254
1217void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval) 1255void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1218 1256
… …
1362 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 1400 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
1363 if (!ix) START (stat, RETVAL); 1401 if (!ix) START (stat, RETVAL);
1364 OUTPUT: 1402 OUTPUT:
1365 RETVAL 1403 RETVAL
1366 1404
1367ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = &PL_sv_undef) 1405ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = 0)
1368 ALIAS: 1406 ALIAS:
1369 embed_ns = 1 1407 embed_ns = 1
1370 CODE: 1408 CODE:
1371{ 1409{
1372 if (!(ev_backend (other) & ev_embeddable_backends ())) 1410 if (!(ev_backend (other) & ev_embeddable_backends ()))
1373 croak ("passed loop is not embeddable via EV::embed,"); 1411 croak ("passed loop is not embeddable via EV::embed,");
1374 1412
1375 RETVAL = e_new (sizeof (ev_embed), cb, ST (0)); 1413 RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
1376 RETVAL->fh = newSVsv (ST (1)); 1414 RETVAL->fh = newSVsv (ST (1));
1377 ev_embed_set (RETVAL, other); 1415 ev_embed_set (RETVAL, other);
1378
1379 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
1380
1381 if (!ix) START (embed, RETVAL); 1416 if (!ix) START (embed, RETVAL);
1382} 1417}
1383 OUTPUT: 1418 OUTPUT:
1384 RETVAL 1419 RETVAL
1385 1420

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines