113 void CMtThread_Construct(CMtThread *p, CMtCoder *mtCoder)  in CMtThread_Construct()  argument
115   p->mtCoder = mtCoder;  in CMtThread_Construct()
141   if (p->mtCoder->alloc)  in CMtThread_Destruct()
142     IAlloc_Free(p->mtCoder->alloc, p->outBuf);  in CMtThread_Destruct()
145   if (p->mtCoder->alloc)  in CMtThread_Destruct()
146     IAlloc_Free(p->mtCoder->alloc, p->inBuf);  in CMtThread_Destruct()
152   { IAlloc_Free(p->mtCoder->alloc, buf); \
153     size = newSize; buf = (Byte *)IAlloc_Alloc(p->mtCoder->alloc, size); \
158   MY_BUF_ALLOC(p->inBuf, p->inBufSize, p->mtCoder->blockSize)  in CMtThread_Prepare()
159   MY_BUF_ALLOC(p->outBuf, p->outBufSize, p->mtCoder->destBlockSize)  in CMtThread_Prepare()
187 #define GET_NEXT_THREAD(p) &p->mtCoder->threads[p->index == p->mtCoder->numThreads  - 1 ? 0 : p->in…
205     size_t size = p->mtCoder->blockSize;  in MtThread_Process()
208     RINOK(FullRead(p->mtCoder->inStream, p->inBuf, &size));  in MtThread_Process()
209     next->stopReading = *stop = (size != p->mtCoder->blockSize);  in MtThread_Process()
213     RINOK(p->mtCoder->mtCallback->Code(p->mtCoder->mtCallback, p->index,  in MtThread_Process()
216     MtProgress_Reinit(&p->mtCoder->mtProgress, p->index);  in MtThread_Process()
222     if (p->mtCoder->outStream->Write(p->mtCoder->outStream, p->outBuf, destSize) != destSize)  in MtThread_Process()
238       MtCoder_SetError(p->mtCoder, res);  in ThreadFunc()
239       MtProgress_SetError(&p->mtCoder->mtProgress, res);  in ThreadFunc()