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

Comparing EV/EV.xs (file contents):
Revision 1.9 by root, Mon Oct 29 07:24:37 2007 UTC vs.
Revision 1.14 by root, Tue Oct 30 12:48:29 2007 UTC

… …
23#define EV_NONE 0 23#define EV_NONE 0
24#define EV_UNDEF -1 24#define EV_UNDEF -1
25 25
26#define TIMEOUT_NONE HUGE_VAL 26#define TIMEOUT_NONE HUGE_VAL
27 27
28#include "EV/EVAPI.h"
29
28typedef struct event_base *Base; 30typedef struct event_base *Base;
31typedef int Signal;
32
33static struct EVAPI evapi;
29 34
30static HV *stash_base, *stash_event; 35static HV *stash_base, *stash_event;
31 36
32static double tv_get (struct timeval *tv) 37static double tv_get (struct timeval *tv)
33{ 38{
… …
37static void tv_set (struct timeval *tv, double val) 42static void tv_set (struct timeval *tv, double val)
38{ 43{
39 tv->tv_sec = (long)val; 44 tv->tv_sec = (long)val;
40 tv->tv_usec = (long)((val - (double)tv->tv_sec) * 1e6); 45 tv->tv_usec = (long)((val - (double)tv->tv_sec) * 1e6);
41 46
47}
48
49static int
50sv_signum (SV *sig)
51{
52 int signum;
53
54 if (SvIV (sig) > 0)
55 return SvIV (sig);
56
57 for (signum = 1; signum < SIG_SIZE; ++signum)
58 if (strEQ (SvPV_nolen (sig), PL_sig_name [signum]))
59 return signum;
60
61 return -1;
62}
63
64static void
65api_once (int fd, short events, double timeout, void (*cb)(int, short, void *), void *arg)
66{
67 if (timeout >= 0.)
68 {
69 struct timeval tv;
70 tv_set (&tv, timeout);
71 event_once (fd, events, cb, arg, &tv);
72 }
73 else
74 event_once (fd, events, cb, arg, 0);
42} 75}
43 76
44///////////////////////////////////////////////////////////////////////////// 77/////////////////////////////////////////////////////////////////////////////
45// Event 78// Event
46 79
… …
53 unsigned char active; 86 unsigned char active;
54 unsigned char abstime; 87 unsigned char abstime;
55} *Event; 88} *Event;
56 89
57static double 90static double
58e_now () 91e_now (void)
59{ 92{
60 struct timeval tv; 93 struct timeval tv;
61 gettimeofday (&tv, 0); 94 gettimeofday (&tv, 0);
62 95
63 return tv_get (&tv); 96 return tv_get (&tv);
… …
165static void 198static void
166e_cb (int fd, short events, void *arg) 199e_cb (int fd, short events, void *arg)
167{ 200{
168 struct ev *ev = (struct ev*)arg; 201 struct ev *ev = (struct ev*)arg;
169 dSP; 202 dSP;
170 203 I32 mark = SP - PL_stack_base;
171 ENTER; 204 SV *sv_self, *sv_events;
172 SAVETMPS; 205 static SV *sv_events_cache;
173 206
174 if (!(ev->ev.ev_events & EV_PERSIST) || (events & EV_TIMEOUT)) 207 if (!(ev->ev.ev_events & EV_PERSIST) || (events & EV_TIMEOUT))
175 ev->active = 0; 208 ev->active = 0;
176 209
210 sv_self = e_self (ev);
211
212 if (sv_events_cache)
213 {
214 sv_events = sv_events_cache; sv_events_cache = 0;
215 SvIV_set (sv_events, events);
216 }
217 else
218 sv_events = newSViv (events);
219
177 PUSHMARK (SP); 220 PUSHMARK (SP);
178 EXTEND (SP, 2); 221 EXTEND (SP, 2);
179 PUSHs (sv_2mortal (e_self (ev))); 222 PUSHs (sv_self);
180 PUSHs (sv_2mortal (newSViv (events))); 223 PUSHs (sv_events);
181 PUTBACK; 224 PUTBACK;
182 call_sv (ev->cb, G_DISCARD | G_VOID | G_EVAL); 225 call_sv (ev->cb, G_DISCARD | G_VOID | G_EVAL);
226 SP = PL_stack_base + mark; PUTBACK;
227
228 SvREFCNT_dec (sv_self);
229
230 if (sv_events_cache)
231 SvREFCNT_dec (sv_events);
232 else
233 sv_events_cache = sv_events;
183 234
184 if (ev->interval && !ev->active) 235 if (ev->interval && !ev->active)
185 e_start (ev); 236 e_start (ev);
186
187 FREETMPS;
188 237
189 if (SvTRUE (ERRSV)) 238 if (SvTRUE (ERRSV))
190 { 239 {
191 PUSHMARK (SP); 240 PUSHMARK (SP);
192 PUTBACK; 241 PUTBACK;
193 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR); 242 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
243 SP = PL_stack_base + mark; PUTBACK;
194 } 244 }
195
196 LEAVE;
197} 245}
198 246
199///////////////////////////////////////////////////////////////////////////// 247/////////////////////////////////////////////////////////////////////////////
200// DNS 248// DNS
201 249
… …
253 301
254MODULE = EV PACKAGE = EV PREFIX = event_ 302MODULE = EV PACKAGE = EV PREFIX = event_
255 303
256BOOT: 304BOOT:
257{ 305{
306 int i;
258 HV *stash = gv_stashpv ("EV", 1); 307 HV *stash = gv_stashpv ("EV", 1);
259 308
260 static const struct { 309 static const struct {
261 const char *name; 310 const char *name;
262 IV iv; 311 IV iv;
… …
280 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; ) 329 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
281 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv)); 330 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
282 331
283 stash_base = gv_stashpv ("EV::Base" , 1); 332 stash_base = gv_stashpv ("EV::Base" , 1);
284 stash_event = gv_stashpv ("EV::Event", 1); 333 stash_event = gv_stashpv ("EV::Event", 1);
334
335 {
336 SV *sv = perl_get_sv ("EV::API", TRUE);
337 perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */
338
339 evapi.ver = EV_API_VERSION;
340 evapi.rev = EV_API_REVISION;
341 evapi.now = e_now;
342 evapi.once = api_once;
343 evapi.loop = event_loop;
344
345 sv_setiv (sv, (IV)&evapi);
346 SvREADONLY_on (sv);
347 }
285} 348}
286 349
287double now () 350double now ()
288 CODE: 351 CODE:
289 RETVAL = e_now (); 352 RETVAL = e_now ();
… …
370 RETVAL->abstime = 1; 433 RETVAL->abstime = 1;
371 if (!ix) e_start (RETVAL); 434 if (!ix) e_start (RETVAL);
372 OUTPUT: 435 OUTPUT:
373 RETVAL 436 RETVAL
374 437
375Event signal (SV *signal, SV *cb) 438Event signal (Signal signum, SV *cb)
376 ALIAS: 439 ALIAS:
377 signal_ns = 1 440 signal_ns = 1
378 CODE: 441 CODE:
379 RETVAL = e_new (signal, EV_SIGNAL | EV_PERSIST, cb); 442 RETVAL = e_new (ST (0), EV_SIGNAL | EV_PERSIST, cb);
443 RETVAL->ev.ev_fd = signum;
380 if (!ix) e_start (RETVAL); 444 if (!ix) e_start (RETVAL);
381 OUTPUT: 445 OUTPUT:
382 RETVAL 446 RETVAL
383 447
384PROTOTYPES: DISABLE 448PROTOTYPES: DISABLE
… …
455 sv_setsv (ev->cb, new_cb); 519 sv_setsv (ev->cb, new_cb);
456 OUTPUT: 520 OUTPUT:
457 RETVAL 521 RETVAL
458 522
459SV *fh (Event ev, SV *new_fh = 0) 523SV *fh (Event ev, SV *new_fh = 0)
460 ALIAS:
461 signal = 1
462 CODE: 524 CODE:
463 RETVAL = newSVsv (ev->fh); 525 RETVAL = newSVsv (ev->fh);
464 if (items > 1) 526 if (items > 1)
465 { 527 {
466 if (ev->active) event_del (&ev->ev); 528 if (ev->active) event_del (&ev->ev);
467 sv_setsv (ev->fh, new_fh); 529 sv_setsv (ev->fh, new_fh);
468 ev->ev.ev_fd = sv_fileno (ev->fh); 530 ev->ev.ev_fd = sv_fileno (ev->fh);
469 ev->ev.ev_events = signal ? ev->ev.ev_events | EV_SIGNAL : ev->ev.ev_events & ~EV_SIGNAL; 531 ev->ev.ev_events &= ev->ev.ev_events & ~EV_SIGNAL;
470 if (ev->active) event_add (&ev->ev, e_tv (ev)); 532 if (ev->active) event_add (&ev->ev, e_tv (ev));
471 } 533 }
534 OUTPUT:
535 RETVAL
536
537SV *signal (Event ev, SV *new_signal = 0)
538 CODE:
539{
540 Signal signum;
541
542 if (items > 1)
543 signum = sv_signum (new_signal); /* may croak here */
544
545 RETVAL = newSVsv (ev->fh);
546
547 if (items > 1)
548 {
549 if (ev->active) event_del (&ev->ev);
550 sv_setsv (ev->fh, new_signal);
551 ev->ev.ev_fd = signum;
552 ev->ev.ev_events |= EV_SIGNAL;
553 if (ev->active) event_add (&ev->ev, e_tv (ev));
554 }
555}
472 OUTPUT: 556 OUTPUT:
473 RETVAL 557 RETVAL
474 558
475short events (Event ev, short new_events = EV_UNDEF) 559short events (Event ev, short new_events = EV_UNDEF)
476 CODE: 560 CODE:

Diff Legend

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