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.12 by root, Mon Oct 29 08:51:44 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);
… …
253 286
254MODULE = EV PACKAGE = EV PREFIX = event_ 287MODULE = EV PACKAGE = EV PREFIX = event_
255 288
256BOOT: 289BOOT:
257{ 290{
291 int i;
258 HV *stash = gv_stashpv ("EV", 1); 292 HV *stash = gv_stashpv ("EV", 1);
259 293
260 static const struct { 294 static const struct {
261 const char *name; 295 const char *name;
262 IV iv; 296 IV iv;
… …
280 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; ) 314 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
281 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv)); 315 newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
282 316
283 stash_base = gv_stashpv ("EV::Base" , 1); 317 stash_base = gv_stashpv ("EV::Base" , 1);
284 stash_event = gv_stashpv ("EV::Event", 1); 318 stash_event = gv_stashpv ("EV::Event", 1);
319
320 {
321 SV *sv = perl_get_sv ("EV::API", TRUE);
322 perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */
323
324 evapi.ver = EV_API_VERSION;
325 evapi.rev = EV_API_REVISION;
326 evapi.now = e_now;
327 evapi.once = api_once;
328
329 sv_setiv (sv, (IV)&evapi);
330 SvREADONLY_on (sv);
331 }
285} 332}
286 333
287double now () 334double now ()
288 CODE: 335 CODE:
289 RETVAL = e_now (); 336 RETVAL = e_now ();
… …
370 RETVAL->abstime = 1; 417 RETVAL->abstime = 1;
371 if (!ix) e_start (RETVAL); 418 if (!ix) e_start (RETVAL);
372 OUTPUT: 419 OUTPUT:
373 RETVAL 420 RETVAL
374 421
375Event signal (SV *signal, SV *cb) 422Event signal (Signal signum, SV *cb)
376 ALIAS: 423 ALIAS:
377 signal_ns = 1 424 signal_ns = 1
378 CODE: 425 CODE:
379 RETVAL = e_new (signal, EV_SIGNAL | EV_PERSIST, cb); 426 RETVAL = e_new (ST (0), EV_SIGNAL | EV_PERSIST, cb);
427 RETVAL->ev.ev_fd = signum;
380 if (!ix) e_start (RETVAL); 428 if (!ix) e_start (RETVAL);
381 OUTPUT: 429 OUTPUT:
382 RETVAL 430 RETVAL
383 431
384PROTOTYPES: DISABLE 432PROTOTYPES: DISABLE
… …
455 sv_setsv (ev->cb, new_cb); 503 sv_setsv (ev->cb, new_cb);
456 OUTPUT: 504 OUTPUT:
457 RETVAL 505 RETVAL
458 506
459SV *fh (Event ev, SV *new_fh = 0) 507SV *fh (Event ev, SV *new_fh = 0)
460 ALIAS:
461 signal = 1
462 CODE: 508 CODE:
463 RETVAL = newSVsv (ev->fh); 509 RETVAL = newSVsv (ev->fh);
464 if (items > 1) 510 if (items > 1)
465 { 511 {
466 if (ev->active) event_del (&ev->ev); 512 if (ev->active) event_del (&ev->ev);
467 sv_setsv (ev->fh, new_fh); 513 sv_setsv (ev->fh, new_fh);
468 ev->ev.ev_fd = sv_fileno (ev->fh); 514 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; 515 ev->ev.ev_events &= ev->ev.ev_events & ~EV_SIGNAL;
470 if (ev->active) event_add (&ev->ev, e_tv (ev)); 516 if (ev->active) event_add (&ev->ev, e_tv (ev));
471 } 517 }
518 OUTPUT:
519 RETVAL
520
521SV *signal (Event ev, SV *new_signal = 0)
522 CODE:
523{
524 Signal signum;
525
526 if (items > 1)
527 signum = sv_signum (new_signal); /* may croak here */
528
529 RETVAL = newSVsv (ev->fh);
530
531 if (items > 1)
532 {
533 if (ev->active) event_del (&ev->ev);
534 sv_setsv (ev->fh, new_signal);
535 ev->ev.ev_fd = signum;
536 ev->ev.ev_events |= EV_SIGNAL;
537 if (ev->active) event_add (&ev->ev, e_tv (ev));
538 }
539}
472 OUTPUT: 540 OUTPUT:
473 RETVAL 541 RETVAL
474 542
475short events (Event ev, short new_events = EV_UNDEF) 543short events (Event ev, short new_events = EV_UNDEF)
476 CODE: 544 CODE:

Diff Legend

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