/dports/textproc/libxml2/libxml2-2.9.12/example/ |
H A D | gjobread.c | 103 } 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 D | gjobread.c | 103 } 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 D | gjobread.c | 103 } 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 D | kioschemehandler.cpp | 48 QPointer<QWebEngineUrlRequestJob> jobPtr = job; in requestStarted() local 51 if (!jobPtr) { in requestStarted()
|
/dports/net/cjdns/cjdns-cjdns-v21.1/memory/ |
H A D | Allocator.c | 663 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1068 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1069 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1068 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 D | zstdmt_compress.c | 1068 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1068 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 D | zstdmt_compress.c | 1079 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 D | zstdmt_compress.c | 1068 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 D | zstdmt_compress.c | 1069 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 …]
|