| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 433 unsigned doneJobID; member
540 while (zcs->doneJobID < zcs->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
541 unsigned const jobID = zcs->doneJobID & zcs->jobIDMask; in ZSTDMT_waitForAllJobsCompleted()
548 zcs->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
845 zcs->doneJobID = 0; in ZSTDMT_initCStream_internal()
961 zcs->doneJobID, in ZSTDMT_createCompressionJob()
962 zcs->doneJobID & zcs->jobIDMask); in ZSTDMT_createCompressionJob()
975 unsigned const wJobID = zcs->doneJobID & zcs->jobIDMask; in ZSTDMT_flushNextJob()
977 if (zcs->doneJobID == zcs->nextJobID) return 0; /* all flushed ! */ in ZSTDMT_flushNextJob()
1016 zcs->doneJobID++; in ZSTDMT_flushNextJob()
[all …]
|
| /dports/archivers/zstd/zstd-1.5.0/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/emulators/ppsspp/ppsspp-1.12.3/ext/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/archivers/py-zstd/zstd-1.5.0.4/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/graphics/aloadimage/arcan-0.6.1/src/a12/external/zstd/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/archivers/c-blosc/c-blosc-1.21.0/internal-complibs/zstd-1.4.8/compress/ |
| H A D | zstdmt_compress.c | 821 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1090 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1285 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1408 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1415 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1456 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1477 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1499 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/archivers/c-blosc2/c-blosc2-2.0.4/internal-complibs/zstd-1.5.0/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/sysutils/acfgfs/arcan-0.6.1/src/a12/external/zstd/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/emulators/ppsspp-qt5/ppsspp-1.12.3/ext/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID;
983 while (mtctx->doneJobID < mtctx->nextJobID) {
991 mtctx->doneJobID++;
1101 unsigned const jobID = mtctx->doneJobID;
1295 mtctx->doneJobID = 0;
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask;
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) {
1466 assert(mtctx->doneJobID < mtctx->nextJobID);
1487 mtctx->doneJobID++;
1509 unsigned const firstJobID = mtctx->doneJobID;
[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 | 822 unsigned doneJobID; member
973 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
981 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1091 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1286 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1409 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1416 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1457 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1478 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1500 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmzstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmzstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/devel/cmake/cmake-3.22.1/Utilities/cmzstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/emulators/citra/citra-ac98458e0/externals/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 821 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1090 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1285 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1408 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1415 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1456 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1477 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1499 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/emulators/citra-qt5/citra-ac98458e0/externals/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 821 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1090 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1285 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1408 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1415 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1456 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1477 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1499 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/emulators/libretro-ppsspp/ppsspp-1.12.3/ext/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/x11/aclip/arcan-0.6.1/src/a12/external/zstd/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[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 | 821 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1090 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1285 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1408 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1415 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1456 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1477 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1499 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/x11/arcan-trayicon/arcan-0.6.1/src/a12/external/zstd/compress/ |
| H A D | zstdmt_compress.c | 832 unsigned doneJobID; member
983 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
991 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1101 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1295 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1418 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1425 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1466 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1487 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1509 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[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 | 821 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1090 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1285 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1408 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1415 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1456 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1477 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1499 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[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 | 822 unsigned doneJobID; member
973 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
981 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1091 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1286 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1409 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1416 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1457 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1478 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1500 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/archivers/p5-Compress-Zstd/Compress-Zstd-0.20/ext/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 803 unsigned doneJobID; member
944 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
952 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1120 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1491 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1660 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1667 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1708 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1727 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1749 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/archivers/py-borgbackup/borgbackup-1.1.17/src/borg/algorithms/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 825 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1148 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1521 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1691 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1698 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1739 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1760 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1782 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/converters/p5-Sereal-Encoder/Sereal-Encoder-4.018/zstd/compress/ |
| H A D | zstdmt_compress.c | 825 unsigned doneJobID; member
972 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
980 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1148 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1521 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1691 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1698 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1739 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1760 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1782 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/third_party/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 803 unsigned doneJobID; member
950 while (mtctx->doneJobID < mtctx->nextJobID) { in ZSTDMT_waitForAllJobsCompleted()
958 mtctx->doneJobID++; in ZSTDMT_waitForAllJobsCompleted()
1126 unsigned const jobID = mtctx->doneJobID; in ZSTDMT_toFlushNow()
1497 mtctx->doneJobID = 0; in ZSTDMT_initCStream_internal()
1666 unsigned const wJobID = mtctx->doneJobID & mtctx->jobIDMask; in ZSTDMT_flushProduced()
1673 && (mtctx->doneJobID < mtctx->nextJobID) ) { in ZSTDMT_flushProduced()
1714 assert(mtctx->doneJobID < mtctx->nextJobID); in ZSTDMT_flushProduced()
1733 mtctx->doneJobID++; in ZSTDMT_flushProduced()
1755 unsigned const firstJobID = mtctx->doneJobID; in ZSTDMT_getInputDataInUse()
[all …]
|