Method Entry

src/PartFileHashThread.cpp:92–167

void* CPartFileHashThread::Entry()
{
	m_bRun = true;

	AddDebugLogLineN(logPartFile, wxT("Hash thread: started"));

	while (m_bRun)
	{
		// Move queued jobs to a local work list under the lock.
		// Mirrors CPartFileWriteThread's pattern: minimise lock hold
		// time so the main thread can keep enqueueing.
		std::list<HashJob> workList;
		{
			wxMutexLocker lock(m_mutex);
			if (m_bRun && !m_bWorkPending) {
				m_condition.WaitTimeout(500);
			}
			m_bWorkPending = false;
			workList.swap(m_jobList);
		}

		for (std::list<HashJob>::iterator it = workList.begin();
			 it != workList.end() && m_bRun; ++it)
		{
			const uint64 startTick = GetTickCount64();

			// CPartFile::m_pendingHashes was incremented before enqueue
			// and is the gate that ~CPartFile waits on, so the file
			// pointer is guaranteed valid here.
			//
			// Lock m_hpartfileMutex against CPartFileWriteThread: with
			// ENABLE_MMAP=OFF, HashSinglePart's CFileArea::ReadAt does
			// Seek+Read on the same fd that the write thread does
			// Seek+Write on for FlushAt; concurrent execution races
			// on the fd's file position. The quiescent guard at
			// enqueue time only gates dispatch — it does not prevent
			// writes from resuming while the hash thread is still
			// chewing through a backlog (e.g. user pause → drain →
			// resume mid-drain). See CPartFile::m_hpartfileMutex.
			bool ok;
			{
				std::lock_guard<std::mutex> lock(it->pFile->m_hpartfileMutex);
				ok = it->pFile->HashSinglePart(it->partNumber);
			}
			//uint32 shall be enough time to hash a file
			const uint32 elapsedMs = GetTickCount64() - startTick;

			AddDebugLogLineN(logPartFile, CFormat(
				"Hash thread: part %u %s in %u ms for '%s'")
				% it->partNumber
				% (ok ? wxT("ok") : wxT("CORRUPT"))
				% elapsedMs
				% it->pFile->GetFileName());
			// Silence the unused-variable warning in release builds, where
			// AddDebugLogLineN above compiles to a no-op.  Caught on lint
			// as clang-analyzer-deadcode.DeadStores.
			wxUnusedVar(elapsedMs);