Method CThread

Source/Client/NM_Engine/ThreadHelper.cpp:12–59

#include <lazy_importer.hpp>

CThread::CThread(DWORD dwThreadId) :
	m_dwThreadId(dwThreadId), m_hThread(INVALID_HANDLE_VALUE), m_iThreadCode(0), m_bOpenedThread(false), m_bRoutineCompleted(false)
{
	auto bFail = false;
	auto dwErr = 0UL;

	auto customThread = g_nmApp->ThreadManagerInstance()->GetThreadFromId(dwThreadId);
	if (IS_VALID_SMART_PTR(customThread)) 
	{
		m_hThread		= customThread->GetHandle();
		m_iThreadCode	= customThread->GetCustomCode();
	}
	else 
	{
		m_hThread = g_winapiApiTable->OpenThread(THREAD_ALL_ACCESS, FALSE, dwThreadId);
		if (!IS_VALID_HANDLE(m_hThread))
		{
			bFail = true;
			dwErr = g_winapiApiTable->GetLastError();

			auto threadEnumerator = std::make_unique<CSafeThreadHandle>();
			if (IS_VALID_SMART_PTR(threadEnumerator))
			{
				auto vThreads = threadEnumerator->EnumerateThreads(NtCurrentProcess);
				if (vThreads.empty() == false)
				{
					for (const auto & hCurrThread : vThreads)
					{
						auto dwCurrThreadId = g_winapiApiTable->GetThreadId(hCurrThread);
						if (dwCurrThreadId == dwThreadId)
						{
							bFail = false;
							break;
						}
					}
				}
			}
		}

		if (bFail)
		{
			DEBUG_LOG(LL_CRI, "CThread class can not created for: %u Error: %u Alive: %d", dwThreadId, dwErr, CThreadFunctions::ThreadIsItAlive(dwThreadId));
			g_nmApp->OnCloseRequest(EXIT_ERR_CUSTOM_THREAD_OPEN_FAIL, g_winapiApiTable->GetLastError());
		}

		m_bOpenedThread = true;
	}
}
CThread::CThread(HANDLE hThread) :
	m_hThread(hThread), m_dwThreadId(0), m_iThreadCode(-1), m_bOpenedThread(false), m_bRoutineCompleted(false)
{