--- IO-AIO/AIO.xs 2007/07/08 11:05:36 1.104 +++ IO-AIO/AIO.xs 2007/07/08 11:12:15 1.105 @@ -803,7 +803,7 @@ { /* read any signals sent by the worker threads */ char buf [4]; - while (PerlSock_recv (respipe [0], buf, 4, 0) == 4) + while (respipe_read (respipe [0], buf, 4) == 4) ; } } @@ -1295,7 +1295,7 @@ if (!reqq_push (&res_queue, req)) { /* write a dummy byte to the pipe so fh becomes ready */ - send (respipe_osf [1], (const void *)&respipe_osf, 1, 0); + respipe_write (respipe_osf [1], (const void *)&respipe_osf, 1); /* optionally signal the main thread asynchronously */ if (main_sig) @@ -1372,8 +1372,8 @@ nready = 0; npending = 0; - PerlSock_closesocket (respipe [0]); - PerlSock_closesocket (respipe [1]); + respipe_close (respipe [0]); + respipe_close (respipe [1]); create_pipe (respipe);