Method FinalizeIOJobs

CrySystem/RefStreamEngine.cpp:332–366

In the Multi-Threaded model (with the IO Worker thread) removes the proxies from the IO Queue as needed, and the proxies may call their callbacks

// In the Multi-Threaded model (with the IO Worker thread)
// removes the proxies from the IO Queue as needed, and the proxies may call their callbacks
unsigned CRefStreamEngine::FinalizeIOJobs(unsigned nFlags)
{
	unsigned numFinalizedJobs = 0;
	// we fetch the executed jobs one-by-one, and finalize them
	// during finalization, the queue itself may be changed

	if (!IsCallbackTimeQuota(nFlags))
		return 0;

	AUTO_LOCK(m_csIOExecuted);
	while (!m_queIOExecuted.empty())
	{
		CRefReadStreamProxy_AutoPtr pProxy = m_queIOExecuted.front();
		m_queIOExecuted.pop_front();
		// to avoid locking the whole array during execution of the callbacks:
		AUTO_UNLOCK(m_csIOExecuted);

		assert(pProxy->IsIOExecuted());

		int64 nStartTime, nEndTime;
		QueryPerformanceCounter ((LARGE_INTEGER*)&nStartTime);
		// TODO: add control over the callback execution time
		// this proxy needs to be moved out of the IO queue
		pProxy->FinalizeIO ();
		++numFinalizedJobs;
		QueryPerformanceCounter((LARGE_INTEGER*)&nEndTime);

		m_nCallbackTimeQuota -= nEndTime - nStartTime;

		if (!IsCallbackTimeQuota(nFlags))
			break;
	}

	return numFinalizedJobs;
}


// this will be the thread that executes everything that can take time