Lines Matching refs:me
1634 CXzDecMt *me = (CXzDecMt *)obj; in XzDecMt_Callback_Parse() local
1635 CXzDecMtThread *coder = &me->coders[coderIndex]; in XzDecMt_Callback_Parse()
1657 coder->numStreams = me->numStreams; in XzDecMt_Callback_Parse()
1658 coder->numTotalBlocks = me->numTotalBlocks; in XzDecMt_Callback_Parse()
1659 coder->numBlocks = me->numBlocks; in XzDecMt_Callback_Parse()
1663 XzUnpacker_Construct(&coder->dec, &me->alignOffsetAlloc.vt); in XzDecMt_Callback_Parse()
1669 if (me->isBlockHeaderState_Parse) in XzDecMt_Callback_Parse()
1671 coder->dec.streamFlags = me->streamFlags; in XzDecMt_Callback_Parse()
1678 me->isBlockHeaderState_Parse = True; in XzDecMt_Callback_Parse()
1681 coder->dec.numStartedStreams = me->numStreams; in XzDecMt_Callback_Parse()
1682 coder->dec.numTotalBlocks = me->numTotalBlocks; in XzDecMt_Callback_Parse()
1683 coder->dec.numBlocks = me->numBlocks; in XzDecMt_Callback_Parse()
1732 if (block->unpackSize * 2 * me->mtc.numStartedThreads > me->props.memUseMax) in XzDecMt_Callback_Parse()
1750 me->streamFlags = coder->dec.streamFlags; in XzDecMt_Callback_Parse()
1795 size_t blockMax = me->unpackBlockMaxSize; in XzDecMt_Callback_Parse()
1799 UInt64 required = (UInt64)blockMax * (me->mtc.numStartedThreads + 1) * 2; in XzDecMt_Callback_Parse()
1800 if (me->props.memUseMax < required) in XzDecMt_Callback_Parse()
1805 if (me->outSize_Defined) in XzDecMt_Callback_Parse()
1808 const UInt64 rem2 = me->outSize - me->outProcessed_Parse; in XzDecMt_Callback_Parse()
1814 me->outProcessed_Parse += coder->outPreSize; in XzDecMt_Callback_Parse()
1826 me->numStreams = coder->dec.numStartedStreams; in XzDecMt_Callback_Parse()
1827 me->numTotalBlocks = coder->dec.numTotalBlocks; in XzDecMt_Callback_Parse()
1828 me->numBlocks = coder->dec.numBlocks + 1; in XzDecMt_Callback_Parse()
1836 CXzDecMt *me = (CXzDecMt *)pp; in XzDecMt_Callback_PreCode() local
1837 CXzDecMtThread *coder = &me->coders[coderIndex]; in XzDecMt_Callback_PreCode()
1849 ISzAlloc_Free(me->allocMid, dest); in XzDecMt_Callback_PreCode()
1857 dest = (Byte *)ISzAlloc_Alloc(me->allocMid, outPreSize); in XzDecMt_Callback_PreCode()
1864 if (coder->outBufSize > me->unpackBlockMaxSize) in XzDecMt_Callback_PreCode()
1865 me->unpackBlockMaxSize = coder->outBufSize; in XzDecMt_Callback_PreCode()
1879 if (me->props.ignoreErrors && res != SZ_ERROR_MEM) in XzDecMt_Callback_PreCode()
1894 CXzDecMt *me = (CXzDecMt *)pp; in XzDecMt_Callback_Code() local
1895 CXzDecMtThread *coder = &me->coders[coderIndex]; in XzDecMt_Callback_Code()
1955 if (me->props.ignoreErrors && coder->codeRes != SZ_ERROR_MEM) in XzDecMt_Callback_Code()
1974 CXzDecMt *me = (CXzDecMt *)pp; in XzDecMt_Callback_Write() local
1975 const CXzDecMtThread *coder = &me->coders[coderIndex]; in XzDecMt_Callback_Write()
1987 if (me->finishedDecoderIndex < 0) in XzDecMt_Callback_Write()
1988 me->finishedDecoderIndex = coderIndex; in XzDecMt_Callback_Write()
1992 if (me->finishedDecoderIndex >= 0) in XzDecMt_Callback_Write()
1995 me->mtc.inProcessed += coder->inCodeSize; in XzDecMt_Callback_Write()
2006 if (!me->isBlockHeaderState_Write) in XzDecMt_Callback_Write()
2008 XzUnpacker_PrepareToRandomBlockDecoding(&me->dec); in XzDecMt_Callback_Write()
2009 me->dec.decodeOnlyOneBlock = False; in XzDecMt_Callback_Write()
2010 me->dec.numStartedStreams = coder->dec.numStartedStreams; in XzDecMt_Callback_Write()
2011 me->dec.streamFlags = coder->streamFlags; in XzDecMt_Callback_Write()
2013 me->isBlockHeaderState_Write = True; in XzDecMt_Callback_Write()
2016 me->dec.numTotalBlocks = coder->dec.numTotalBlocks; in XzDecMt_Callback_Write()
2017 XzUnpacker_UpdateIndex(&me->dec, coder->blockPackSize_for_Index, coder->outPreSize); in XzDecMt_Callback_Write()
2021 if (me->props.ignoreErrors) in XzDecMt_Callback_Write()
2027 if (me->mainErrorCode == SZ_OK) in XzDecMt_Callback_Write()
2030 me->mainErrorCode = SZ_ERROR_INPUT_EOF; in XzDecMt_Callback_Write()
2032 me->mainErrorCode = SZ_ERROR_DATA; in XzDecMt_Callback_Write()
2036 if (me->writeRes != SZ_OK) in XzDecMt_Callback_Write()
2037 return me->writeRes; in XzDecMt_Callback_Write()
2041 if (me->outSize_Defined) in XzDecMt_Callback_Write()
2043 const UInt64 rem = me->outSize - me->outProcessed; in XzDecMt_Callback_Write()
2055 written = ISeqOutStream_Write(me->outStream, data, cur); in XzDecMt_Callback_Write()
2059 me->outProcessed += written; in XzDecMt_Callback_Write()
2062 me->writeRes = SZ_ERROR_WRITE; in XzDecMt_Callback_Write()
2063 res = me->writeRes; in XzDecMt_Callback_Write()
2071 res = MtProgress_ProgressAdd(&me->mtc.mtProgress, 0, 0); in XzDecMt_Callback_Write()
2078 if (!me->props.ignoreErrors) in XzDecMt_Callback_Write()
2080 me->finishedDecoderIndex = coderIndex; in XzDecMt_Callback_Write()
2089 me->finishedDecoderIndex = coderIndex; 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()
2107 CXzUnpacker *dec = &me->dec; in XzDecMt_Callback_Write()
2120 me->mainDecoderWasCalled = True; in XzDecMt_Callback_Write()
2124 me->parsing_Truncated = True; in XzDecMt_Callback_Write()
2131 me->mtc.readWasFinished, // srcFinished in XzDecMt_Callback_Write()
2135 me->status = status; in XzDecMt_Callback_Write()
2136 me->codeRes = res; 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()
2150 me->isBlockHeaderState_Parse = False; in XzDecMt_Callback_Write()
2151 me->isBlockHeaderState_Write = False; 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()
2220 me->codeRes = res; in XzDecMt_Callback_Write()
2221 me->status = status; 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()
2237 me->isBlockHeaderState_Parse = False; in XzDecMt_Callback_Write()
2238 me->isBlockHeaderState_Write = False; 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()