42e214f124
Batch #4879 by Millenium: 1 byte-identical, 6 confirmed by peer review. - fn_19733 CTimeScheduler::Init: byte-identical - fn_19734 CTimeScheduler::Create: logic confirmed by peer review - fn_19735 CTimeScheduler::Destroy: logic confirmed by peer review - fn_19736 CTimeScheduler::FindSchedule: logic confirmed by peer review - fn_19737 CTimeScheduler::AddSchedule: logic confirmed by peer review - fn_19738 CTimeScheduler::Process: logic confirmed by peer review - fn_19739 CTimeScheduler::sub_BA95F0: logic confirmed by peer review Peer-reviewed-by: youko, KWDev Accepted without human review: peers confirmed the logic ("same" ahead by at least 3, with 70% of the votes). Adds to the build: Source/Contents/Schedule/TimeScheduler.cpp
119 lines
2.5 KiB
C++
119 lines
2.5 KiB
C++
#include "Contents/Schedule/TimeScheduler.h"
|
|
#include "Contents/Schedule/CheckGDISchedule.h"
|
|
|
|
#include <new>
|
|
|
|
extern "C" long long _Xtime_get_ticks();
|
|
|
|
// INLINED
|
|
CTimeScheduler::CTimeScheduler() {
|
|
this->m_initialized = this->Init();
|
|
this->m_unknown_000D = false;
|
|
}
|
|
|
|
// INLINED
|
|
CTimeScheduler::~CTimeScheduler() {
|
|
for (CSchedule* schedule : this->m_schedules) {
|
|
if (schedule != nullptr) {
|
|
delete schedule;
|
|
}
|
|
}
|
|
this->m_schedules.clear();
|
|
this->m_unknown_000D = false;
|
|
}
|
|
|
|
// OFFSET: 0x00BA91E0
|
|
// FUNCTION: fn_19733
|
|
bool CTimeScheduler::Init() {
|
|
return true;
|
|
}
|
|
|
|
// OFFSET: 0x00BA91F0
|
|
// FUNCTION: fn_19734
|
|
bool CTimeScheduler::Create() {
|
|
if (g_timeScheduler != nullptr) {
|
|
return false;
|
|
}
|
|
|
|
CTimeScheduler* scheduler = new (std::nothrow) CTimeScheduler();
|
|
g_timeScheduler = reinterpret_cast<char*>(scheduler);
|
|
if (scheduler != nullptr) {
|
|
if (scheduler->m_initialized) {
|
|
return true;
|
|
}
|
|
delete scheduler;
|
|
g_timeScheduler = nullptr;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
// OFFSET: 0x00BA9340
|
|
// FUNCTION: fn_19735
|
|
void CTimeScheduler::Destroy() {
|
|
if (g_timeScheduler != nullptr) {
|
|
delete reinterpret_cast<CTimeScheduler*>(g_timeScheduler);
|
|
g_timeScheduler = nullptr;
|
|
}
|
|
}
|
|
|
|
// OFFSET: 0x00BA9360
|
|
// FUNCTION: fn_19736
|
|
CSchedule* CTimeScheduler::FindSchedule(int serial) {
|
|
for (CSchedule* schedule : this->m_schedules) {
|
|
if (schedule->serial == serial) {
|
|
return schedule;
|
|
}
|
|
}
|
|
return nullptr;
|
|
}
|
|
|
|
// OFFSET: 0x00BA94E0
|
|
// FUNCTION: fn_19737
|
|
CSchedule* CTimeScheduler::AddSchedule(CSchedule* schedule) {
|
|
if (schedule == nullptr) {
|
|
return nullptr;
|
|
}
|
|
schedule->timestamp = _Xtime_get_ticks();
|
|
this->m_schedules.push_back(schedule);
|
|
return schedule;
|
|
}
|
|
|
|
// OFFSET: 0x00BA9550
|
|
// FUNCTION: fn_19738
|
|
void CTimeScheduler::Process() {
|
|
if (this->m_unknown_000D) {
|
|
return;
|
|
}
|
|
|
|
auto it = this->m_schedules.begin();
|
|
while (it != this->m_schedules.end()) {
|
|
CSchedule* schedule = *it;
|
|
if (schedule == nullptr) {
|
|
++it;
|
|
continue;
|
|
}
|
|
|
|
if (schedule->active) {
|
|
uint64_t now = _Xtime_get_ticks();
|
|
if (!schedule->unknown_0025) {
|
|
if (schedule->CheckTime(now)) {
|
|
schedule->Process(now);
|
|
}
|
|
}
|
|
++it;
|
|
} else {
|
|
it = this->m_schedules.erase(it);
|
|
delete schedule;
|
|
}
|
|
}
|
|
}
|
|
|
|
// OFFSET: 0x00BA95F0
|
|
// FUNCTION: fn_19739
|
|
void CTimeScheduler::sub_BA95F0(int value) {
|
|
for (CSchedule* schedule : this->m_schedules) {
|
|
if (schedule->unknown_002C == value) {
|
|
schedule->active = false;
|
|
}
|
|
}
|
|
}
|