Home
last modified time | relevance | path

Searched refs:jobPtr (Results 1 – 25 of 55) sorted by relevance

123

/dports/textproc/libxml2/libxml2-2.9.12/example/
H A Dgjobread.c103 } job, *jobPtr; typedef
108 static jobPtr
110 jobPtr ret = NULL; in parseJob()
116 ret = (jobPtr) malloc(sizeof(job)); in parseJob()
155 printJob(jobPtr cur) { in printJob()
175 jobPtr jobs[500]; /* using dynamic alloc is left as an exercise */
183 jobPtr curjob; in parseGjobFile()
/dports/graphics/opencollada/OpenCOLLADA-1.6.68/Externals/LibXML/example/
H A Dgjobread.c103 } job, *jobPtr; typedef
108 static jobPtr
110 jobPtr ret = NULL; in parseJob()
116 ret = (jobPtr) malloc(sizeof(job)); in parseJob()
155 printJob(jobPtr cur) { in printJob()
175 jobPtr jobs[500]; /* using dynamic alloc is left as an exercise */
183 jobPtr curjob; in parseGjobFile()
/dports/textproc/py-libxml2/libxml2-2.9.12/example/
H A Dgjobread.c103 } job, *jobPtr; typedef
108 static jobPtr
110 jobPtr ret = NULL; in parseJob()
116 ret = (jobPtr) malloc(sizeof(job)); in parseJob()
155 printJob(jobPtr cur) { in printJob()
175 jobPtr jobs[500]; /* using dynamic alloc is left as an exercise */
183 jobPtr curjob; in parseGjobFile()
/dports/www/falkon/falkon-3.2.0/src/plugins/KDEFrameworksIntegration/
H A Dkioschemehandler.cpp48 QPointer<QWebEngineUrlRequestJob> jobPtr = job; in requestStarted() local
51 if (!jobPtr) { in requestStarted()
/dports/net/cjdns/cjdns-cjdns-v21.1/memory/
H A DAllocator.c663 struct Allocator_OnFreeJob_pvt** jobPtr = &(context->onFree); in Allocator_cancelOnFree() local
664 while (*jobPtr != NULL) { in Allocator_cancelOnFree()
665 if (*jobPtr == job) { in Allocator_cancelOnFree()
666 *jobPtr = (*jobPtr)->next; in Allocator_cancelOnFree()
669 jobPtr = &(*jobPtr)->next; in Allocator_cancelOnFree()
/dports/archivers/zstd/zstd-1.5.0/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/emulators/ppsspp/ppsspp-1.12.3/ext/zstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/archivers/py-zstd/zstd-1.5.0.4/zstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/graphics/aloadimage/arcan-0.6.1/src/a12/external/zstd/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/archivers/c-blosc/c-blosc-1.21.0/internal-complibs/zstd-1.4.8/compress/
H A Dzstdmt_compress.c1068 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1069 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1070 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1074 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1075 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1078 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1096 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1097 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1098 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1102 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/archivers/c-blosc2/c-blosc2-2.0.4/internal-complibs/zstd-1.5.0/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/sysutils/acfgfs/arcan-0.6.1/src/a12/external/zstd/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/emulators/ppsspp-qt5/ppsspp-1.12.3/ext/zstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID];
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex);
1081 { size_t const cResult = jobPtr->cSize;
1085 fps.ingested += jobPtr->src.size;
1086 fps.consumed += jobPtr->consumed;
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size);
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID];
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex);
1109 { size_t const cResult = jobPtr->cSize;
1113 assert(jobPtr->consumed <= jobPtr->src.size);
[all …]
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/zstd-sys-1.5.0+zstd.1.4.9/zstd/lib/compress/
H A Dzstdmt_compress.c1069 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1070 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1071 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1075 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1076 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1079 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1097 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1098 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1099 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1103 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmzstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmzstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/devel/cmake/cmake-3.22.1/Utilities/cmzstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/emulators/citra/citra-ac98458e0/externals/zstd/lib/compress/
H A Dzstdmt_compress.c1068 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1069 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1070 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1074 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1075 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1078 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1096 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1097 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1098 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1102 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/emulators/citra-qt5/citra-ac98458e0/externals/zstd/lib/compress/
H A Dzstdmt_compress.c1068 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1069 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1070 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1074 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1075 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1078 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1096 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1097 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1098 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1102 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/emulators/libretro-ppsspp/ppsspp-1.12.3/ext/zstd/lib/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/x11/aclip/arcan-0.6.1/src/a12/external/zstd/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/sysutils/onefetch/onefetch-2.10.2/cargo-crates/zstd-sys-1.4.18+zstd.1.4.7/zstd/lib/compress/
H A Dzstdmt_compress.c1068 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1069 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1070 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1074 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1075 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1078 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1096 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1097 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1098 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1102 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/x11/arcan-trayicon/arcan-0.6.1/src/a12/external/zstd/compress/
H A Dzstdmt_compress.c1079 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1080 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1081 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1085 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1086 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1089 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1107 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1108 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1109 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1113 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/devel/sccache/sccache-0.2.15/cargo-crates/zstd-sys-1.4.19+zstd.1.4.8/zstd/lib/compress/
H A Dzstdmt_compress.c1068 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1069 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1070 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1074 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1075 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1078 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1096 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1097 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1098 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1102 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]
/dports/www/miniserve/miniserve-0.18.0/cargo-crates/zstd-sys-1.5.0+zstd.1.4.9/zstd/lib/compress/
H A Dzstdmt_compress.c1069 ZSTDMT_jobDescription* jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_getFrameProgression() local
1070 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_getFrameProgression()
1071 { size_t const cResult = jobPtr->cSize; in ZSTDMT_getFrameProgression()
1075 fps.ingested += jobPtr->src.size; in ZSTDMT_getFrameProgression()
1076 fps.consumed += jobPtr->consumed; in ZSTDMT_getFrameProgression()
1079 fps.nbActiveWorkers += (jobPtr->consumed < jobPtr->src.size); in ZSTDMT_getFrameProgression()
1097 ZSTDMT_jobDescription* const jobPtr = &mtctx->jobs[wJobID]; in ZSTDMT_toFlushNow() local
1098 ZSTD_pthread_mutex_lock(&jobPtr->job_mutex); in ZSTDMT_toFlushNow()
1099 { size_t const cResult = jobPtr->cSize; in ZSTDMT_toFlushNow()
1103 assert(jobPtr->consumed <= jobPtr->src.size); in ZSTDMT_toFlushNow()
[all …]

123