Lines Matching refs:mtc
1503 CMtDec mtc; member
1605 MtDec_Destruct(&p->mtc); in XzDecMt_Destroy()
1732 if (block->unpackSize * 2 * me->mtc.numStartedThreads > me->props.memUseMax) in XzDecMt_Callback_Parse()
1799 UInt64 required = (UInt64)blockMax * (me->mtc.numStartedThreads + 1) * 2; in XzDecMt_Callback_Parse()
1995 me->mtc.inProcessed += coder->inCodeSize; in XzDecMt_Callback_Write()
2071 res = MtProgress_ProgressAdd(&me->mtc.mtProgress, 0, 0); in XzDecMt_Callback_Write()
2103 PRF_STR_INT("Write MTDEC_PARSE_END", me->mtc.inProcessed); in XzDecMt_Callback_Write()
2105 me->mtc.mtProgress.totalInSize = me->mtc.inProcessed; in XzDecMt_Callback_Write()
2131 me->mtc.readWasFinished, // srcFinished in XzDecMt_Callback_Write()
2138 me->mtc.inProcessed += srcProcessed; in XzDecMt_Callback_Write()
2139 me->mtc.mtProgress.totalInSize = me->mtc.inProcessed; in XzDecMt_Callback_Write()
2153 Byte *crossBuf = MtDec_GetCrossBuff(&me->mtc); in XzDecMt_Callback_Write()
2158 me->mtc.crossStart = 0; in XzDecMt_Callback_Write()
2159 me->mtc.crossEnd = srcSize - srcProcessed; in XzDecMt_Callback_Write()
2168 if (me->mtc.readWasFinished) in XzDecMt_Callback_Write()
2178 UInt64 inProgressPrev = me->mtc.inProcessed; in XzDecMt_Callback_Write()
2181 Byte *crossBuf = MtDec_GetCrossBuff(&me->mtc); in XzDecMt_Callback_Write()
2200 if (!me->mtc.readWasFinished) in XzDecMt_Callback_Write()
2203 inLim = me->mtc.inBufSize; in XzDecMt_Callback_Write()
2204 me->mtc.readRes = ISeqInStream_Read(me->inStream, (void *)inData, &inLim); in XzDecMt_Callback_Write()
2205 me->mtc.readProcessed += inLim; in XzDecMt_Callback_Write()
2206 if (inLim == 0 || me->mtc.readRes != SZ_OK) in XzDecMt_Callback_Write()
2207 me->mtc.readWasFinished = True; in XzDecMt_Callback_Write()
2223 me->mtc.inProcessed += inProcessed; in XzDecMt_Callback_Write()
2224 me->mtc.mtProgress.totalInSize = me->mtc.inProcessed; in XzDecMt_Callback_Write()
2235 me->mtc.crossStart = inPos; in XzDecMt_Callback_Write()
2236 me->mtc.crossEnd = inLim; in XzDecMt_Callback_Write()
2245 if (me->mtc.progress) in XzDecMt_Callback_Write()
2247 UInt64 inDelta = me->mtc.inProcessed - inProgressPrev; in XzDecMt_Callback_Write()
2250 RINOK(MtProgress_Progress_ST(&me->mtc.mtProgress)); in XzDecMt_Callback_Write()
2251 inProgressPrev = me->mtc.inProcessed; in XzDecMt_Callback_Write()
2254 if (me->mtc.readWasFinished) in XzDecMt_Callback_Write()
2317 tMode = MtDec_PrepareRead(&p->mtc); in XzDecMt_Decode_ST()
2373 inData = MtDec_Read(&p->mtc, &inLim); in XzDecMt_Decode_ST()
2609 MtDec_Construct(&p->mtc); in XzDecMt_Decode()
2612 p->mtc.mtCallback = &vt; in XzDecMt_Decode()
2613 p->mtc.mtCallbackObject = p; in XzDecMt_Decode()
2615 p->mtc.progress = progress; in XzDecMt_Decode()
2616 p->mtc.inStream = inStream; in XzDecMt_Decode()
2617 p->mtc.alloc = &p->alignOffsetAlloc.vt; in XzDecMt_Decode()
2620 p->mtc.inBufSize = p->props.inBufSize_MT; in XzDecMt_Decode()
2622 p->mtc.numThreadsMax = p->props.numThreads; in XzDecMt_Decode()
2634 SRes res = MtDec_Code(&p->mtc); in XzDecMt_Decode()
2636 stat->InSize = p->mtc.inProcessed; in XzDecMt_Decode()
2638 p->inProcessed = p->mtc.inProcessed; in XzDecMt_Decode()
2639 p->readRes = p->mtc.readRes; in XzDecMt_Decode()
2640 p->readWasFinished = p->mtc.readWasFinished; in XzDecMt_Decode()
2641 p->readProcessed = p->mtc.readProcessed; in XzDecMt_Decode()
2648 if (p->mtc.mtProgress.res != SZ_OK) in XzDecMt_Decode()
2650 res = p->mtc.mtProgress.res; in XzDecMt_Decode()
2655 needContinue = p->mtc.needContinue; in XzDecMt_Decode()
2685 p->mtc.readProcessed, p->mtc.inProcessed, in XzDecMt_Decode()
2697 else if (p->mtc.readRes != SZ_OK && p->mtc.inProcessed == p->mtc.readProcessed) in XzDecMt_Decode()
2699 res = p->mtc.readRes; in XzDecMt_Decode()