Lines Matching refs:POOL_ctx
68 POOL_ctx* const ctx = (POOL_ctx*)opaque; in POOL_thread()
109 POOL_ctx* ZSTD_createThreadPool(size_t numThreads) { in ZSTD_createThreadPool()
113 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create()
117 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, in POOL_create_advanced()
120 POOL_ctx* ctx; in POOL_create_advanced()
124 ctx = (POOL_ctx*)ZSTD_customCalloc(sizeof(POOL_ctx), customMem); in POOL_create_advanced()
167 static void POOL_join(POOL_ctx* ctx) { in POOL_join()
182 void POOL_free(POOL_ctx *ctx) { in POOL_free()
197 size_t POOL_sizeof(const POOL_ctx* ctx) { in POOL_sizeof()
206 static int POOL_resize_internal(POOL_ctx* ctx, size_t numThreads) in POOL_resize_internal()
235 int POOL_resize(POOL_ctx* ctx, size_t numThreads) in POOL_resize()
252 static int isQueueFull(POOL_ctx const* ctx) { in isQueueFull()
263 POOL_add_internal(POOL_ctx* ctx, POOL_function function, void *opaque) in POOL_add_internal()
275 void POOL_add(POOL_ctx* ctx, POOL_function function, void* opaque) in POOL_add()
288 int POOL_tryAdd(POOL_ctx* ctx, POOL_function function, void* opaque) in POOL_tryAdd()
313 static POOL_ctx g_poolCtx;
315 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create()
319 POOL_ctx*
328 void POOL_free(POOL_ctx* ctx) { in POOL_free()
333 int POOL_resize(POOL_ctx* ctx, size_t numThreads) { in POOL_resize()
338 void POOL_add(POOL_ctx* ctx, POOL_function function, void* opaque) { in POOL_add()
343 int POOL_tryAdd(POOL_ctx* ctx, POOL_function function, void* opaque) { in POOL_tryAdd()
349 size_t POOL_sizeof(const POOL_ctx* ctx) { in POOL_sizeof()