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

Comparing EV/EV.xs (file contents):
Revision 1.53 by root, Mon Nov 5 21:43:17 2007 UTC vs.
Revision 1.58 by root, Wed Nov 7 13:27:56 2007 UTC

5/*#include <netinet/in.h>*/ 5/*#include <netinet/in.h>*/
6 6
7#define EV_PROTOTYPES 1 7#define EV_PROTOTYPES 1
8#include "EV/EVAPI.h" 8#include "EV/EVAPI.h"
9 9
10/* fix perl api breakage */
11#undef signal
12#undef sigaction
13
14#define EV_SELECT_USE_WIN32_HANDLES 0
15#define EV_SELECT_USE_FD_SET 0
10/* due to bugs in OS X we have to use libev/ explicitly here */ 16/* due to bugs in OS X we have to use libev/ explicitly here */
11#include "libev/ev.c" 17#include "libev/ev.c"
12#include "event.c" 18#include "event.c"
19
20#ifndef WIN32
13#define DNS_USE_GETTIMEOFDAY_FOR_ID 1 21#define DNS_USE_GETTIMEOFDAY_FOR_ID 1
22#if !defined (WIN32) && !defined(__CYGWIN__)
14#define HAVE_STRUCT_IN6_ADDR 1 23# define HAVE_STRUCT_IN6_ADDR 1
24#endif
15#undef HAVE_STRTOK_R 25#undef HAVE_STRTOK_R
16#undef strtok_r 26#undef strtok_r
17#define strtok_r fake_strtok_r 27#define strtok_r fake_strtok_r
18#include "evdns.c" 28#include "evdns.c"
29#endif
30
31#ifndef WIN32
32# include <pthread.h>
33#endif
19 34
20typedef int Signal; 35typedef int Signal;
21 36
22static struct EVAPI evapi; 37static struct EVAPI evapi;
23 38
94 w->self = self; 109 w->self = self;
95 110
96 return (void *)w; 111 return (void *)w;
97} 112}
98 113
99static void * 114static void
100e_destroy (void *w_) 115e_destroy (void *w_)
101{ 116{
102 struct ev_watcher *w = w_; 117 struct ev_watcher *w = (struct ev_watcher *)w_;
103 118
104 SvREFCNT_dec (w->fh ); w->fh = 0; 119 SvREFCNT_dec (w->fh ); w->fh = 0;
105 SvREFCNT_dec (w->cb_sv); w->cb_sv = 0; 120 SvREFCNT_dec (w->cb_sv); w->cb_sv = 0;
106} 121}
107 122
167} 182}
168 183
169///////////////////////////////////////////////////////////////////////////// 184/////////////////////////////////////////////////////////////////////////////
170// DNS 185// DNS
171 186
187#ifndef WIN32
172static void 188static void
173dns_cb (int result, char type, int count, int ttl, void *addresses, void *arg) 189dns_cb (int result, char type, int count, int ttl, void *addresses, void *arg)
174{ 190{
175 dSP; 191 dSP;
176 SV *cb = (SV *)arg; 192 SV *cb = (SV *)arg;
215 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR); 231 call_sv (get_sv ("EV::DIED", 1), G_DISCARD | G_VOID | G_EVAL | G_KEEPERR);
216 } 232 }
217 233
218 LEAVE; 234 LEAVE;
219} 235}
236#endif
220 237
221#define CHECK_REPEAT(repeat) if (repeat < 0.) \ 238#define CHECK_REPEAT(repeat) if (repeat < 0.) \
222 croak (# repeat " value must be >= 0"); 239 croak (# repeat " value must be >= 0");
223 240
224#define CHECK_FD(fh,fd) if ((fd) < 0) \ 241#define CHECK_FD(fh,fd) if ((fd) < 0) \
231 248
232PROTOTYPES: ENABLE 249PROTOTYPES: ENABLE
233 250
234BOOT: 251BOOT:
235{ 252{
236 int i;
237 HV *stash = gv_stashpv ("EV", 1); 253 HV *stash = gv_stashpv ("EV", 1);
238 254
239 static const struct { 255 static const struct {
240 const char *name; 256 const char *name;
241 IV iv; 257 IV iv;
314 evapi.child_stop = ev_child_stop; 330 evapi.child_stop = ev_child_stop;
315 331
316 sv_setiv (sv, (IV)&evapi); 332 sv_setiv (sv, (IV)&evapi);
317 SvREADONLY_on (sv); 333 SvREADONLY_on (sv);
318 } 334 }
319 335#ifndef WIN32
320 pthread_atfork (0, 0, ev_default_fork); 336 pthread_atfork (0, 0, ev_default_fork);
337#endif
321} 338}
322 339
323NV ev_now () 340NV ev_now ()
324 341
325int ev_method () 342int ev_method ()
716 rpid = 1 733 rpid = 1
717 CODE: 734 CODE:
718 RETVAL = ix ? w->rpid : w->rstatus; 735 RETVAL = ix ? w->rpid : w->rstatus;
719 OUTPUT: 736 OUTPUT:
720 RETVAL 737 RETVAL
738
739#ifndef WIN32
721 740
722MODULE = EV PACKAGE = EV::DNS PREFIX = evdns_ 741MODULE = EV PACKAGE = EV::DNS PREFIX = evdns_
723 742
724BOOT: 743BOOT:
725{ 744{
850 869
851#void DESTROY (struct evhttp_request *req); 870#void DESTROY (struct evhttp_request *req);
852 871
853#endif 872#endif
854 873
874#endif
855 875
856 876
857 877
858 878
859 879

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines