aboutsummaryrefslogtreecommitdiff
path: root/C/MtCoder.c
diff options
context:
space:
mode:
Diffstat (limited to 'C/MtCoder.c')
-rw-r--r--C/MtCoder.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/C/MtCoder.c b/C/MtCoder.c
index 6f58abb..03959b6 100644
--- a/C/MtCoder.c
+++ b/C/MtCoder.c
@@ -1,5 +1,5 @@
1/* MtCoder.c -- Multi-thread Coder 1/* MtCoder.c -- Multi-thread Coder
22023-04-13 : Igor Pavlov : Public domain */ 22023-09-07 : Igor Pavlov : Public domain */
3 3
4#include "Precomp.h" 4#include "Precomp.h"
5 5
@@ -430,7 +430,7 @@ SRes MtCoder_Code(CMtCoder *p)
430 SRes res = SZ_OK; 430 SRes res = SZ_OK;
431 431
432 if (numThreads > MTCODER_THREADS_MAX) 432 if (numThreads > MTCODER_THREADS_MAX)
433 numThreads = MTCODER_THREADS_MAX; 433 numThreads = MTCODER_THREADS_MAX;
434 numBlocksMax = MTCODER_GET_NUM_BLOCKS_FROM_THREADS(numThreads); 434 numBlocksMax = MTCODER_GET_NUM_BLOCKS_FROM_THREADS(numThreads);
435 435
436 if (p->blockSize < ((UInt32)1 << 26)) numBlocksMax++; 436 if (p->blockSize < ((UInt32)1 << 26)) numBlocksMax++;
@@ -438,7 +438,7 @@ SRes MtCoder_Code(CMtCoder *p)
438 if (p->blockSize < ((UInt32)1 << 22)) numBlocksMax++; 438 if (p->blockSize < ((UInt32)1 << 22)) numBlocksMax++;
439 439
440 if (numBlocksMax > MTCODER_BLOCKS_MAX) 440 if (numBlocksMax > MTCODER_BLOCKS_MAX)
441 numBlocksMax = MTCODER_BLOCKS_MAX; 441 numBlocksMax = MTCODER_BLOCKS_MAX;
442 442
443 if (p->blockSize != p->allocatedBufsSize) 443 if (p->blockSize != p->allocatedBufsSize)
444 { 444 {
@@ -469,7 +469,7 @@ SRes MtCoder_Code(CMtCoder *p)
469 469
470 { 470 {
471 RINOK_THREAD(AutoResetEvent_OptCreate_And_Reset(&p->readEvent)) 471 RINOK_THREAD(AutoResetEvent_OptCreate_And_Reset(&p->readEvent))
472 RINOK_THREAD(Semaphore_OptCreateInit(&p->blocksSemaphore, numBlocksMax, numBlocksMax)) 472 RINOK_THREAD(Semaphore_OptCreateInit(&p->blocksSemaphore, (UInt32)numBlocksMax, (UInt32)numBlocksMax))
473 } 473 }
474 474
475 for (i = 0; i < MTCODER_BLOCKS_MAX - 1; i++) 475 for (i = 0; i < MTCODER_BLOCKS_MAX - 1; i++)