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.120 by root, Sun Nov 23 17:44:46 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/* 5.6.x */
35#ifndef SvRV_set
36# define SvRV_set(a,b) SvRV ((a)) = (b)
37#endif
38
39#if __GNUC__ >= 3
40# define expect(expr,value) __builtin_expect ((expr),(value))
41#else
42# define expect(expr,value) (expr)
43#endif
44
45#define expect_false(expr) expect ((expr) != 0, 0)
46#define expect_true(expr) expect ((expr) != 0, 1)
28 47
29#define e_loop(w) INT2PTR (struct ev_loop *, SvIVX ((w)->loop)) 48#define e_loop(w) INT2PTR (struct ev_loop *, SvIVX ((w)->loop))
30 49
31#define WFLAG_KEEPALIVE 1 50#define WFLAG_KEEPALIVE 1
32 51
… …
143} 162}
144 163
145static void * 164static void *
146e_new (int size, SV *cb_sv, SV *loop) 165e_new (int size, SV *cb_sv, SV *loop)
147{ 166{
148 SV *cv = e_get_cv (cb_sv); 167 SV *cv = cb_sv ? e_get_cv (cb_sv) : 0;
149 ev_watcher *w; 168 ev_watcher *w;
150 SV *self = NEWSV (0, size); 169 SV *self = NEWSV (0, size);
151 SvPOK_only (self); 170 SvPOK_only (self);
152 SvCUR_set (self, size); 171 SvCUR_set (self, size);
153 172
154 w = (ev_watcher *)SvPVX (self); 173 w = (ev_watcher *)SvPVX (self);
155 174
156 ev_init (w, e_cb); 175 ev_init (w, cv ? e_cb : 0);
157 176
158 w->loop = SvREFCNT_inc (SvRV (loop)); 177 w->loop = SvREFCNT_inc (SvRV (loop));
159 w->e_flags = WFLAG_KEEPALIVE; 178 w->e_flags = WFLAG_KEEPALIVE;
160 w->data = 0; 179 w->data = 0;
161 w->fh = 0; 180 w->fh = 0;
… …
191 } 210 }
192 211
193 return rv; 212 return rv;
194} 213}
195 214
196static SV *sv_events_cache; 215static SV *sv_self_cache, *sv_events_cache;
197 216
198static void 217static void
199e_cb (EV_P_ ev_watcher *w, int revents) 218e_cb (EV_P_ ev_watcher *w, int revents)
200{ 219{
201 dSP; 220 dSP;
202 I32 mark = SP - PL_stack_base; 221 I32 mark = SP - PL_stack_base;
203 SV *sv_self, *sv_events; 222 SV *sv_self, *sv_events;
204 223
224 if (expect_true (sv_self_cache))
225 {
226 sv_self = sv_self_cache; sv_self_cache = 0;
227 SvRV_set (sv_self, SvREFCNT_inc_NN (w->self));
228 }
229 else
230 {
205 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */ 231 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */
232 SvREADONLY_on (sv_self);
233 }
206 234
207 if (sv_events_cache) 235 if (expect_true (sv_events_cache))
208 { 236 {
209 sv_events = sv_events_cache; sv_events_cache = 0; 237 sv_events = sv_events_cache; sv_events_cache = 0;
210 SvIV_set (sv_events, revents); 238 SvIV_set (sv_events, revents);
211 } 239 }
212 else 240 else
241 {
213 sv_events = newSViv (revents); 242 sv_events = newSViv (revents);
243 SvREADONLY_on (sv_events);
244 }
214 245
215 PUSHMARK (SP); 246 PUSHMARK (SP);
216 EXTEND (SP, 2); 247 EXTEND (SP, 2);
217 PUSHs (sv_self); 248 PUSHs (sv_self);
218 PUSHs (sv_events); 249 PUSHs (sv_events);
219 250
220 PUTBACK; 251 PUTBACK;
221 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL); 252 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
222 253
254 if (expect_false (SvREFCNT (sv_self) != 1 || sv_self_cache))
223 SvREFCNT_dec (sv_self); 255 SvREFCNT_dec (sv_self);
256 else
257 {
258 SvREFCNT_dec (SvRV (sv_self));
259 SvRV_set (sv_self, &PL_sv_undef);
260 sv_self_cache = sv_self;
261 }
224 262
225 if (sv_events_cache) 263 if (expect_false (SvREFCNT (sv_events) != 1 || sv_events_cache))
226 SvREFCNT_dec (sv_events); 264 SvREFCNT_dec (sv_events);
227 else 265 else
228 sv_events_cache = sv_events; 266 sv_events_cache = sv_events;
229 267
230 if (SvTRUE (ERRSV)) 268 if (expect_false (SvTRUE (ERRSV)))
231 { 269 {
232 SPAGAIN; 270 SPAGAIN;
233 PUSHMARK (SP); 271 PUSHMARK (SP);
234 PUTBACK; 272 PUTBACK;
235 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR); 273 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
… …
411 evapi.loop_new = ev_loop_new; 449 evapi.loop_new = ev_loop_new;
412 evapi.loop_destroy = ev_loop_destroy; 450 evapi.loop_destroy = ev_loop_destroy;
413 evapi.loop_fork = ev_loop_fork; 451 evapi.loop_fork = ev_loop_fork;
414 evapi.loop_count = ev_loop_count; 452 evapi.loop_count = ev_loop_count;
415 evapi.now = ev_now; 453 evapi.now = ev_now;
454 evapi.now_update = ev_now_update;
416 evapi.backend = ev_backend; 455 evapi.backend = ev_backend;
417 evapi.unloop = ev_unloop; 456 evapi.unloop = ev_unloop;
418 evapi.ref = ev_ref; 457 evapi.ref = ev_ref;
419 evapi.unref = ev_unref; 458 evapi.unref = ev_unref;
420 evapi.loop = ev_loop; 459 evapi.loop = ev_loop;
… …
486 525
487unsigned int ev_recommended_backends () 526unsigned int ev_recommended_backends ()
488 527
489unsigned int ev_embeddable_backends () 528unsigned int ev_embeddable_backends ()
490 529
530void ev_sleep (NV interval)
531
491NV ev_time () 532NV ev_time ()
492 533
493NV ev_now () 534NV ev_now ()
535 C_ARGS: evapi.default_loop
536
537void ev_now_update ()
494 C_ARGS: evapi.default_loop 538 C_ARGS: evapi.default_loop
495 539
496unsigned int ev_backend () 540unsigned int ev_backend ()
497 C_ARGS: evapi.default_loop 541 C_ARGS: evapi.default_loop
498 542
… …
642 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 686 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
643 if (!ix) START (stat, RETVAL); 687 if (!ix) START (stat, RETVAL);
644 OUTPUT: 688 OUTPUT:
645 RETVAL 689 RETVAL
646 690
647ev_embed *embed (struct ev_loop *loop, SV *cb = &PL_sv_undef) 691ev_embed *embed (struct ev_loop *loop, SV *cb = 0)
648 ALIAS: 692 ALIAS:
649 embed_ns = 1 693 embed_ns = 1
650 CODE: 694 CODE:
651{ 695{
652 if (!(ev_backend (loop) & ev_embeddable_backends ())) 696 if (!(ev_backend (loop) & ev_embeddable_backends ()))
653 croak ("passed loop is not embeddable via EV::embed,"); 697 croak ("passed loop is not embeddable via EV::embed,");
654 698
655 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv); 699 RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
656 RETVAL->fh = newSVsv (ST (0)); 700 RETVAL->fh = newSVsv (ST (0));
657 ev_embed_set (RETVAL, loop); 701 ev_embed_set (RETVAL, loop);
658
659 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
660
661 if (!ix) START (embed, RETVAL); 702 if (!ix) START (embed, RETVAL);
662} 703}
663 OUTPUT: 704 OUTPUT:
664 RETVAL 705 RETVAL
665 706
… …
1208 if (loop != evapi.default_loop) /* global destruction sucks */ 1249 if (loop != evapi.default_loop) /* global destruction sucks */
1209 ev_loop_destroy (loop); 1250 ev_loop_destroy (loop);
1210 1251
1211void ev_loop_fork (struct ev_loop *loop) 1252void ev_loop_fork (struct ev_loop *loop)
1212 1253
1254void ev_loop_verify (struct ev_loop *loop)
1255
1213NV ev_now (struct ev_loop *loop) 1256NV ev_now (struct ev_loop *loop)
1257
1258void ev_now_update (struct ev_loop *loop)
1214 1259
1215void ev_set_io_collect_interval (struct ev_loop *loop, NV interval) 1260void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
1216 1261
1217void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval) 1262void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
1218 1263
… …
1362 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval); 1407 ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
1363 if (!ix) START (stat, RETVAL); 1408 if (!ix) START (stat, RETVAL);
1364 OUTPUT: 1409 OUTPUT:
1365 RETVAL 1410 RETVAL
1366 1411
1367ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = &PL_sv_undef) 1412ev_embed *embed (struct ev_loop *loop, struct ev_loop *other, SV *cb = 0)
1368 ALIAS: 1413 ALIAS:
1369 embed_ns = 1 1414 embed_ns = 1
1370 CODE: 1415 CODE:
1371{ 1416{
1372 if (!(ev_backend (other) & ev_embeddable_backends ())) 1417 if (!(ev_backend (other) & ev_embeddable_backends ()))
1373 croak ("passed loop is not embeddable via EV::embed,"); 1418 croak ("passed loop is not embeddable via EV::embed,");
1374 1419
1375 RETVAL = e_new (sizeof (ev_embed), cb, ST (0)); 1420 RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
1376 RETVAL->fh = newSVsv (ST (1)); 1421 RETVAL->fh = newSVsv (ST (1));
1377 ev_embed_set (RETVAL, other); 1422 ev_embed_set (RETVAL, other);
1378
1379 if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
1380
1381 if (!ix) START (embed, RETVAL); 1423 if (!ix) START (embed, RETVAL);
1382} 1424}
1383 OUTPUT: 1425 OUTPUT:
1384 RETVAL 1426 RETVAL
1385 1427

Diff Legend

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