Home
last modified time | relevance | path

Searched refs:numStartedThreads (Results 1 - 5 of 5) sorted by relevance

/third_party/lzma/C/
H A DMtDec.c554 if (p->numStartedThreads < p->numStartedThreads_Limit && canCreateNewThread) in MtDec_ThreadFunc2()
556 SRes res2 = MtDecThread_CreateAndStart(&p->threads[p->numStartedThreads]); in MtDec_ThreadFunc2()
559 // if (p->numStartedThreads % 1000 == 0) PRF(printf("\n numStartedThreads=%d\n", 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()
[all...]
H A DMtCoder.c185 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()
H A DMtCoder.h114 unsigned numStartedThreads; member
H A DMtDec.h162 unsigned numStartedThreads; member
H A DXzDec.c1769 if (block->unpackSize * 2 * me->mtc.numStartedThreads > me->props.memUseMax) in XzDecMt_Callback_Parse()
1836 UInt64 required = (UInt64)blockMax * (me->mtc.numStartedThreads + 1) * 2; in XzDecMt_Callback_Parse()

Completed in 6 milliseconds