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

Comparing EV/schmorp.h (file contents):
Revision 1.2 by root, Tue Jul 14 02:33:55 2009 UTC vs.
Revision 1.9 by root, Thu Jul 8 00:45:03 2010 UTC

… …
2#define SCHMORP_PERL_H_ 2#define SCHMORP_PERL_H_
3 3
4/* WARNING 4/* WARNING
5 * This header file is a shared resource between many modules. 5 * This header file is a shared resource between many modules.
6 */ 6 */
7
8#include <signal.h>
9#include <errno.h>
10
11#if defined(WIN32 ) || defined(_MINIX)
12# define SCHMORP_H_PREFER_SELECT 1
13#endif
14
15#if !SCHMORP_H_PREFER_SELECT
16# include <poll.h>
17#endif
7 18
8/* useful stuff, used by schmorp mostly */ 19/* useful stuff, used by schmorp mostly */
9 20
10#include "patchlevel.h" 21#include "patchlevel.h"
11 22
… …
13 (PERL_REVISION > (a) \ 24 (PERL_REVISION > (a) \
14 || (PERL_REVISION == (a) \ 25 || (PERL_REVISION == (a) \
15 && (PERL_VERSION > (b) \ 26 && (PERL_VERSION > (b) \
16 || (PERL_VERSION == (b) && PERL_SUBVERSION >= (c))))) 27 || (PERL_VERSION == (b) && PERL_SUBVERSION >= (c)))))
17 28
29#ifndef PERL_MAGIC_ext
30# define PERL_MAGIC_ext '~'
31#endif
32
18#if !PERL_VERSION_ATLEAST (5,6,0) 33#if !PERL_VERSION_ATLEAST (5,6,0)
19# ifndef PL_ppaddr 34# ifndef PL_ppaddr
20# define PL_ppaddr ppaddr 35# define PL_ppaddr ppaddr
21# endif 36# endif
22# ifndef call_sv 37# ifndef call_sv
… …
187 S_GENSUB_ARG = arg; 202 S_GENSUB_ARG = arg;
188 203
189 return newRV_noinc ((SV *)cv); 204 return newRV_noinc ((SV *)cv);
190} 205}
191 206
207/*****************************************************************************/
208/* portable pipe/socketpair */
209
210#ifdef USE_SOCKETS_AS_HANDLES
211# define S_TO_HANDLE(x) ((HANDLE)win32_get_osfhandle (x))
212#else
213# define S_TO_HANDLE(x) ((HANDLE)x)
214#endif
215
216#ifdef _WIN32
217/* taken almost verbatim from libev's ev_win32.c */
218/* oh, the humanity! */
219static int
220s_pipe (int filedes [2])
221{
222 dTHX;
223
224 struct sockaddr_in addr = { 0 };
225 int addr_size = sizeof (addr);
226 struct sockaddr_in adr2;
227 int adr2_size = sizeof (adr2);
228 SOCKET listener;
229 SOCKET sock [2] = { -1, -1 };
230
231 if ((listener = socket (AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET)
232 return -1;
233
234 addr.sin_family = AF_INET;
235 addr.sin_addr.s_addr = htonl (INADDR_LOOPBACK);
236 addr.sin_port = 0;
237
238 if (bind (listener, (struct sockaddr *)&addr, addr_size))
239 goto fail;
240
241 if (getsockname (listener, (struct sockaddr *)&addr, &addr_size))
242 goto fail;
243
244 if (listen (listener, 1))
245 goto fail;
246
247 if ((sock [0] = socket (AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET)
248 goto fail;
249
250 if (connect (sock [0], (struct sockaddr *)&addr, addr_size))
251 goto fail;
252
253 if ((sock [1] = accept (listener, 0, 0)) < 0)
254 goto fail;
255
256 /* windows vista returns fantasy port numbers for getpeername.
257 * example for two interconnected tcp sockets:
258 *
259 * (Socket::unpack_sockaddr_in getsockname $sock0)[0] == 53364
260 * (Socket::unpack_sockaddr_in getpeername $sock0)[0] == 53363
261 * (Socket::unpack_sockaddr_in getsockname $sock1)[0] == 53363
262 * (Socket::unpack_sockaddr_in getpeername $sock1)[0] == 53365
263 *
264 * wow! tridirectional sockets!
265 *
266 * this way of checking ports seems to work:
267 */
268 if (getpeername (sock [0], (struct sockaddr *)&addr, &addr_size))
269 goto fail;
270
271 if (getsockname (sock [1], (struct sockaddr *)&adr2, &adr2_size))
272 goto fail;
273
274 errno = WSAEINVAL;
275 if (addr_size != adr2_size
276 || addr.sin_addr.s_addr != adr2.sin_addr.s_addr /* just to be sure, I mean, it's windows */
277 || addr.sin_port != adr2.sin_port)
278 goto fail;
279
280 closesocket (listener);
281
282#ifdef USE_SOCKETS_AS_HANDLES
283 /* when select isn't winsocket, we also expect socket, connect, accept etc.
284 * to work on fds */
285 filedes [0] = sock [0];
286 filedes [1] = sock [1];
287#else
288 filedes [0] = _open_osfhandle (sock [0], 0);
289 filedes [1] = _open_osfhandle (sock [1], 0);
290#endif
291
292 return 0;
293
294fail:
295 closesocket (listener);
296
297 if (sock [0] != INVALID_SOCKET) closesocket (sock [0]);
298 if (sock [1] != INVALID_SOCKET) closesocket (sock [1]);
299
300 return -1;
301}
302
303#define s_socketpair(domain,type,protocol,filedes) s_pipe (filedes)
304
305static int
306s_fd_blocking (int fd, int blocking)
307{
308 u_long nonblocking = !blocking;
309
310 return ioctlsocket ((SOCKET)S_TO_HANDLE (fd), FIONBIO, &nonblocking);
311}
312
313#define s_fd_prepare(fd) s_fd_blocking (fd, 0)
314
315#else
316
317#define s_socketpair(domain,type,protocol,filedes) socketpair (domain, type, protocol, filedes)
318#define s_pipe(filedes) pipe (filedes)
319
320static int
321s_fd_blocking (int fd, int blocking)
322{
323 return fcntl (fd, F_SETFL, blocking ? 0 : O_NONBLOCK);
324}
325
326static int
327s_fd_prepare (int fd)
328{
329 return s_fd_blocking (fd, 0)
330 || fcntl (fd, F_SETFD, FD_CLOEXEC);
331}
332
333#endif
334
335#if __linux && (__GLIBC__ > 2 || (__GLIBC__ == 2 && __GLIBC_MINOR__ >= 7))
336# define SCHMORP_H_HAVE_EVENTFD 1
337/* our minimum requirement is glibc 2.7 which has the stub, but not the header */
338# include <stdint.h>
339# ifdef __cplusplus
340extern "C" {
192#endif 341# endif
342 int eventfd (unsigned int initval, int flags);
343# ifdef __cplusplus
344}
345# endif
346#else
347# define eventfd(initval,flags) -1
348#endif
193 349
350typedef struct {
351 int fd[2]; /* read, write fd, might be equal */
352 int len; /* write length (1 pipe/socket, 8 eventfd) */
353} s_epipe;
354
355static int
356s_epipe_new (s_epipe *epp)
357{
358 s_epipe ep;
359
360 ep.fd [0] = ep.fd [1] = eventfd (0, 0);
361
362 if (ep.fd [0] >= 0)
363 {
364 s_fd_prepare (ep.fd [0]);
365 ep.len = 8;
366 }
367 else
368 {
369 if (s_pipe (ep.fd))
370 return -1;
371
372 if (s_fd_prepare (ep.fd [0])
373 || s_fd_prepare (ep.fd [1]))
374 {
375 dTHX;
376
377 close (ep.fd [0]);
378 close (ep.fd [1]);
379 return -1;
380 }
381
382 ep.len = 1;
383 }
384
385 *epp = ep;
386 return 0;
387}
388
389static void
390s_epipe_destroy (s_epipe *epp)
391{
392 dTHX;
393
394 close (epp->fd [0]);
395
396 if (epp->fd [1] != epp->fd [0])
397 close (epp->fd [1]);
398
399 epp->len = 0;
400}
401
402static void
403s_epipe_signal (s_epipe *epp)
404{
405#ifdef _WIN32
406 /* perl overrides send with a function that crashes in other threads.
407 * unfortunately, it overrides it with an argument-less macro, so
408 * there is no way to force usage of the real send function.
409 * incompetent windows programmers - is this redundant?
410 */
411 DWORD dummy;
412 WriteFile (S_TO_HANDLE (epp->fd [1]), (LPCVOID)&dummy, 1, &dummy, 0);
413#else
414# if SCHMORP_H_HAVE_EVENTFD
415 static uint64_t counter = 1;
416# else
417 static char counter [8];
418# endif
419 /* some modules accept fd's from outside, support eventfd here */
420 if (write (epp->fd [1], &counter, epp->len) < 0
421 && errno == EINVAL
422 && epp->len != 8)
423 write (epp->fd [1], &counter, (epp->len = 8));
424#endif
425}
426
427static void
428s_epipe_drain (s_epipe *epp)
429{
430 dTHX;
431 char buf [9];
432
433#ifdef _WIN32
434 recv (epp->fd [0], buf, sizeof (buf), 0);
435#else
436 read (epp->fd [0], buf, sizeof (buf));
437#endif
438}
439
440/* like new, but dups over old */
441static int
442s_epipe_renew (s_epipe *epp)
443{
444 dTHX;
445 s_epipe epn;
446
447 if (epp->fd [1] != epp->fd [0])
448 close (epp->fd [1]);
449
450 if (s_epipe_new (&epn))
451 return -1;
452
453 if (epp->len)
454 {
455 if (dup2 (epn.fd [0], epp->fd [0]) < 0)
456 croak ("unable to dup over old event pipe"); /* should not croak */
457
458 close (epn.fd [0]);
459
460 if (epn.fd [0] == epn.fd [1])
461 epn.fd [1] = epp->fd [0];
462
463 epn.fd [0] = epp->fd [0];
464 }
465
466 *epp = epn;
467
468 return 0;
469}
470
471#define s_epipe_fd(epp) ((epp)->fd [0])
472
473static int
474s_epipe_wait (s_epipe *epp)
475{
476 dTHX;
477#if SCHMORP_H_PREFER_SELECT
478 fd_set rfd;
479 int fd = s_epipe_fd (epp);
480
481 FD_ZERO (&rfd);
482 FD_SET (fd, &rfd);
483
484 return PerlSock_select (fd + 1, &rfd, 0, 0, 0);
485#else
486 /* poll is preferable on posix systems */
487 struct pollfd pfd;
488
489 pfd.fd = s_epipe_fd (epp);
490 pfd.events = POLLIN;
491
492 return poll (&pfd, 1, -1);
493#endif
494}
495
496#endif
497

Diff Legend

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