ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/EV/EV.xs
Revision: 1.38
Committed: Thu Nov 1 17:45:30 2007 UTC (16 years, 6 months ago) by root
Branch: MAIN
Changes since 1.37: +0 -6 lines
Log Message:
*** empty log message ***

File Contents

# User Rev Content
1 root 1.1 #include "EXTERN.h"
2     #include "perl.h"
3     #include "XSUB.h"
4    
5 root 1.20 /*#include <netinet/in.h>*/
6 root 1.1
7 root 1.20 #define EV_PROTOTYPES 1
8 root 1.11 #include "EV/EVAPI.h"
9    
10 root 1.16 #include "libev/ev.c"
11 root 1.36 #include "libev/event.h"
12     #include "libev/event.c"
13     #include "libev/evdns.c"
14 root 1.16
15 root 1.10 typedef int Signal;
16 root 1.1
17 root 1.11 static struct EVAPI evapi;
18    
19 root 1.15 static HV
20     *stash_watcher,
21     *stash_io,
22     *stash_timer,
23     *stash_periodic,
24     *stash_signal,
25     *stash_idle,
26 root 1.22 *stash_prepare,
27 root 1.23 *stash_check,
28     *stash_child;
29 root 1.1
30 root 1.10 static int
31     sv_signum (SV *sig)
32     {
33     int signum;
34    
35 root 1.31 SvGETMAGIC (sig);
36 root 1.10
37     for (signum = 1; signum < SIG_SIZE; ++signum)
38     if (strEQ (SvPV_nolen (sig), PL_sig_name [signum]))
39     return signum;
40    
41 root 1.31 if (SvIV (sig) > 0)
42     return SvIV (sig);
43    
44 root 1.10 return -1;
45     }
46    
47 root 1.1 /////////////////////////////////////////////////////////////////////////////
48     // Event
49    
50 root 1.15 static void e_cb (struct ev_watcher *w, int revents);
51 root 1.1
52 root 1.15 static int
53     sv_fileno (SV *fh)
54 root 1.1 {
55 root 1.3 SvGETMAGIC (fh);
56 root 1.1
57 root 1.3 if (SvROK (fh))
58     fh = SvRV (fh);
59 root 1.1
60 root 1.3 if (SvTYPE (fh) == SVt_PVGV)
61     return PerlIO_fileno (IoIFP (sv_2io (fh)));
62 root 1.1
63 root 1.31 if ((SvIV (fh) >= 0) && (SvIV (fh) < 0x7ffffff))
64 root 1.3 return SvIV (fh);
65 root 1.1
66     return -1;
67     }
68    
69 root 1.15 static void *
70     e_new (int size, SV *cb_sv)
71 root 1.1 {
72 root 1.15 struct ev_watcher *w;
73     SV *self = NEWSV (0, size);
74 root 1.1 SvPOK_only (self);
75 root 1.15 SvCUR_set (self, size);
76 root 1.1
77 root 1.15 w = (struct ev_watcher *)SvPVX (self);
78 root 1.1
79 root 1.29 ev_watcher_init (w, e_cb);
80 root 1.1
81 root 1.15 w->fh = 0;
82     w->cb_sv = newSVsv (cb_sv);
83     w->self = self;
84 root 1.1
85 root 1.15 return (void *)w;
86 root 1.1 }
87    
88 root 1.34 static void *
89     e_destroy (void *w_)
90     {
91     struct ev_watcher *w = w_;
92    
93     SvREFCNT_dec (w->fh ); w->fh = 0;
94     SvREFCNT_dec (w->cb_sv); w->cb_sv = 0;
95     }
96    
97 root 1.15 static SV *
98     e_bless (struct ev_watcher *w, HV *stash)
99 root 1.1 {
100     SV *rv;
101    
102 root 1.15 if (SvOBJECT (w->self))
103     rv = newRV_inc (w->self);
104 root 1.1 else
105     {
106 root 1.15 rv = newRV_noinc (w->self);
107     sv_bless (rv, stash);
108     SvREADONLY_on (w->self);
109 root 1.1 }
110    
111     return rv;
112     }
113    
114     static void
115 root 1.15 e_cb (struct ev_watcher *w, int revents)
116 root 1.1 {
117     dSP;
118 root 1.14 I32 mark = SP - PL_stack_base;
119 root 1.24 SV *sv_self, *sv_events, *sv_status = 0;
120 root 1.14 static SV *sv_events_cache;
121 root 1.1
122 root 1.15 sv_self = newRV_inc (w->self); /* w->self MUST be blessed by now */
123 root 1.14
124     if (sv_events_cache)
125     {
126     sv_events = sv_events_cache; sv_events_cache = 0;
127 root 1.15 SvIV_set (sv_events, revents);
128 root 1.14 }
129     else
130 root 1.15 sv_events = newSViv (revents);
131 root 1.14
132 root 1.1 PUSHMARK (SP);
133     EXTEND (SP, 2);
134 root 1.14 PUSHs (sv_self);
135     PUSHs (sv_events);
136 root 1.24
137     if (revents & EV_CHILD)
138     XPUSHs (sv_status = newSViv (((struct ev_child *)w)->status));
139    
140 root 1.1 PUTBACK;
141 root 1.15 call_sv (w->cb_sv, G_DISCARD | G_VOID | G_EVAL);
142 root 1.14 SP = PL_stack_base + mark; PUTBACK;
143    
144     SvREFCNT_dec (sv_self);
145 root 1.24 SvREFCNT_dec (sv_status);
146 root 1.14
147     if (sv_events_cache)
148     SvREFCNT_dec (sv_events);
149     else
150     sv_events_cache = sv_events;
151 root 1.1
152 root 1.8 if (SvTRUE (ERRSV))
153     {
154     PUSHMARK (SP);
155     PUTBACK;
156     call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
157 root 1.14 SP = PL_stack_base + mark; PUTBACK;
158 root 1.8 }
159 root 1.1 }
160    
161     /////////////////////////////////////////////////////////////////////////////
162     // DNS
163    
164     static void
165     dns_cb (int result, char type, int count, int ttl, void *addresses, void *arg)
166     {
167     dSP;
168     SV *cb = (SV *)arg;
169    
170     ENTER;
171     SAVETMPS;
172     PUSHMARK (SP);
173     EXTEND (SP, count + 3);
174     PUSHs (sv_2mortal (newSViv (result)));
175    
176     if (result == DNS_ERR_NONE && ttl >= 0)
177     {
178     int i;
179    
180     PUSHs (sv_2mortal (newSViv (type)));
181     PUSHs (sv_2mortal (newSViv (ttl)));
182    
183     for (i = 0; i < count; ++i)
184     switch (type)
185     {
186     case DNS_IPv6_AAAA:
187     PUSHs (sv_2mortal (newSVpvn (i * 16 + (char *)addresses, 16)));
188     break;
189     case DNS_IPv4_A:
190     PUSHs (sv_2mortal (newSVpvn (i * 4 + (char *)addresses, 4)));
191     break;
192     case DNS_PTR:
193     PUSHs (sv_2mortal (newSVpv (*(char **)addresses, 0)));
194     break;
195     }
196     }
197    
198     PUTBACK;
199     call_sv (sv_2mortal (cb), G_DISCARD | G_VOID | G_EVAL);
200    
201     FREETMPS;
202 root 1.8
203     if (SvTRUE (ERRSV))
204     {
205     PUSHMARK (SP);
206     PUTBACK;
207     call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
208     }
209    
210 root 1.1 LEAVE;
211     }
212    
213 root 1.18 #define CHECK_REPEAT(repeat) if (repeat < 0.) \
214     croak (# repeat " value must be >= 0");
215    
216 root 1.31 #define CHECK_FD(fh,fd) if ((fd) < 0) \
217     croak ("illegal file descriptor or filehandle (either no attached file descriptor or illegal value): %s", SvPV_nolen (fh));
218    
219 root 1.1 /////////////////////////////////////////////////////////////////////////////
220     // XS interface functions
221    
222 root 1.15 MODULE = EV PACKAGE = EV PREFIX = ev_
223 root 1.1
224 root 1.21 PROTOTYPES: ENABLE
225    
226 root 1.1 BOOT:
227     {
228 root 1.10 int i;
229 root 1.1 HV *stash = gv_stashpv ("EV", 1);
230    
231     static const struct {
232     const char *name;
233     IV iv;
234     } *civ, const_iv[] = {
235     # define const_iv(pfx, name) { # name, (IV) pfx ## name },
236 root 1.20 const_iv (EV_, UNDEF)
237 root 1.1 const_iv (EV_, NONE)
238     const_iv (EV_, TIMEOUT)
239     const_iv (EV_, READ)
240     const_iv (EV_, WRITE)
241     const_iv (EV_, SIGNAL)
242 root 1.15 const_iv (EV_, IDLE)
243     const_iv (EV_, CHECK)
244 root 1.20 const_iv (EV_, ERROR)
245 root 1.15
246     const_iv (EV, LOOP_ONESHOT)
247 root 1.1 const_iv (EV, LOOP_NONBLOCK)
248 root 1.15
249     const_iv (EV, METHOD_NONE)
250     const_iv (EV, METHOD_SELECT)
251     const_iv (EV, METHOD_EPOLL)
252 root 1.1 };
253    
254     for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
255     newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
256    
257 root 1.15 stash_watcher = gv_stashpv ("EV::Watcher" , 1);
258 root 1.28 stash_io = gv_stashpv ("EV::Io" , 1);
259 root 1.15 stash_timer = gv_stashpv ("EV::Timer" , 1);
260     stash_periodic = gv_stashpv ("EV::Periodic", 1);
261     stash_signal = gv_stashpv ("EV::Signal" , 1);
262     stash_idle = gv_stashpv ("EV::Idle" , 1);
263 root 1.22 stash_prepare = gv_stashpv ("EV::Prepare" , 1);
264 root 1.15 stash_check = gv_stashpv ("EV::Check" , 1);
265 root 1.23 stash_child = gv_stashpv ("EV::Child" , 1);
266 root 1.11
267     {
268     SV *sv = perl_get_sv ("EV::API", TRUE);
269     perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */
270    
271 root 1.15 /* the poor man's shared library emulator */
272     evapi.ver = EV_API_VERSION;
273     evapi.rev = EV_API_REVISION;
274     evapi.sv_fileno = sv_fileno;
275     evapi.sv_signum = sv_signum;
276     evapi.now = &ev_now;
277     evapi.method = &ev_method;
278     evapi.loop_done = &ev_loop_done;
279     evapi.time = ev_time;
280     evapi.loop = ev_loop;
281 root 1.20 evapi.once = ev_once;
282 root 1.29 evapi.io_start = ev_io_start;
283     evapi.io_stop = ev_io_stop;
284     evapi.timer_start = ev_timer_start;
285     evapi.timer_stop = ev_timer_stop;
286     evapi.timer_again = ev_timer_again;
287     evapi.periodic_start = ev_periodic_start;
288     evapi.periodic_stop = ev_periodic_stop;
289     evapi.signal_start = ev_signal_start;
290     evapi.signal_stop = ev_signal_stop;
291     evapi.idle_start = ev_idle_start;
292     evapi.idle_stop = ev_idle_stop;
293     evapi.prepare_start = ev_prepare_start;
294     evapi.prepare_stop = ev_prepare_stop;
295     evapi.check_start = ev_check_start;
296     evapi.check_stop = ev_check_stop;
297     evapi.child_start = ev_child_start;
298     evapi.child_stop = ev_child_stop;
299 root 1.11
300     sv_setiv (sv, (IV)&evapi);
301     SvREADONLY_on (sv);
302     }
303 root 1.33
304     pthread_atfork (ev_fork_prepare, ev_fork_parent, ev_fork_child);
305 root 1.1 }
306    
307 root 1.15 NV ev_now ()
308 root 1.1 CODE:
309 root 1.15 RETVAL = ev_now;
310 root 1.1 OUTPUT:
311     RETVAL
312    
313 root 1.15 int ev_method ()
314 root 1.1 CODE:
315 root 1.15 RETVAL = ev_method;
316 root 1.1 OUTPUT:
317     RETVAL
318    
319 root 1.15 NV ev_time ()
320 root 1.1
321 root 1.15 void ev_init (int flags = 0)
322 root 1.1
323 root 1.15 void ev_loop (int flags = 0)
324 root 1.1
325 root 1.15 void ev_loop_done (int value = 1)
326 root 1.1 CODE:
327 root 1.15 ev_loop_done = value;
328 root 1.1
329 root 1.15 struct ev_io *io (SV *fh, int events, SV *cb)
330     ALIAS:
331     io_ns = 1
332 root 1.1 CODE:
333 root 1.31 {
334     int fd = sv_fileno (fh);
335     CHECK_FD (fh, fd);
336    
337 root 1.15 RETVAL = e_new (sizeof (struct ev_io), cb);
338     RETVAL->fh = newSVsv (fh);
339 root 1.31 ev_io_set (RETVAL, fd, events);
340 root 1.29 if (!ix) ev_io_start (RETVAL);
341 root 1.31 }
342 root 1.1 OUTPUT:
343     RETVAL
344    
345 root 1.15 struct ev_timer *timer (NV after, NV repeat, SV *cb)
346 root 1.1 ALIAS:
347 root 1.15 timer_ns = 1
348 root 1.18 INIT:
349     CHECK_REPEAT (repeat);
350 root 1.1 CODE:
351 root 1.15 RETVAL = e_new (sizeof (struct ev_timer), cb);
352 root 1.29 ev_timer_set (RETVAL, after, repeat);
353     if (!ix) ev_timer_start (RETVAL);
354 root 1.1 OUTPUT:
355     RETVAL
356    
357 root 1.15 struct ev_periodic *periodic (NV at, NV interval, SV *cb)
358 root 1.9 ALIAS:
359 root 1.15 periodic_ns = 1
360 root 1.18 INIT:
361     CHECK_REPEAT (interval);
362 root 1.9 CODE:
363 root 1.15 RETVAL = e_new (sizeof (struct ev_periodic), cb);
364 root 1.29 ev_periodic_set (RETVAL, at, interval);
365     if (!ix) ev_periodic_start (RETVAL);
366 root 1.9 OUTPUT:
367     RETVAL
368    
369 root 1.15 struct ev_signal *signal (Signal signum, SV *cb)
370 root 1.1 ALIAS:
371 root 1.15 signal_ns = 1
372 root 1.1 CODE:
373 root 1.15 RETVAL = e_new (sizeof (struct ev_signal), cb);
374 root 1.29 ev_signal_set (RETVAL, signum);
375     if (!ix) ev_signal_start (RETVAL);
376 root 1.1 OUTPUT:
377     RETVAL
378    
379 root 1.15 struct ev_idle *idle (SV *cb)
380 root 1.1 ALIAS:
381 root 1.15 idle_ns = 1
382 root 1.1 CODE:
383 root 1.15 RETVAL = e_new (sizeof (struct ev_idle), cb);
384 root 1.29 ev_idle_set (RETVAL);
385     if (!ix) ev_idle_start (RETVAL);
386 root 1.1 OUTPUT:
387     RETVAL
388    
389 root 1.22 struct ev_prepare *prepare (SV *cb)
390     ALIAS:
391     prepare_ns = 1
392     CODE:
393     RETVAL = e_new (sizeof (struct ev_prepare), cb);
394 root 1.29 ev_prepare_set (RETVAL);
395     if (!ix) ev_prepare_start (RETVAL);
396 root 1.22 OUTPUT:
397     RETVAL
398    
399 root 1.15 struct ev_check *check (SV *cb)
400 root 1.1 ALIAS:
401 root 1.15 check_ns = 1
402 root 1.1 CODE:
403 root 1.15 RETVAL = e_new (sizeof (struct ev_check), cb);
404 root 1.29 ev_check_set (RETVAL);
405     if (!ix) ev_check_start (RETVAL);
406 root 1.1 OUTPUT:
407     RETVAL
408    
409 root 1.25 struct ev_child *child (int pid, SV *cb)
410 root 1.23 ALIAS:
411     check_ns = 1
412     CODE:
413     RETVAL = e_new (sizeof (struct ev_check), cb);
414 root 1.29 ev_child_set (RETVAL, pid);
415     if (!ix) ev_child_start (RETVAL);
416 root 1.23 OUTPUT:
417     RETVAL
418    
419 root 1.15
420 root 1.1 PROTOTYPES: DISABLE
421    
422 root 1.15 MODULE = EV PACKAGE = EV::Watcher PREFIX = ev_
423 root 1.1
424 root 1.15 int ev_is_active (struct ev_watcher *w)
425 root 1.1
426 root 1.15 SV *cb (struct ev_watcher *w, SV *new_cb = 0)
427 root 1.1 CODE:
428 root 1.15 {
429     RETVAL = newSVsv (w->cb_sv);
430    
431     if (items > 1)
432     sv_setsv (w->cb_sv, new_cb);
433     }
434 root 1.1 OUTPUT:
435     RETVAL
436    
437 root 1.28 void trigger (struct ev_watcher *w, int revents = EV_NONE)
438     CODE:
439     w->cb (w, revents);
440    
441 root 1.29 MODULE = EV PACKAGE = EV::Io PREFIX = ev_io_
442 root 1.1
443 root 1.29 void ev_io_start (struct ev_io *w)
444 root 1.1
445 root 1.29 void ev_io_stop (struct ev_io *w)
446 root 1.15
447 root 1.26 void DESTROY (struct ev_io *w)
448     CODE:
449 root 1.29 ev_io_stop (w);
450 root 1.34 e_destroy (w);
451 root 1.26
452 root 1.15 void set (struct ev_io *w, SV *fh, int events)
453 root 1.1 CODE:
454     {
455 root 1.15 int active = w->active;
456 root 1.31 int fd = sv_fileno (fh);
457     CHECK_FD (fh, fd);
458    
459 root 1.29 if (active) ev_io_stop (w);
460 root 1.1
461 root 1.15 sv_setsv (w->fh, fh);
462 root 1.31 ev_io_set (w, fd, events);
463 root 1.1
464 root 1.29 if (active) ev_io_start (w);
465 root 1.15 }
466 root 1.1
467 root 1.15 SV *fh (struct ev_io *w, SV *new_fh = 0)
468 root 1.1 CODE:
469 root 1.15 {
470     RETVAL = newSVsv (w->fh);
471 root 1.1
472 root 1.15 if (items > 1)
473     {
474     int active = w->active;
475 root 1.29 if (active) ev_io_stop (w);
476 root 1.1
477 root 1.15 sv_setsv (w->fh, new_fh);
478 root 1.29 ev_io_set (w, sv_fileno (w->fh), w->events);
479 root 1.1
480 root 1.29 if (active) ev_io_start (w);
481 root 1.15 }
482     }
483 root 1.1 OUTPUT:
484     RETVAL
485    
486 root 1.37 int events (struct ev_io *w, int new_events = EV_UNDEF)
487 root 1.1 CODE:
488 root 1.15 {
489     RETVAL = w->events;
490    
491     if (items > 1)
492     {
493     int active = w->active;
494 root 1.29 if (active) ev_io_stop (w);
495 root 1.15
496 root 1.29 ev_io_set (w, w->fd, new_events);
497 root 1.15
498 root 1.29 if (active) ev_io_start (w);
499 root 1.15 }
500     }
501 root 1.1 OUTPUT:
502     RETVAL
503    
504 root 1.29 MODULE = EV PACKAGE = EV::Signal PREFIX = ev_signal_
505 root 1.15
506 root 1.29 void ev_signal_start (struct ev_signal *w)
507 root 1.15
508 root 1.29 void ev_signal_stop (struct ev_signal *w)
509 root 1.15
510 root 1.26 void DESTROY (struct ev_signal *w)
511     CODE:
512 root 1.29 ev_signal_stop (w);
513 root 1.34 e_destroy (w);
514 root 1.26
515 root 1.15 void set (struct ev_signal *w, SV *signal = 0)
516 root 1.1 CODE:
517 root 1.15 {
518     Signal signum = sv_signum (signal); /* may croak here */
519     int active = w->active;
520    
521 root 1.29 if (active) ev_signal_stop (w);
522     ev_signal_set (w, signum);
523     if (active) ev_signal_start (w);
524 root 1.15 }
525    
526     MODULE = EV PACKAGE = EV::Time
527    
528 root 1.29 MODULE = EV PACKAGE = EV::Timer PREFIX = ev_timer_
529 root 1.15
530 root 1.29 void ev_timer_start (struct ev_timer *w)
531 root 1.18 INIT:
532     CHECK_REPEAT (w->repeat);
533 root 1.15
534 root 1.29 void ev_timer_stop (struct ev_timer *w)
535 root 1.1
536 root 1.29 void ev_timer_again (struct ev_timer *w)
537 root 1.18 INIT:
538     CHECK_REPEAT (w->repeat);
539 root 1.17
540 root 1.26 void DESTROY (struct ev_timer *w)
541     CODE:
542 root 1.29 ev_timer_stop (w);
543 root 1.34 e_destroy (w);
544 root 1.26
545 root 1.15 void set (struct ev_timer *w, NV after, NV repeat = 0.)
546 root 1.18 INIT:
547     CHECK_REPEAT (repeat);
548 root 1.1 CODE:
549 root 1.15 {
550     int active = w->active;
551 root 1.29 if (active) ev_timer_stop (w);
552     ev_timer_set (w, after, repeat);
553     if (active) ev_timer_start (w);
554 root 1.15 }
555 root 1.1
556 root 1.29 MODULE = EV PACKAGE = EV::Periodic PREFIX = ev_periodic_
557 root 1.15
558 root 1.29 void ev_periodic_start (struct ev_periodic *w)
559 root 1.18 INIT:
560     CHECK_REPEAT (w->interval);
561 root 1.1
562 root 1.29 void ev_periodic_stop (struct ev_periodic *w)
563 root 1.1
564 root 1.26 void DESTROY (struct ev_periodic *w)
565     CODE:
566 root 1.29 ev_periodic_stop (w);
567 root 1.34 e_destroy (w);
568 root 1.26
569 root 1.15 void set (struct ev_periodic *w, NV at, NV interval = 0.)
570 root 1.18 INIT:
571     CHECK_REPEAT (interval);
572 root 1.10 CODE:
573     {
574 root 1.15 int active = w->active;
575 root 1.29 if (active) ev_periodic_stop (w);
576     ev_periodic_set (w, at, interval);
577     if (active) ev_periodic_start (w);
578 root 1.15 }
579 root 1.10
580 root 1.29 MODULE = EV PACKAGE = EV::Idle PREFIX = ev_idle_
581 root 1.10
582 root 1.29 void ev_idle_start (struct ev_idle *w)
583 root 1.10
584 root 1.29 void ev_idle_stop (struct ev_idle *w)
585 root 1.10
586 root 1.26 void DESTROY (struct ev_idle *w)
587     CODE:
588 root 1.29 ev_idle_stop (w);
589 root 1.34 e_destroy (w);
590 root 1.26
591 root 1.29 MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_check_
592 root 1.22
593 root 1.29 void ev_prepare_start (struct ev_prepare *w)
594 root 1.22
595 root 1.29 void ev_prepare_stop (struct ev_prepare *w)
596 root 1.22
597 root 1.26 void DESTROY (struct ev_prepare *w)
598     CODE:
599 root 1.29 ev_prepare_stop (w);
600 root 1.34 e_destroy (w);
601 root 1.26
602 root 1.29 MODULE = EV PACKAGE = EV::Check PREFIX = ev_check_
603 root 1.1
604 root 1.29 void ev_check_start (struct ev_check *w)
605 root 1.1
606 root 1.29 void ev_check_stop (struct ev_check *w)
607 root 1.1
608 root 1.26 void DESTROY (struct ev_check *w)
609     CODE:
610 root 1.29 ev_check_stop (w);
611 root 1.34 e_destroy (w);
612 root 1.26
613 root 1.29 MODULE = EV PACKAGE = EV::Child PREFIX = ev_child_
614 root 1.23
615 root 1.29 void ev_child_start (struct ev_child *w)
616 root 1.23
617 root 1.29 void ev_child_stop (struct ev_child *w)
618 root 1.23
619 root 1.26 void DESTROY (struct ev_child *w)
620     CODE:
621 root 1.29 ev_child_stop (w);
622 root 1.34 e_destroy (w);
623 root 1.26
624 root 1.23 void set (struct ev_child *w, int pid)
625     CODE:
626     {
627     int active = w->active;
628 root 1.29 if (active) ev_child_stop (w);
629     ev_child_set (w, pid);
630     if (active) ev_child_start (w);
631 root 1.23 }
632    
633 root 1.24 int status (struct ev_child *w)
634     CODE:
635     RETVAL = w->status;
636     OUTPUT:
637     RETVAL
638    
639 root 1.1 MODULE = EV PACKAGE = EV::DNS PREFIX = evdns_
640    
641     BOOT:
642     {
643     HV *stash = gv_stashpv ("EV::DNS", 1);
644    
645     static const struct {
646     const char *name;
647     IV iv;
648     } *civ, const_iv[] = {
649     # define const_iv(pfx, name) { # name, (IV) pfx ## name },
650     const_iv (DNS_, ERR_NONE)
651     const_iv (DNS_, ERR_FORMAT)
652     const_iv (DNS_, ERR_SERVERFAILED)
653     const_iv (DNS_, ERR_NOTEXIST)
654     const_iv (DNS_, ERR_NOTIMPL)
655     const_iv (DNS_, ERR_REFUSED)
656     const_iv (DNS_, ERR_TRUNCATED)
657     const_iv (DNS_, ERR_UNKNOWN)
658     const_iv (DNS_, ERR_TIMEOUT)
659     const_iv (DNS_, ERR_SHUTDOWN)
660     const_iv (DNS_, IPv4_A)
661     const_iv (DNS_, PTR)
662     const_iv (DNS_, IPv6_AAAA)
663     const_iv (DNS_, QUERY_NO_SEARCH)
664     const_iv (DNS_, OPTION_SEARCH)
665     const_iv (DNS_, OPTION_NAMESERVERS)
666     const_iv (DNS_, OPTION_MISC)
667     const_iv (DNS_, OPTIONS_ALL)
668     const_iv (DNS_, NO_SEARCH)
669     };
670    
671     for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
672     newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
673     }
674    
675     int evdns_init ()
676    
677     void evdns_shutdown (int fail_requests = 1)
678    
679     const char *evdns_err_to_string (int err)
680    
681     int evdns_nameserver_add (U32 address)
682    
683     int evdns_count_nameservers ()
684    
685     int evdns_clear_nameservers_and_suspend ()
686    
687     int evdns_resume ()
688    
689     int evdns_nameserver_ip_add (char *ip_as_string)
690    
691     int evdns_resolve_ipv4 (const char *name, int flags, SV *cb)
692     C_ARGS: name, flags, dns_cb, (void *)SvREFCNT_inc (cb)
693    
694     int evdns_resolve_ipv6 (const char *name, int flags, SV *cb)
695     C_ARGS: name, flags, dns_cb, (void *)SvREFCNT_inc (cb)
696    
697     int evdns_resolve_reverse (SV *addr, int flags, SV *cb)
698     ALIAS:
699     evdns_resolve_reverse_ipv6 = 1
700     CODE:
701     {
702     STRLEN len;
703     char *data = SvPVbyte (addr, len);
704     if (len != (ix ? 16 : 4))
705 root 1.8 croak ("ipv4/ipv6 address to be resolved must be given as 4/16 byte octet string");
706 root 1.1
707     RETVAL = ix
708     ? evdns_resolve_reverse_ipv6 ((struct in6_addr *)data, flags, dns_cb, (void *)SvREFCNT_inc (cb))
709     : evdns_resolve_reverse ((struct in_addr *)data, flags, dns_cb, (void *)SvREFCNT_inc (cb));
710     }
711     OUTPUT:
712     RETVAL
713    
714     int evdns_set_option (char *option, char *val, int flags)
715    
716     int evdns_resolv_conf_parse (int flags, const char *filename)
717    
718     #ifdef MS_WINDOWS
719    
720     int evdns_config_windows_nameservers ()
721    
722     #endif
723    
724     void evdns_search_clear ()
725    
726     void evdns_search_add (char *domain)
727    
728     void evdns_search_ndots_set (int ndots)
729    
730 root 1.36 #if 0
731 root 1.5
732     MODULE = EV PACKAGE = EV::HTTP PREFIX = evhttp_
733    
734     BOOT:
735     {
736     HV *stash = gv_stashpv ("EV::HTTP", 1);
737    
738     static const struct {
739     const char *name;
740     IV iv;
741     } *civ, const_iv[] = {
742     # define const_iv(pfx, name) { # name, (IV) pfx ## name },
743     const_iv (HTTP_, OK)
744     const_iv (HTTP_, NOCONTENT)
745     const_iv (HTTP_, MOVEPERM)
746     const_iv (HTTP_, MOVETEMP)
747     const_iv (HTTP_, NOTMODIFIED)
748     const_iv (HTTP_, BADREQUEST)
749     const_iv (HTTP_, NOTFOUND)
750     const_iv (HTTP_, SERVUNAVAIL)
751     const_iv (EVHTTP_, REQ_OWN_CONNECTION)
752     const_iv (EVHTTP_, PROXY_REQUEST)
753     const_iv (EVHTTP_, REQ_GET)
754     const_iv (EVHTTP_, REQ_POST)
755     const_iv (EVHTTP_, REQ_HEAD)
756     const_iv (EVHTTP_, REQUEST)
757     const_iv (EVHTTP_, RESPONSE)
758     };
759    
760     for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
761     newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
762     }
763    
764     MODULE = EV PACKAGE = EV::HTTP::Request PREFIX = evhttp_request_
765    
766     #HttpRequest new (SV *klass, SV *cb)
767    
768     #void DESTROY (struct evhttp_request *req);
769    
770 root 1.15 #endif
771    
772 root 1.5
773    
774    
775    
776    
777    
778