… | |
… | |
704 | { |
704 | { |
705 | while (eio_nreqs ()) |
705 | while (eio_nreqs ()) |
706 | { |
706 | { |
707 | int size; |
707 | int size; |
708 | |
708 | |
709 | X_LOCK (reslock); |
709 | X_LOCK (EIO_POOL->reslock); |
710 | size = res_queue.size; |
710 | size = EIO_POOL->res_queue.size; |
711 | X_UNLOCK (reslock); |
711 | X_UNLOCK (EIO_POOL->reslock); |
712 | |
712 | |
713 | if (size) |
713 | if (size) |
714 | return; |
714 | return; |
715 | |
715 | |
716 | etp_maybe_start_thread (); |
716 | etp_maybe_start_thread (EIO_POOL); |
717 | |
717 | |
718 | s_epipe_wait (&respipe); |
718 | s_epipe_wait (&respipe); |
719 | } |
719 | } |
720 | } |
720 | } |
721 | |
721 | |