static void nbd_coroutine_start(NBDClientSession *s,

                                NBDRequest *request)

{

    /* Poor man semaphore.  The free_sema is locked when no other request

     * can be accepted, and unlocked after receiving one reply.  */

    if (s->in_flight == MAX_NBD_REQUESTS) {

        qemu_co_queue_wait(&s->free_sema, NULL);

        assert(s->in_flight < MAX_NBD_REQUESTS);

    }

    s->in_flight++;



    /* s->recv_coroutine[i] is set as soon as we get the send_lock.  */

}

static void nbd_coroutine_start(NBDClientSession *s,

                                NBDRequest *request)

{

    



    if (s->in_flight == MAX_NBD_REQUESTS) {

        qemu_co_queue_wait(&s->free_sema, NULL);

        assert(s->in_flight < MAX_NBD_REQUESTS);

    }

    s->in_flight++;



    

}

static void nbd_coroutine_start(NBDClientSession *s,                                 NBDRequest *request)     if (s->in_flight == MAX_NBD_REQUESTS) {         qemu_co_queue_wait(&s->free_sema, NULL);         assert(s->in_flight < MAX_NBD_REQUESTS);     s->in_flight++;
static void FUNC_0(NBDClientSession *VAR_0,

                                NBDRequest *VAR_1)

{

    



    if (VAR_0->in_flight == MAX_NBD_REQUESTS) {

        qemu_co_queue_wait(&VAR_0->free_sema, NULL);

        assert(VAR_0->in_flight < MAX_NBD_REQUESTS);

    }

    VAR_0->in_flight++;



    

}

static void FUNC_0(NBDClientSession *VAR_0,
NBDRequest *VAR_1)
{ if (VAR_0->in_flight == MAX_NBD_REQUESTS) { qemu_co_queue_wait(&VAR_0->free_sema, NULL); assert(VAR_0->in_flight < MAX_NBD_REQUESTS); } VAR_0->in_flight++; }