| … | … | ||
|---|---|---|---|
| 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 (reslock); |
| 710 | size = res_queue.size; | 710 | size = EIO_POOL->res_queue.size; |
| 711 | X_UNLOCK (reslock); | 711 | X_UNLOCK (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 |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |