Lines Matching refs:me
1671 CXzDecMt *me = (CXzDecMt *)obj;
1672 CXzDecMtThread *coder = &me->coders[coderIndex];
1694 coder->numStreams = me->numStreams;
1695 coder->numTotalBlocks = me->numTotalBlocks;
1696 coder->numBlocks = me->numBlocks;
1700 XzUnpacker_Construct(&coder->dec, &me->alignOffsetAlloc.vt);
1706 if (me->isBlockHeaderState_Parse)
1708 coder->dec.streamFlags = me->streamFlags;
1715 me->isBlockHeaderState_Parse = True;
1718 coder->dec.numStartedStreams = me->numStreams;
1719 coder->dec.numTotalBlocks = me->numTotalBlocks;
1720 coder->dec.numBlocks = me->numBlocks;
1765 // && block->unpackSize <= me->props.outBlockMax
1769 if (block->unpackSize * 2 * me->mtc.numStartedThreads > me->props.memUseMax)
1780 // if (blockPackSum <= me->props.inBlockMax)
1787 me->streamFlags = coder->dec.streamFlags;
1795 // if (coder->inPreSize <= me->props.inBlockMax)
1832 size_t blockMax = me->unpackBlockMaxSize;
1836 UInt64 required = (UInt64)blockMax * (me->mtc.numStartedThreads + 1) * 2;
1837 if (me->props.memUseMax < required)
1842 if (me->outSize_Defined)
1845 const UInt64 rem2 = me->outSize - me->outProcessed_Parse;
1851 me->outProcessed_Parse += coder->outPreSize;
1863 me->numStreams = coder->dec.numStartedStreams;
1864 me->numTotalBlocks = coder->dec.numTotalBlocks;
1865 me->numBlocks = coder->dec.numBlocks + 1;
1873 CXzDecMt *me = (CXzDecMt *)pp;
1874 CXzDecMtThread *coder = &me->coders[coderIndex];
1886 ISzAlloc_Free(me->allocMid, dest);
1894 dest = (Byte *)ISzAlloc_Alloc(me->allocMid, outPreSize);
1901 if (coder->outBufSize > me->unpackBlockMaxSize)
1902 me->unpackBlockMaxSize = coder->outBufSize;
1916 if (me->props.ignoreErrors && res != SZ_ERROR_MEM)
1931 CXzDecMt *me = (CXzDecMt *)pp;
1932 CXzDecMtThread *coder = &me->coders[coderIndex];
1995 if (me->props.ignoreErrors && coder->codeRes != SZ_ERROR_MEM)
2014 CXzDecMt *me = (CXzDecMt *)pp;
2015 const CXzDecMtThread *coder = &me->coders[coderIndex];
2017 // PRF(printf("\nWrite processed = %d srcSize = %d\n", (unsigned)me->mtc.inProcessed, (unsigned)srcSize));
2027 if (me->finishedDecoderIndex < 0)
2028 me->finishedDecoderIndex = (int)coderIndex;
2032 if (me->finishedDecoderIndex >= 0)
2035 me->mtc.inProcessed += coder->inCodeSize;
2044 // we use in me->dec: sha, numBlocks, indexSize
2046 if (!me->isBlockHeaderState_Write)
2048 XzUnpacker_PrepareToRandomBlockDecoding(&me->dec);
2049 me->dec.decodeOnlyOneBlock = False;
2050 me->dec.numStartedStreams = coder->dec.numStartedStreams;
2051 me->dec.streamFlags = coder->streamFlags;
2053 me->isBlockHeaderState_Write = True;
2056 me->dec.numTotalBlocks = coder->dec.numTotalBlocks;
2057 XzUnpacker_UpdateIndex(&me->dec, coder->blockPackSize_for_Index, coder->outPreSize);
2061 if (me->props.ignoreErrors)
2066 // me->numBadBlocks++;
2067 if (me->mainErrorCode == SZ_OK)
2070 me->mainErrorCode = SZ_ERROR_INPUT_EOF;
2072 me->mainErrorCode = SZ_ERROR_DATA;
2076 if (me->writeRes != SZ_OK)
2077 return me->writeRes;
2081 if (me->outSize_Defined)
2083 const UInt64 rem = me->outSize - me->outProcessed;
2095 written = ISeqOutStream_Write(me->outStream, data, cur);
2099 me->outProcessed += written;
2102 me->writeRes = SZ_ERROR_WRITE;
2103 res = me->writeRes;
2111 res = MtProgress_ProgressAdd(&me->mtc.mtProgress, 0, 0);
2118 if (!me->props.ignoreErrors)
2120 me->finishedDecoderIndex = (int)coderIndex;
2129 me->finishedDecoderIndex = (int)coderIndex;
2143 PRF_STR_INT("Write MTDEC_PARSE_END", me->mtc.inProcessed)
2145 me->mtc.mtProgress.totalInSize = me->mtc.inProcessed;
2147 CXzUnpacker *dec = &me->dec;
2160 me->mainDecoderWasCalled = True;
2164 me->parsing_Truncated = True;
2182 me->mtc.readWasFinished, // srcFinished
2188 me->status = status;
2189 me->codeRes = res;
2192 me->mtc.crossStart += srcProcessed;
2194 me->mtc.inProcessed += srcProcessed;
2195 me->mtc.mtProgress.totalInSize = me->mtc.inProcessed;
2209 me->isBlockHeaderState_Parse = False;
2210 me->isBlockHeaderState_Write = False;
2214 Byte *crossBuf = MtDec_GetCrossBuff(&me->mtc);
2219 me->mtc.crossStart = 0;
2220 me->mtc.crossEnd = srcSize;
2223 PRF_STR_INT("XZ_STATE_STREAM_HEADER crossEnd = ", (unsigned)me->mtc.crossEnd)
2233 if (me->mtc.readWasFinished)
2243 UInt64 inProgressPrev = me->mtc.inProcessed;
2246 Byte *crossBuf = MtDec_GetCrossBuff(&me->mtc);
2264 if (!me->mtc.readWasFinished)
2267 inLim = me->mtc.inBufSize;
2268 me->mtc.readRes = ISeqInStream_Read(me->inStream, (void *)crossBuf, &inLim);
2269 me->mtc.readProcessed += inLim;
2270 if (inLim == 0 || me->mtc.readRes != SZ_OK)
2271 me->mtc.readWasFinished = True;
2284 me->codeRes = res;
2285 me->status = status;
2287 me->mtc.inProcessed += inProcessed;
2288 me->mtc.mtProgress.totalInSize = me->mtc.inProcessed;
2299 me->mtc.crossStart = inPos;
2300 me->mtc.crossEnd = inLim;
2301 me->isBlockHeaderState_Parse = False;
2302 me->isBlockHeaderState_Write = False;
2309 if (me->mtc.progress)
2311 UInt64 inDelta = me->mtc.inProcessed - inProgressPrev;
2314 RINOK(MtProgress_Progress_ST(&me->mtc.mtProgress))
2315 inProgressPrev = me->mtc.inProcessed;
2318 if (me->mtc.readWasFinished)