Searched refs:numStartedThreads (Results 1 – 5 of 5) sorted by relevance
581 if (p->numStartedThreads < p->numStartedThreads_Limit && canCreateNewThread) in ThreadFunc2()583 SRes res2 = MtDecThread_CreateAndStart(&p->threads[p->numStartedThreads]); in ThreadFunc2()587 p->numStartedThreads++; in ThreadFunc2()591 PRF(printf("\nERROR: numStartedThreads=%d\n", p->numStartedThreads)); in ThreadFunc2()592 if (p->numStartedThreads == 1) in ThreadFunc2()600 p->numStartedThreads_Limit = p->numStartedThreads; in ThreadFunc2()607 nextThread = &p->threads[nextIndex >= p->numStartedThreads ? 0 : nextIndex]; in ThreadFunc2()886 if (i > p->numStartedThreads in MtDec_PrepareRead()890 i + p->numStartedThreads - p->filledThreadStart)) in MtDec_PrepareRead()918 if (++p->filledThreadStart == p->numStartedThreads) in MtDec_Read()[all …]
212 if (mtc->numStartedThreads < mtc->numStartedThreadsLimit in ThreadFunc2()215 res = MtCoderThread_CreateAndStart(&mtc->threads[mtc->numStartedThreads]); in ThreadFunc2()217 mtc->numStartedThreads++; in ThreadFunc2()359 if (numFinished == mtc->numStartedThreads) in ThreadFunc()526 p->numStartedThreads = 0; in MtCoder_Code()530 CMtCoderThread *nextThread = &p->threads[p->numStartedThreads++]; in MtCoder_Code()
114 unsigned numStartedThreads; member
161 unsigned numStartedThreads; member
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()