Commit bb52b14b authored by Stefan Hajnoczi's avatar Stefan Hajnoczi
Browse files

thread-pool: drop thread_pool_active() 



.io_flush() is no longer called so drop thread_pool_active().  The block
layer is the only thread-pool.c user and it already tracks in-flight
requests, therefore we do not need thread_pool_active().

Signed-off-by: default avatarStefan Hajnoczi <stefanha@redhat.com>
parent ce689368

thread-pool.c

+1 −7
Original line number Diff line number Diff line
@@ -197,12 +197,6 @@ restart: 
    }

}



static int thread_pool_active(EventNotifier *notifier)

{

    ThreadPool *pool = container_of(notifier, ThreadPool, notifier);

    return !QLIST_EMPTY(&pool->head);

}



static void thread_pool_cancel(BlockDriverAIOCB *acb)

{

    ThreadPoolElement *elem = (ThreadPoolElement *)acb;
@@ -310,7 +304,7 @@ static void thread_pool_init_one(ThreadPool *pool, AioContext *ctx) 
    QTAILQ_INIT(&pool->request_list);



    aio_set_event_notifier(ctx, &pool->notifier, event_notifier_ready,

                           thread_pool_active);

                           NULL);

}



ThreadPool *thread_pool_new(AioContext *ctx)