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

Comparing EV/EV.xs (file contents):
Revision 1.113 by root, Thu May 22 02:44:57 2008 UTC vs.
Revision 1.115 by root, Mon Sep 8 17:27:42 2008 UTC

… …
143} 143}
144 144
145static void * 145static void *
146e_new (int size, SV *cb_sv, SV *loop) 146e_new (int size, SV *cb_sv, SV *loop)
147{ 147{
148 SV *cv = e_get_cv (cb_sv); 148 SV *cv = cb_sv ? e_get_cv (cb_sv) : 0;
149 ev_watcher *w; 149 ev_watcher *w;
150 SV *self = NEWSV (0, size); 150 SV *self = NEWSV (0, size);
151 SvPOK_only (self); 151 SvPOK_only (self);
152 SvCUR_set (self, size); 152 SvCUR_set (self, size);
153 153
154 w = (ev_watcher *)SvPVX (self); 154 w = (ev_watcher *)SvPVX (self);
155 155
156 ev_init (w, e_cb); 156 ev_init (w, cv ? e_cb : 0);
157 157
158 w->loop = SvREFCNT_inc (SvRV (loop)); 158 w->loop = SvREFCNT_inc (SvRV (loop));
159 w->e_flags = WFLAG_KEEPALIVE; 159 w->e_flags = WFLAG_KEEPALIVE;
160 w->data = 0; 160 w->data = 0;
161 w->fh = 0; 161 w->fh = 0;
… …
411 evapi.loop_new = ev_loop_new; 411 evapi.loop_new = ev_loop_new;
412 evapi.loop_destroy = ev_loop_destroy; 412 evapi.loop_destroy = ev_loop_destroy;
413 evapi.loop_fork = ev_loop_fork; 413 evapi.loop_fork = ev_loop_fork;
414 evapi.loop_count = ev_loop_count; 414 evapi.loop_count = ev_loop_count;
415 evapi.now = ev_now; 415 evapi.now = ev_now;
416 evapi.now_update = ev_now_update;
416 evapi.backend = ev_backend; 417 evapi.backend = ev_backend;
417 evapi.unloop = ev_unloop; 418 evapi.unloop = ev_unloop;
418 evapi.ref = ev_ref; 419 evapi.ref = ev_ref;
419 evapi.unref = ev_unref; 420 evapi.unref = ev_unref;
420 evapi.loop = ev_loop; 421 evapi.loop = ev_loop;
… …
491NV ev_time () 492NV ev_time ()
492 493
493NV ev_now () 494NV ev_now ()
494 C_ARGS: evapi.default_loop 495 C_ARGS: evapi.default_loop
495 496
497void ev_now_update ()
498 C_ARGS: evapi.default_loop
499
496unsigned int ev_backend () 500unsigned int ev_backend ()
497 C_ARGS: evapi.default_loop 501 C_ARGS: evapi.default_loop
498 502
499unsigned int ev_loop_count () 503unsigned int ev_loop_count ()
500 C_ARGS: evapi.default_loop 504 C_ARGS: evapi.default_loop
… …
642 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 646 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
643 if (!ix) START (stat, RETVAL); 647 if (!ix) START (stat, RETVAL);
644 OUTPUT: 648 OUTPUT:
645 RETVAL 649 RETVAL
646 650
647ev_embed *embed (struct ev_loop *loop, SV *cb = &PL_sv_undef) 651ev_embed *embed (struct ev_loop *loop, SV *cb = 0)
648 ALIAS: 652 ALIAS:
649 embed_ns = 1 653 embed_ns = 1
650 CODE: 654 CODE:
651{ 655{
652 if (!(ev_backend (loop) & ev_embeddable_backends ())) 656 if (!(ev_backend (loop) & ev_embeddable_backends ()))
653 croak ("passed loop is not embeddable via EV::embed,"); 657 croak ("passed loop is not embeddable via EV::embed,");
654 658
655 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv); 659 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
656 RETVAL->fh = newSVsv (ST (0)); 660 RETVAL->fh = newSVsv (ST (0));
657 ev_embed_set (RETVAL, loop); 661 ev_embed_set (RETVAL, loop);
658
659 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
660
661 if (!ix) START (embed, RETVAL); 662 if (!ix) START (embed, RETVAL);
662} 663}
663 OUTPUT: 664 OUTPUT:
664 RETVAL 665 RETVAL
665 666
… …
1212 1213
1213void ev_loop_verify (struct ev_loop *loop) 1214void ev_loop_verify (struct ev_loop *loop)
1214 1215
1215NV ev_now (struct ev_loop *loop) 1216NV ev_now (struct ev_loop *loop)
1216 1217
1218void ev_now_update (struct ev_loop *loop)
1219
1217void ev_set_io_collect_interval (struct ev_loop *loop, NV interval) 1220void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1218 1221
1219void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval) 1222void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1220 1223
1221unsigned int ev_backend (struct ev_loop *loop) 1224unsigned int ev_backend (struct ev_loop *loop)
… …
1364 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 1367 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
1365 if (!ix) START (stat, RETVAL); 1368 if (!ix) START (stat, RETVAL);
1366 OUTPUT: 1369 OUTPUT:
1367 RETVAL 1370 RETVAL
1368 1371
1369ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = &PL_sv_undef) 1372ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = 0)
1370 ALIAS: 1373 ALIAS:
1371 embed_ns = 1 1374 embed_ns = 1
1372 CODE: 1375 CODE:
1373{ 1376{
1374 if (!(ev_backend (other) & ev_embeddable_backends ())) 1377 if (!(ev_backend (other) & ev_embeddable_backends ()))
1375 croak ("passed loop is not embeddable via EV::embed,"); 1378 croak ("passed loop is not embeddable via EV::embed,");
1376 1379
1377 RETVAL = e_new (sizeof (ev_embed), cb, ST (0)); 1380 RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
1378 RETVAL->fh = newSVsv (ST (1)); 1381 RETVAL->fh = newSVsv (ST (1));
1379 ev_embed_set (RETVAL, other); 1382 ev_embed_set (RETVAL, other);
1380
1381 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
1382
1383 if (!ix) START (embed, RETVAL); 1383 if (!ix) START (embed, RETVAL);
1384} 1384}
1385 OUTPUT: 1385 OUTPUT:
1386 RETVAL 1386 RETVAL
1387 1387

Diff Legend

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