| … | |
… | |
| 423 | } |
423 | } |
| 424 | } |
424 | } |
| 425 | |
425 | |
| 426 | static int poll_cb (void) |
426 | static int poll_cb (void) |
| 427 | { |
427 | { |
| 428 | int res; |
428 | for (;;) |
| 429 | |
|
|
| 430 | do |
|
|
| 431 | { |
429 | { |
| 432 | res = eio_poll (); |
430 | int res = eio_poll (); |
| 433 | |
431 | |
| 434 | if (res > 0) |
432 | if (res > 0) |
| 435 | croak (0); |
433 | croak (0); |
|
|
434 | |
|
|
435 | if (!max_outstanding || max_outstanding > eio_nreqs ()) |
|
|
436 | return res; |
|
|
437 | |
|
|
438 | poll_wait (); |
| 436 | } |
439 | } |
| 437 | while (max_outstanding && max_outstanding <= eio_nreqs ()); |
|
|
| 438 | |
|
|
| 439 | return res; |
|
|
| 440 | } |
440 | } |
| 441 | |
441 | |
| 442 | static void atfork_child (void) |
442 | static void atfork_child (void) |
| 443 | { |
443 | { |
| 444 | create_respipe (); |
444 | create_respipe (); |
