… | |
… | |
160 | |
160 | |
161 | static SV *on_next_submit; |
161 | static SV *on_next_submit; |
162 | static int next_pri = EIO_PRI_DEFAULT; |
162 | static int next_pri = EIO_PRI_DEFAULT; |
163 | static int max_outstanding; |
163 | static int max_outstanding; |
164 | |
164 | |
165 | static int respipe_osf [2]; |
|
|
166 | static s_epipe respipe; |
165 | static s_epipe respipe; |
167 | |
166 | |
168 | static void req_destroy (aio_req req); |
167 | static void req_destroy (aio_req req); |
169 | static void req_cancel (aio_req req); |
168 | static void req_cancel (aio_req req); |
170 | |
169 | |
… | |
… | |
445 | static void |
444 | static void |
446 | create_respipe (void) |
445 | create_respipe (void) |
447 | { |
446 | { |
448 | if (s_epipe_renew (&respipe)) |
447 | if (s_epipe_renew (&respipe)) |
449 | croak ("unable to initialize result pipe"); |
448 | croak ("unable to initialize result pipe"); |
450 | |
|
|
451 | respipe_osf [0] = S_TO_SOCKET (respipe.fd [0]); |
|
|
452 | respipe_osf [1] = S_TO_SOCKET (respipe.fd [1]); |
|
|
453 | } |
449 | } |
454 | |
450 | |
455 | static void poll_wait (void) |
451 | static void poll_wait (void) |
456 | { |
452 | { |
457 | while (eio_nreqs ()) |
453 | while (eio_nreqs ()) |