| /dports/audio/faust/faust-2.37.3/tools/physicalModeling/mesh2faust/vega/libraries/distanceField/ |
| H A D | distanceFieldMT.cpp | 59 int jobSize = totalSlices / numThreads; in Setup() local
65 startSlice[rank] = zMin + rank * (jobSize+1); in Setup()
66 endSlice[rank] = zMin + (rank+1) * (jobSize+1); in Setup()
70 startSlice[rank] = zMin + remainder * (jobSize+1) + (rank-remainder) * jobSize; in Setup()
71 endSlice[rank] = zMin + remainder * (jobSize+1) + ((rank-remainder)+1) * jobSize; in Setup()
77 printf("Canonical job size: %d \n", jobSize); in Setup()
|
| /dports/audio/faust/faust-2.37.3/tools/physicalModeling/mesh2faust/vega/libraries/stvk/ |
| H A D | StVKStiffnessMatrixMT.cpp | 49 int jobSize = numElements / numThreads; in StVKStiffnessMatrixMT() local
55 startElement[rank] = rank * (jobSize+1); in StVKStiffnessMatrixMT()
56 endElement[rank] = (rank+1) * (jobSize+1); in StVKStiffnessMatrixMT()
60 startElement[rank] = remainder * (jobSize+1) + (rank-remainder) * jobSize; in StVKStiffnessMatrixMT()
61 endElement[rank] = remainder * (jobSize+1) + ((rank-remainder)+1) * jobSize; in StVKStiffnessMatrixMT()
69 printf("Canonical job size: %d \n",jobSize); in StVKStiffnessMatrixMT()
|
| H A D | StVKInternalForcesMT.cpp | 45 int jobSize = numElements / numThreads; in StVKInternalForcesMT() local
51 startElement[rank] = rank * (jobSize+1); in StVKInternalForcesMT()
52 endElement[rank] = (rank+1) * (jobSize+1); in StVKInternalForcesMT()
56 startElement[rank] = remainder * (jobSize+1) + (rank-remainder) * jobSize; in StVKInternalForcesMT()
57 endElement[rank] = remainder * (jobSize+1) + ((rank-remainder)+1) * jobSize; in StVKInternalForcesMT()
63 printf("Canonical job size: %d \n",jobSize); in StVKInternalForcesMT()
|
| /dports/x11-toolkits/scintilla/scite/src/ |
| H A D | Worker.h | 15 std::atomic_size_t jobSize; member
18 Worker() : completed(false), cancelling(false), jobSize(1), jobProgress(0) { in Worker()
38 return jobSize; in SizeJob()
41 jobSize = size; in SetSizeJob()
|
| /dports/editors/scite/scite/src/ |
| H A D | Worker.h | 15 std::atomic_size_t jobSize; member
18 Worker() : completed(false), cancelling(false), jobSize(1), jobProgress(0) { in Worker()
38 return jobSize; in SizeJob()
41 jobSize = size; in SetSizeJob()
|
| /dports/devel/bullet/bullet3-3.21/src/LinearMath/TaskScheduler/ |
| H A D | btTaskScheduler.cpp | 278 void clearQueue(int jobCount, int jobSize)
285 int jobBufSize = jobSize * jobCount;
299 void* allocJobMem(int jobSize)
301 btAssert(m_jobMemSize >= (m_allocSize + jobSize));
303 m_allocSize += jobSize;
668 int jobSize = sizeof(JobType);
672 m_jobQueues[i].clearQueue(jobCount, jobSize);
686 void* jobMem = jq->allocJobMem(jobSize);
721 int jobSize = sizeof(JobType);
724 m_jobQueues[i].clearQueue(jobCount, jobSize);
[all …]
|
| /dports/graphics/blender/blender-2.91.0/extern/bullet2/src/LinearMath/TaskScheduler/ |
| H A D | btTaskScheduler.cpp | 278 void clearQueue(int jobCount, int jobSize)
285 int jobBufSize = jobSize * jobCount;
299 void* allocJobMem(int jobSize)
301 btAssert(m_jobMemSize >= (m_allocSize + jobSize));
303 m_allocSize += jobSize;
668 int jobSize = sizeof(JobType);
672 m_jobQueues[i].clearQueue(jobCount, jobSize);
686 void* jobMem = jq->allocJobMem(jobSize);
721 int jobSize = sizeof(JobType);
724 m_jobQueues[i].clearQueue(jobCount, jobSize);
[all …]
|
| /dports/devel/godot-tools/godot-3.2.3-stable/thirdparty/bullet/LinearMath/TaskScheduler/ |
| H A D | btTaskScheduler.cpp | 278 void clearQueue(int jobCount, int jobSize)
285 int jobBufSize = jobSize * jobCount;
299 void* allocJobMem(int jobSize)
301 btAssert(m_jobMemSize >= (m_allocSize + jobSize));
303 m_allocSize += jobSize;
668 int jobSize = sizeof(JobType);
672 m_jobQueues[i].clearQueue(jobCount, jobSize);
686 void* jobMem = jq->allocJobMem(jobSize);
721 int jobSize = sizeof(JobType);
724 m_jobQueues[i].clearQueue(jobCount, jobSize);
[all …]
|
| /dports/science/chrono/chrono-7.0.1/src/chrono/collision/bullet/LinearMath/TaskScheduler/ |
| H A D | btTaskScheduler.cpp | 278 void clearQueue(int jobCount, int jobSize)
285 int jobBufSize = jobSize * jobCount;
299 void* allocJobMem(int jobSize)
301 btAssert(m_jobMemSize >= (m_allocSize + jobSize));
303 m_allocSize += jobSize;
668 int jobSize = sizeof(JobType);
672 m_jobQueues[i].clearQueue(jobCount, jobSize);
686 void* jobMem = jq->allocJobMem(jobSize);
721 int jobSize = sizeof(JobType);
724 m_jobQueues[i].clearQueue(jobCount, jobSize);
[all …]
|
| /dports/devel/py-bullet3/bullet3-3.21/src/LinearMath/TaskScheduler/ |
| H A D | btTaskScheduler.cpp | 278 void clearQueue(int jobCount, int jobSize)
285 int jobBufSize = jobSize * jobCount;
299 void* allocJobMem(int jobSize)
301 btAssert(m_jobMemSize >= (m_allocSize + jobSize));
303 m_allocSize += jobSize;
668 int jobSize = sizeof(JobType);
672 m_jobQueues[i].clearQueue(jobCount, jobSize);
686 void* jobMem = jq->allocJobMem(jobSize);
721 int jobSize = sizeof(JobType);
724 m_jobQueues[i].clearQueue(jobCount, jobSize);
[all …]
|
| /dports/devel/godot/godot-3.2.3-stable/thirdparty/bullet/LinearMath/TaskScheduler/ |
| H A D | btTaskScheduler.cpp | 278 void clearQueue(int jobCount, int jobSize)
285 int jobBufSize = jobSize * jobCount;
299 void* allocJobMem(int jobSize)
301 btAssert(m_jobMemSize >= (m_allocSize + jobSize));
303 m_allocSize += jobSize;
668 int jobSize = sizeof(JobType);
672 m_jobQueues[i].clearQueue(jobCount, jobSize);
686 void* jobMem = jq->allocJobMem(jobSize);
721 int jobSize = sizeof(JobType);
724 m_jobQueues[i].clearQueue(jobCount, jobSize);
[all …]
|
| /dports/audio/faust/faust-2.37.3/tools/physicalModeling/mesh2faust/vega/libraries/multicore/ |
| H A D | multicore.cpp | 352 int jobSize = n / numThreads; in SplitWorkLoad() local
358 bucketLo[rank] = rank * (jobSize+1); in SplitWorkLoad()
359 bucketHi[rank] = (rank+1) * (jobSize+1); in SplitWorkLoad()
363 bucketLo[rank] = remainder * (jobSize+1) + (rank-remainder) * jobSize; in SplitWorkLoad()
364 bucketHi[rank] = remainder * (jobSize+1) + ((rank-remainder)+1) * jobSize; in SplitWorkLoad()
|
| /dports/devel/py-tables/tables-3.6.1/c-blosc/internal-complibs/zstd-1.3.8/compress/ |
| H A D | zstdmt_compress.c | 510 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
870 params->jobSize = 0; in ZSTDMT_CCtxParam_setNbWorkers()
994 params->jobSize = value; in ZSTDMT_CCtxParam_setMTCtxParameter()
1025 *value = (int)(mtctx->params.jobSize); in ZSTDMT_getMTCtxParameter()
1250 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1279 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1299 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1301 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1401 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1402 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/biology/mmseqs2/MMseqs2-13-45111/lib/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 512 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
872 params->jobSize = 0; in ZSTDMT_CCtxParam_setNbWorkers()
993 params->jobSize = value; in ZSTDMT_CCtxParam_setMTCtxParameter()
1018 *value = mtctx->params.jobSize; in ZSTDMT_getMTCtxParameter()
1199 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1228 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1248 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1250 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1349 …if (params.jobSize > 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MIN; in ZSTDMT_initCStream_internal()
1350 if (params.jobSize > ZSTDMT_JOBSIZE_MAX) params.jobSize = ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/archivers/p5-Compress-Zstd/Compress-Zstd-0.20/ext/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1037 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1251 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1280 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1300 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1302 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1402 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1403 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1440 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/archivers/py-borgbackup/borgbackup-1.1.17/src/borg/algorithms/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 468 size_t jobSize, in ZSTDMT_serialState_reset() argument
533 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
1065 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1280 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1310 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1330 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1332 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1432 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1433 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1470 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/converters/p5-Sereal-Encoder/Sereal-Encoder-4.018/zstd/compress/ |
| H A D | zstdmt_compress.c | 468 size_t jobSize, in ZSTDMT_serialState_reset() argument
533 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
1065 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1280 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1310 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1330 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1332 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1432 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1433 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1470 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/third_party/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/converters/p5-Sereal-Decoder/Sereal-Decoder-4.018/zstd/compress/ |
| H A D | zstdmt_compress.c | 468 size_t jobSize, in ZSTDMT_serialState_reset() argument
533 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
1065 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1280 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1310 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1330 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1332 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1432 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1433 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1470 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/zstd-sys-1.4.15+zstd.1.4.4/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/third_party/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/DataDog/zstd/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/devel/mercurial/mercurial-6.0/contrib/python-zstandard/zstd/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/devel/godot/godot-3.2.3-stable/thirdparty/zstd/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/third_party/zstd/lib/compress/ |
| H A D | zstdmt_compress.c | 511 serialState->params.jobSize = (U32)jobSize; in ZSTDMT_serialState_reset()
554 assert(src.size <= serialState->params.jobSize); in ZSTDMT_serialState_update()
1043 jobParams.jobSize = 0; in ZSTDMT_initJobCCtxParams()
1257 params.jobSize = (U32)avgJobSize; in ZSTDMT_compress_advanced_internal()
1286 mtctx->jobs[u].src.size = jobSize; assert(jobSize > 0); /* avoid job.src.size == 0 */ in ZSTDMT_compress_advanced_internal()
1306 frameStartPos += jobSize; in ZSTDMT_compress_advanced_internal()
1308 remainingSrcSize -= jobSize; in ZSTDMT_compress_advanced_internal()
1408 …if (params.jobSize != 0 && params.jobSize < ZSTDMT_JOBSIZE_MIN) params.jobSize = ZSTDMT_JOBSIZE_MI… in ZSTDMT_initCStream_internal()
1409 if (params.jobSize > (size_t)ZSTDMT_JOBSIZE_MAX) params.jobSize = (size_t)ZSTDMT_JOBSIZE_MAX; in ZSTDMT_initCStream_internal()
1446 mtctx->targetSectionSize = params.jobSize; in ZSTDMT_initCStream_internal()
[all …]
|