Lines Matching defs:_CMtCoder
74 typedef struct _CMtCoder struct
78 size_t blockSize; /* size of input block */
79 unsigned numThreadsMax;
80 UInt64 expectedDataSize;
82 ISeqInStream *inStream;
83 const Byte *inData;
84 size_t inDataSize;
86 ICompressProgress *progress;
87 ISzAllocPtr allocBig;
89 IMtCoderCallback2 *mtCallback;
90 void *mtCallbackObject;
95 size_t allocatedBufsSize;
97 CAutoResetEvent readEvent;
98 CSemaphore blocksSemaphore;
100 BoolInt stopReading;
101 SRes readRes;
104 CAutoResetEvent writeEvents[MTCODER__BLOCKS_MAX];
106 CAutoResetEvent finishedEvent;
107 SRes writeRes;
108 unsigned writeIndex;
109 Byte ReadyBlocks[MTCODER__BLOCKS_MAX];
110 LONG numFinishedThreads;
113 unsigned numStartedThreadsLimit;
114 unsigned numStartedThreads;
116 unsigned numBlocksMax;
117 unsigned blockIndex;
118 UInt64 readProcessed;
120 CCriticalSection cs;
122 unsigned freeBlockHead;
123 unsigned freeBlockList[MTCODER__BLOCKS_MAX];
125 CMtProgress mtProgress;
126 CMtCoderBlock blocks[MTCODER__BLOCKS_MAX];
127 CMtCoderThread threads[MTCODER__THREADS_MAX];