af6220aade
Batch #12934 by cremane: 0 byte-identical, 1 confirmed by peer review. - fn_07612 NMessageMgr::Register: logic confirmed by peer review Peer-reviewed-by: gordaoprogramas, Tanke, codeplay Accepted without human review: peers confirmed the logic ("same" ahead by at least 3, with 70% of the votes).
78 lines
1.8 KiB
C++
78 lines
1.8 KiB
C++
#include "Utility/Async/NMessageMgr.h"
|
|
#include "Utility/Threading/NSyncObject.h"
|
|
|
|
#include <new>
|
|
|
|
// STATIC: 0x0138D3EC
|
|
// GLOBAL: gl_24361
|
|
NMessageMgr* g_messageMgr;
|
|
|
|
NInter::~NInter() = default;
|
|
|
|
// INLINED
|
|
NMessageMgr::NMessageMgr() {
|
|
this->m_enabled = false;
|
|
InitializeCriticalSection(&this->m_criticalSection);
|
|
this->m_enabled = true;
|
|
}
|
|
|
|
// INLINED
|
|
NMessageMgr::~NMessageMgr() {
|
|
DeleteCriticalSection(&this->m_criticalSection);
|
|
}
|
|
|
|
// OFFSET: 0x007359A0
|
|
// FUNCTION: fn_07610
|
|
bool NMessageMgr::Initialize() {
|
|
g_messageMgr = new (std::nothrow) NMessageMgr;
|
|
if (!g_messageMgr) {
|
|
return false;
|
|
}
|
|
|
|
if (!g_messageMgr->m_enabled) {
|
|
delete g_messageMgr;
|
|
g_messageMgr = nullptr;
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
// OFFSET: 0x00735A90
|
|
// FUNCTION: fn_07611
|
|
void NMessageMgr::Shutdown() {
|
|
if (g_messageMgr) {
|
|
delete g_messageMgr;
|
|
g_messageMgr = nullptr;
|
|
}
|
|
}
|
|
|
|
// OFFSET: 0x00735AB0
|
|
// FUNCTION: fn_07612
|
|
bool NMessageMgr::Register(std::uint32_t objectId, NInter* object) {
|
|
NSyncObject held(&this->m_criticalSection);
|
|
return this->m_objects.insert({objectId, object}).second;
|
|
}
|
|
|
|
// OFFSET: 0x00735BC0
|
|
// FUNCTION: fn_07613
|
|
bool NMessageMgr::Send(std::uint32_t objectId, std::uint32_t argumentLow, std::uint32_t argumentHigh, std::uint32_t id) {
|
|
NSyncObject held(&this->m_criticalSection);
|
|
auto object = this->m_objects.find(objectId);
|
|
if (object == this->m_objects.end()) {
|
|
return false;
|
|
}
|
|
|
|
object->second->Receive(argumentLow, argumentHigh, id);
|
|
return true;
|
|
}
|
|
|
|
// OFFSET: 0x00735C60
|
|
// FUNCTION: fn_07614
|
|
void NMessageMgr::Unregister(std::uint32_t objectId, NInter* object) {
|
|
NSyncObject held(&this->m_criticalSection);
|
|
auto registered = this->m_objects.find(objectId);
|
|
if (registered != this->m_objects.end() && registered->second == object) {
|
|
this->m_objects.erase(registered);
|
|
}
|
|
}
|