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.
59 lines
1.6 KiB
C++
59 lines
1.6 KiB
C++
#include "Utility/Async/NMessageQueue.h"
|
|
#include "Utility/Threading/NSyncObject.h"
|
|
|
|
// OFFSET: 0x00736340
|
|
// FUNCTION: fn_07619
|
|
NMessageQueue::NMessageQueue() : m_semaphore(nullptr), m_enabled(false) {
|
|
InitializeCriticalSection(&this->m_criticalSection);
|
|
|
|
this->m_semaphore = CreateSemaphoreA(nullptr, 0, 0x7FFFFFFF, "");
|
|
if (this->m_semaphore) {
|
|
this->m_enabled = true;
|
|
}
|
|
}
|
|
|
|
// OFFSET: 0x00736460
|
|
// FUNCTION: fn_07620
|
|
NMessageQueue::~NMessageQueue() {
|
|
if (this->m_semaphore) {
|
|
CloseHandle(this->m_semaphore);
|
|
this->m_semaphore = nullptr;
|
|
}
|
|
|
|
DeleteCriticalSection(&this->m_criticalSection);
|
|
}
|
|
|
|
// OFFSET: 0x00736590
|
|
// FUNCTION: fn_07622
|
|
NMessage* NMessageQueue::Pop(NMessage* message) {
|
|
NSyncObject held(&this->m_criticalSection);
|
|
if (!this->m_messages.empty()) {
|
|
Record record = this->m_messages.front();
|
|
this->m_messages.pop_front();
|
|
message->id = record.id;
|
|
message->argumentHigh = record.argumentHigh;
|
|
message->argumentLow = record.argumentLow;
|
|
message->valid = true;
|
|
} else {
|
|
message->id = 0;
|
|
message->argumentHigh = 0;
|
|
message->argumentLow = 0;
|
|
message->valid = false;
|
|
}
|
|
|
|
return message;
|
|
}
|
|
|
|
// OFFSET: 0x00736660
|
|
// FUNCTION: fn_07624
|
|
void NMessageQueue::Push(std::uint64_t argument, std::uint32_t id) {
|
|
NSyncObject held(&this->m_criticalSection);
|
|
this->m_messages.push_back({static_cast<std::uint32_t>(argument), static_cast<std::uint32_t>(argument >> 32), id});
|
|
ReleaseSemaphore(this->m_semaphore, 1, nullptr);
|
|
}
|
|
|
|
// OFFSET: 0x00736650
|
|
// FUNCTION: fn_07623
|
|
void NMessageQueue::Clear() {
|
|
std::deque<Record>().swap(this->m_messages);
|
|
}
|