Lines Matching defs:workerId
352 INLINE void UpdateClientStats(SWR_CONTEXT* pContext, uint32_t workerId, DRAW_CONTEXT* pDC)
375 INLINE void ExecuteCallbacks(SWR_CONTEXT* pContext, uint32_t workerId, DRAW_CONTEXT* pDC)
377 UpdateClientStats(pContext, workerId, pDC);
388 INLINE int32_t CompleteDrawContextInl(SWR_CONTEXT* pContext, uint32_t workerId, DRAW_CONTEXT* pDC)
397 ExecuteCallbacks(pContext, workerId, pDC);
424 INLINE bool FindFirstIncompleteDraw(SWR_CONTEXT* pContext, uint32_t workerId, uint32_t& curDrawBE, uint32_t& drawEnqueued)
442 CompleteDrawContextInl(pContext, workerId, pDC);
457 /// @param workerId - The unique worker ID that is assigned to this thread.
471 uint32_t workerId,
482 if (FindFirstIncompleteDraw(pContext, workerId, curDrawBE, drawEnqueued) == false)
553 pContext->pHotTileMgr->InitializeHotTiles(pContext, pDC, workerId, tileID);
562 pWork->pfnWork(pDC, workerId, tileID, &pWork->desc);
577 CompleteDrawContextInl(pContext, workerId, pDC);
603 INLINE void CompleteDrawFE(SWR_CONTEXT* pContext, uint32_t workerId, DRAW_CONTEXT* pDC)
639 void WorkOnFifoFE(SWR_CONTEXT *pContext, uint32_t workerId, uint32_t &curDrawFE)
649 CompleteDrawContextInl(pContext, workerId, pDC);
676 pDC->FeWork.pfnWork(pContext, pDC, workerId, &pDC->FeWork.desc);
678 CompleteDrawFE(pContext, workerId, pDC);
688 /// @param workerId - The unique worker ID that is assigned to this thread.
694 uint32_t workerId,
698 if (FindFirstIncompleteDraw(pContext, workerId, curDrawBE, drawEnqueued) == false)
727 queue.dispatch(pDC, workerId, threadGroupId, pSpillFillBuffer, pScratchSpace);
766 uint32_t workerId = pThreadData->workerId;
779 workerId, pThreadData->numaId, pThreadData->coreId, pThreadData->htId);
853 bShutdown |= WorkOnFifoBE(pContext, workerId, curDrawBE, lockedTiles, numaNode, numaMask);
856 WorkOnCompute(pContext, workerId, curDrawBE);
861 WorkOnFifoFE(pContext, workerId, curDrawFE);
1108 for (uint32_t workerId = 0; workerId < numThreads; ++workerId)
1110 pPool->pThreadData[workerId].workerId = workerId;
1111 pPool->pThreadData[workerId].procGroupId = workerId % numProcGroups;
1112 pPool->pThreadData[workerId].threadId = 0;
1113 pPool->pThreadData[workerId].numaId = 0;
1114 pPool->pThreadData[workerId].coreId = 0;
1115 pPool->pThreadData[workerId].htId = 0;
1116 pPool->pThreadData[workerId].pContext = pContext;
1117 pPool->pThreadData[workerId].forceBindProcGroup = bForceBindProcGroup;
1141 uint32_t workerId = 0;
1171 pPool->pApiThreadData[numReservedThreads].workerId = 0xFFFFFFFFU;
1184 pPool->pApiThreadData[numReservedThreads].workerId = 0xFFFFFFFFU;
1197 SWR_ASSERT(workerId < numThreads);
1199 pPool->pThreadData[workerId].workerId = workerId;
1200 pPool->pThreadData[workerId].procGroupId = core.procGroup;
1201 pPool->pThreadData[workerId].threadId = core.threadIds[t + pContext->threadInfo.BASE_THREAD];
1202 pPool->pThreadData[workerId].numaId = useNuma ? (n + pContext->threadInfo.BASE_NUMA_NODE) : 0;
1203 pPool->pThreadData[workerId].coreId = c + pContext->threadInfo.BASE_CORE;
1204 pPool->pThreadData[workerId].htId = t + pContext->threadInfo.BASE_THREAD;
1205 pPool->pThreadData[workerId].pContext = pContext;
1206 pPool->pThreadData[workerId].forceBindProcGroup = false;
1211 ++workerId;
1215 SWR_ASSERT(workerId == pContext->NumWorkerThreads);
1230 for (uint32_t workerId = 0; workerId < pContext->NumWorkerThreads; ++workerId)
1232 pPool->pThreads[workerId] = new std::thread(workerThreadInit<true, true>, &pPool->pThreadData[workerId]);
