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

Comparing EV/EV.xs (file contents):
Revision 1.8 by root, Sat Oct 27 19:11:27 2007 UTC vs.
Revision 1.13 by root, Mon Oct 29 18:33:02 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 evapi.loop = event_loop;
329
330 sv_setiv (sv, (IV)&evapi);
331 SvREADONLY_on (sv);
332 }
285} 333}
286 334
287double now () 335double now ()
288 CODE: 336 CODE:
289 RETVAL = e_now (); 337 RETVAL = e_now ();
… …
324 ALIAS: 372 ALIAS:
325 io_ns = 1 373 io_ns = 1
326 CODE: 374 CODE:
327 RETVAL = e_new (fh, events, cb); 375 RETVAL = e_new (fh, events, cb);
328 if (!ix) e_start (RETVAL); 376 if (!ix) e_start (RETVAL);
377 OUTPUT:
378 RETVAL
379
380Event timed_io (SV *fh, short events, double timeout, SV *cb)
381 ALIAS:
382 timed_io_ns = 1
383 CODE:
384{
385 events = timeout ? events & ~EV_PERSIST : events | EV_PERSIST;
386
387 RETVAL = e_new (fh, events, cb);
388
389 if (timeout)
390 {
391 RETVAL->timeout = timeout;
392 RETVAL->interval = 1;
393 }
394
395 if (!ix) e_start (RETVAL);
396}
329 OUTPUT: 397 OUTPUT:
330 RETVAL 398 RETVAL
331 399
332Event timer (double after, int repeat, SV *cb) 400Event timer (double after, int repeat, SV *cb)
333 ALIAS: 401 ALIAS:
… …
350 RETVAL->abstime = 1; 418 RETVAL->abstime = 1;
351 if (!ix) e_start (RETVAL); 419 if (!ix) e_start (RETVAL);
352 OUTPUT: 420 OUTPUT:
353 RETVAL 421 RETVAL
354 422
355Event signal (SV *signal, SV *cb) 423Event signal (Signal signum, SV *cb)
356 ALIAS: 424 ALIAS:
357 signal_ns = 1 425 signal_ns = 1
358 CODE: 426 CODE:
359 RETVAL = e_new (signal, EV_SIGNAL | EV_PERSIST, cb); 427 RETVAL = e_new (ST (0), EV_SIGNAL | EV_PERSIST, cb);
428 RETVAL->ev.ev_fd = signum;
360 if (!ix) e_start (RETVAL); 429 if (!ix) e_start (RETVAL);
361 OUTPUT: 430 OUTPUT:
362 RETVAL 431 RETVAL
363 432
364PROTOTYPES: DISABLE 433PROTOTYPES: DISABLE
… …
435 sv_setsv (ev->cb, new_cb); 504 sv_setsv (ev->cb, new_cb);
436 OUTPUT: 505 OUTPUT:
437 RETVAL 506 RETVAL
438 507
439SV *fh (Event ev, SV *new_fh = 0) 508SV *fh (Event ev, SV *new_fh = 0)
440 ALIAS:
441 signal = 0
442 CODE: 509 CODE:
443 RETVAL = newSVsv (ev->fh); 510 RETVAL = newSVsv (ev->fh);
444 if (items > 1) 511 if (items > 1)
445 { 512 {
446 if (ev->active) event_del (&ev->ev); 513 if (ev->active) event_del (&ev->ev);
447 sv_setsv (ev->fh, new_fh); 514 sv_setsv (ev->fh, new_fh);
448 ev->ev.ev_fd = sv_fileno (ev->fh); 515 ev->ev.ev_fd = sv_fileno (ev->fh);
516 ev->ev.ev_events &= ev->ev.ev_events & ~EV_SIGNAL;
449 if (ev->active) event_add (&ev->ev, e_tv (ev)); 517 if (ev->active) event_add (&ev->ev, e_tv (ev));
450 } 518 }
519 OUTPUT:
520 RETVAL
521
522SV *signal (Event ev, SV *new_signal = 0)
523 CODE:
524{
525 Signal signum;
526
527 if (items > 1)
528 signum = sv_signum (new_signal); /* may croak here */
529
530 RETVAL = newSVsv (ev->fh);
531
532 if (items > 1)
533 {
534 if (ev->active) event_del (&ev->ev);
535 sv_setsv (ev->fh, new_signal);
536 ev->ev.ev_fd = signum;
537 ev->ev.ev_events |= EV_SIGNAL;
538 if (ev->active) event_add (&ev->ev, e_tv (ev));
539 }
540}
451 OUTPUT: 541 OUTPUT:
452 RETVAL 542 RETVAL
453 543
454short events (Event ev, short new_events = EV_UNDEF) 544short events (Event ev, short new_events = EV_UNDEF)
455 CODE: 545 CODE:

Diff Legend

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