111 void CMtThread_Construct(CMtThread *p, CMtCoder *mtCoder)  in CMtThread_Construct()  argument
113   p->mtCoder = mtCoder;  in CMtThread_Construct()
139   if (p->mtCoder->alloc)  in CMtThread_Destruct()
140     IAlloc_Free(p->mtCoder->alloc, p->outBuf);  in CMtThread_Destruct()
143   if (p->mtCoder->alloc)  in CMtThread_Destruct()
144     IAlloc_Free(p->mtCoder->alloc, p->inBuf);  in CMtThread_Destruct()
150   { IAlloc_Free(p->mtCoder->alloc, buf); \
151     size = newSize; buf = (Byte *)IAlloc_Alloc(p->mtCoder->alloc, size); \
156   MY_BUF_ALLOC(p->inBuf, p->inBufSize, p->mtCoder->blockSize)  in CMtThread_Prepare()
157   MY_BUF_ALLOC(p->outBuf, p->outBufSize, p->mtCoder->destBlockSize)  in CMtThread_Prepare()
185 #define GET_NEXT_THREAD(p) &p->mtCoder->threads[p->index == p->mtCoder->numThreads  - 1 ? 0 : p->in…
203     size_t size = p->mtCoder->blockSize;  in MtThread_Process()
206     RINOK(FullRead(p->mtCoder->inStream, p->inBuf, &size));  in MtThread_Process()
207     next->stopReading = *stop = (size != p->mtCoder->blockSize);  in MtThread_Process()
211     RINOK(p->mtCoder->mtCallback->Code(p->mtCoder->mtCallback, p->index,  in MtThread_Process()
214     MtProgress_Reinit(&p->mtCoder->mtProgress, p->index);  in MtThread_Process()
220     if (p->mtCoder->outStream->Write(p->mtCoder->outStream, p->outBuf, destSize) != destSize)  in MtThread_Process()
236       MtCoder_SetError(p->mtCoder, res);  in ThreadFunc()
237       MtProgress_SetError(&p->mtCoder->mtProgress, res);  in ThreadFunc()