Lines Matching refs:threadPool

165     ctx->threadPool = NULL;  in AIO_IOPool_createThreadPool()
173         ctx->threadPool = POOL_create(1, MAX_IO_JOBS - 2);  in AIO_IOPool_createThreadPool()
175         if (!ctx->threadPool)  in AIO_IOPool_createThreadPool()
187     ctx->totalIoJobs = ctx->threadPool ? MAX_IO_JOBS : 2;  in AIO_IOPool_init()
201     return ctx->threadPool && ctx->threadPoolActive;  in AIO_IOPool_threadPoolActive()
233         POOL_joinJobs(ctx->threadPool);  in AIO_IOPool_join()
252     if(ctx->threadPool) {  in AIO_IOPool_destroy()
257         POOL_free(ctx->threadPool);  in AIO_IOPool_destroy()
304         POOL_add(ctx->threadPool, ctx->poolFunction, job);  in AIO_IOPool_enqueueJob()
471         assert(ctx->base.threadPool != NULL); /* we shouldn't be here if we work in sync mode */  in AIO_ReadPool_getNextCompletedJob()
559     if(ctx->base.threadPool)  in AIO_ReadPool_create()
571     if(ctx->base.threadPool)  in AIO_ReadPool_free()