07897c8bea
Batch #11163 by ragnarok-clanker: no function's compiled code changes; checked with 226 compiled unit(s), including every includer of Source/Client/Application/UnhandledExceptionHandler.h, Source/Contents/ReputeMgrLoad.inl, Source/Render/RenderSystemBase.h, Source/UI/Lists/UIListBoxTemplate.h, Source/Utility/Async/NRecycleObject.h.
88 lines
1.9 KiB
C++
88 lines
1.9 KiB
C++
#include "Utility/Threading/NThread.h"
|
|
|
|
#include <process.h>
|
|
#include <utility>
|
|
|
|
namespace {
|
|
// OFFSET: 0x00737510
|
|
// FUNCTION: fn_07647
|
|
void SetDebuggerThreadName(unsigned id, const char* name) {
|
|
ULONG_PTR arguments[4] = {0x1000, reinterpret_cast<ULONG_PTR>(name), id, 0};
|
|
__try {
|
|
RaiseException(0x406D1388, 0, 4, arguments);
|
|
} __except (EXCEPTION_EXECUTE_HANDLER) {
|
|
}
|
|
}
|
|
}
|
|
|
|
// OFFSET: 0x00737200
|
|
// FUNCTION: fn_07643
|
|
NThread::NThread(std::string name) : m_threadId(0), unknown_0008(true), m_state(0), m_handle(nullptr), m_name(std::move(name)) {
|
|
}
|
|
|
|
// OFFSET: 0x00737290
|
|
// FUNCTION: fn_07644
|
|
NThread::~NThread() {
|
|
this->Stop();
|
|
}
|
|
|
|
// OFFSET: 0x007375C0
|
|
// FUNCTION: fn_07648
|
|
unsigned __stdcall NThread::Entry(void* parameter) {
|
|
NThread* thread = static_cast<NThread*>(parameter);
|
|
unsigned result = thread->Run();
|
|
thread->m_state = 3;
|
|
|
|
return result;
|
|
}
|
|
|
|
// INLINED
|
|
bool NThread::Start() {
|
|
if (this->m_handle || this->m_state) {
|
|
return false;
|
|
}
|
|
|
|
this->m_handle = reinterpret_cast<HANDLE>(_beginthreadex(nullptr, 0, Entry, this, CREATE_SUSPENDED, &this->m_threadId));
|
|
if (!this->m_handle) {
|
|
return false;
|
|
}
|
|
|
|
ResumeThread(this->m_handle);
|
|
this->m_state = 1;
|
|
SetDebuggerThreadName(this->m_threadId, this->m_name.c_str());
|
|
|
|
return true;
|
|
}
|
|
|
|
// OFFSET: 0x00737480
|
|
// FUNCTION: fn_45509
|
|
void NThread::Stop() {
|
|
switch (this->m_state) {
|
|
case 2:
|
|
if (ResumeThread(this->m_handle) != static_cast<DWORD>(-1)) {
|
|
this->m_state = 1;
|
|
}
|
|
[[fallthrough]];
|
|
case 1:
|
|
this->RequestStop();
|
|
WaitForSingleObject(this->m_handle, 3000);
|
|
[[fallthrough]];
|
|
case 3:
|
|
if (this->m_handle) {
|
|
CloseHandle(this->m_handle);
|
|
this->m_handle = nullptr;
|
|
}
|
|
this->m_state = 0;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
// OFFSET: 0x007374F0
|
|
// FUNCTION: fn_07646
|
|
void NThread::Resume() {
|
|
if (this->m_state == 2 && ResumeThread(this->m_handle) != static_cast<DWORD>(-1)) {
|
|
this->m_state = 1;
|
|
}
|
|
}
|