static void nbd_recv_coroutines_enter_all(BlockDriverState *bs)

{

    NBDClientSession *s = nbd_get_client_session(bs);

    int i;



    for (i = 0; i < MAX_NBD_REQUESTS; i++) {

        if (s->recv_coroutine[i]) {

            qemu_coroutine_enter(s->recv_coroutine[i]);

        }

    }

    BDRV_POLL_WHILE(bs, s->read_reply_co);

}

static void nbd_recv_coroutines_enter_all(BlockDriverState *bs)

{

    NBDClientSession *s = nbd_get_client_session(bs);

    int i;



    for (i = 0; i < MAX_NBD_REQUESTS; i++) {

        if (s->recv_coroutine[i]) {

            qemu_coroutine_enter(s->recv_coroutine[i]);

        }

    }

    BDRV_POLL_WHILE(bs, s->read_reply_co);

}

static void FUNC_0(BlockDriverState *VAR_0)

{

    NBDClientSession *s = nbd_get_client_session(VAR_0);

    int VAR_1;



    for (VAR_1 = 0; VAR_1 < MAX_NBD_REQUESTS; VAR_1++) {

        if (s->recv_coroutine[VAR_1]) {

            qemu_coroutine_enter(s->recv_coroutine[VAR_1]);

        }

    }

    BDRV_POLL_WHILE(VAR_0, s->read_reply_co);

}

static void FUNC_0(BlockDriverState *VAR_0)
{ NBDClientSession *s = nbd_get_client_session(VAR_0); int VAR_1; for (VAR_1 = 0; VAR_1 < MAX_NBD_REQUESTS; VAR_1++) { if (s->recv_coroutine[VAR_1]) { qemu_coroutine_enter(s->recv_coroutine[VAR_1]); } } BDRV_POLL_WHILE(VAR_0, s->read_reply_co); }