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.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
… …
1208 if (loop != evapi.default_loop) /* global destruction sucks */ 1209 if (loop != evapi.default_loop) /* global destruction sucks */
1209 ev_loop_destroy (loop); 1210 ev_loop_destroy (loop);
1210 1211
1211void ev_loop_fork (struct ev_loop *loop) 1212void ev_loop_fork (struct ev_loop *loop)
1212 1213
1214void ev_loop_verify (struct ev_loop *loop)
1215
1213NV ev_now (struct ev_loop *loop) 1216NV ev_now (struct ev_loop *loop)
1217
1218void ev_now_update (struct ev_loop *loop)
1214 1219
1215void ev_set_io_collect_interval (struct ev_loop *loop, NV interval) 1220void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1216 1221
1217void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval) 1222void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1218 1223
… …
1362 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 1367 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
1363 if (!ix) START (stat, RETVAL); 1368 if (!ix) START (stat, RETVAL);
1364 OUTPUT: 1369 OUTPUT:
1365 RETVAL 1370 RETVAL
1366 1371
1367ev_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)
1368 ALIAS: 1373 ALIAS:
1369 embed_ns = 1 1374 embed_ns = 1
1370 CODE: 1375 CODE:
1371{ 1376{
1372 if (!(ev_backend (other) & ev_embeddable_backends ())) 1377 if (!(ev_backend (other) & ev_embeddable_backends ()))
1373 croak ("passed loop is not embeddable via EV::embed,"); 1378 croak ("passed loop is not embeddable via EV::embed,");
1374 1379
1375 RETVAL = e_new (sizeof (ev_embed), cb, ST (0)); 1380 RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
1376 RETVAL->fh = newSVsv (ST (1)); 1381 RETVAL->fh = newSVsv (ST (1));
1377 ev_embed_set (RETVAL, other); 1382 ev_embed_set (RETVAL, other);
1378
1379 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
1380
1381 if (!ix) START (embed, RETVAL); 1383 if (!ix) START (embed, RETVAL);
1382} 1384}
1383 OUTPUT: 1385 OUTPUT:
1384 RETVAL 1386 RETVAL
1385 1387

Diff Legend

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