Home
last modified time | relevance | path

Searched refs:POOL_ctx (Results 1 – 8 of 8) sorted by relevance

/external/zstd/lib/common/
Dpool.c68 POOL_ctx* const ctx = (POOL_ctx*)opaque; in POOL_thread()
108 POOL_ctx* ZSTD_createThreadPool(size_t numThreads) { in ZSTD_createThreadPool()
112 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize) { in POOL_create()
116 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize, in POOL_create_advanced()
118 POOL_ctx* ctx; in POOL_create_advanced()
122 ctx = (POOL_ctx*)ZSTD_customCalloc(sizeof(POOL_ctx), customMem); in POOL_create_advanced()
165 static void POOL_join(POOL_ctx* ctx) { in POOL_join()
180 void POOL_free(POOL_ctx *ctx) { in POOL_free()
195 size_t POOL_sizeof(POOL_ctx *ctx) { in POOL_sizeof()
204 static int POOL_resize_internal(POOL_ctx* ctx, size_t numThreads) in POOL_resize_internal()
[all …]
Dpool.h23 typedef struct POOL_ctx_s POOL_ctx; typedef
31 POOL_ctx* POOL_create(size_t numThreads, size_t queueSize);
33 POOL_ctx* POOL_create_advanced(size_t numThreads, size_t queueSize,
39 void POOL_free(POOL_ctx* ctx);
50 int POOL_resize(POOL_ctx* ctx, size_t numThreads);
56 size_t POOL_sizeof(POOL_ctx* ctx);
69 void POOL_add(POOL_ctx* ctx, POOL_function function, void* opaque);
77 int POOL_tryAdd(POOL_ctx* ctx, POOL_function function, void* opaque);
/external/zstd/tests/
DpoolTests.c46 POOL_ctx* const ctx = POOL_create(numThreads, queueSize); in testOrder()
77 POOL_ctx* const ctx = POOL_create(numThreads, queueSize); in testWait()
117 static int testThreadReduction_internal(POOL_ctx* ctx, poolTest_t test) in testThreadReduction_internal()
157 POOL_ctx* const ctx = POOL_create(4 /*nbThreads*/, 2 /*queueSize*/); in testThreadReduction()
194 POOL_ctx* const ctx = POOL_create(3 /*numThreads*/, nbWaits /*queueSize*/); in testAbruptEnding_internal()
/external/zstd/contrib/seekable_format/examples/
Dparallel_processing.c140 POOL_ctx* pool = POOL_create(nbThreads, nbThreads); in sumFile_orDie()
Dparallel_compression.c125 POOL_ctx* pool = POOL_create(nbThreads, nbThreads); in compressFile_orDie()
/external/zstd/lib/dictBuilder/
Dfastcover.c639 POOL_ctx *pool = NULL; in ZDICT_optimizeTrainFromBuffer_fastCover()
Dcover.c1134 POOL_ctx *pool = NULL; in ZDICT_optimizeTrainFromBuffer_cover()
/external/zstd/lib/compress/
Dzstdmt_compress.c807 POOL_ctx* factory;