Searched refs:numStartedThreads (Results 1 – 5 of 5) sorted by relevance
554 if (p->numStartedThreads < p->numStartedThreads_Limit && canCreateNewThread) in MtDec_ThreadFunc2()556 SRes res2 = MtDecThread_CreateAndStart(&p->threads[p->numStartedThreads]); in MtDec_ThreadFunc2()560 p->numStartedThreads++; in MtDec_ThreadFunc2()564 PRF(printf("\nERROR: numStartedThreads=%d\n", p->numStartedThreads)); in MtDec_ThreadFunc2()565 if (p->numStartedThreads == 1) in MtDec_ThreadFunc2()573 p->numStartedThreads_Limit = p->numStartedThreads; in MtDec_ThreadFunc2()580 nextThread = &p->threads[nextIndex >= p->numStartedThreads ? 0 : nextIndex]; in MtDec_ThreadFunc2()870 if (i > p->numStartedThreads in MtDec_PrepareRead()874 i + p->numStartedThreads - p->filledThreadStart)) in MtDec_PrepareRead()902 if (++p->filledThreadStart == p->numStartedThreads) in MtDec_Read()[all …]
185 if (mtc->numStartedThreads < mtc->numStartedThreadsLimit in ThreadFunc2()188 res = MtCoderThread_CreateAndStart(&mtc->threads[mtc->numStartedThreads]); in ThreadFunc2()190 mtc->numStartedThreads++; in ThreadFunc2()332 if (numFinished == mtc->numStartedThreads) in ThreadFunc()494 p->numStartedThreads = 0; in MtCoder_Code()498 CMtCoderThread *nextThread = &p->threads[p->numStartedThreads++]; in MtCoder_Code()
114 unsigned numStartedThreads; member
162 unsigned numStartedThreads; member
1771 if (block->unpackSize * 2 * me->mtc.numStartedThreads > me->props.memUseMax) in XzDecMt_Callback_Parse()1838 UInt64 required = (UInt64)blockMax * (me->mtc.numStartedThreads + 1) * 2; in XzDecMt_Callback_Parse()