rodecomp/Source/Contents/Schedule/TimeScheduler.cpp

#include "Contents/Schedule/TimeScheduler.h"
#include "Contents/ShowRankingScheduler.h"

#include <new>

extern "C" long long _Xtime_get_ticks();

// GLOBAL: gl_24852
CTimeScheduler* g_timeScheduler;

// INLINED
CTimeScheduler::CTimeScheduler() {
  this->m_initialized = this->Init();
  this->m_processingStopped = false;
}

// INLINED
CTimeScheduler::~CTimeScheduler() {
  for (CSchedule* schedule : this->m_schedules) {
    if (schedule != nullptr) {
      delete schedule;
    }
  }
  this->m_schedules.clear();
  this->m_processingStopped = 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 = scheduler;
  if (scheduler == nullptr) {
    return false;
  }
  if (!scheduler->m_initialized) {
    delete scheduler;
    g_timeScheduler = nullptr;
    return false;
  }
  return true;
}

// OFFSET: 0x00BA9340
// FUNCTION: fn_19735
void CTimeScheduler::Destroy() {
  if (g_timeScheduler != nullptr) {
    delete 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: 0x00BA9390
// FUNCTION: fn_45541
CSchedule* CTimeScheduler::FindScheduleByKey(int key) {
  for (CSchedule* schedule : this->m_schedules) {
    if (schedule->userValue == key) {
      return schedule;
    }
  }
  return nullptr;
}

// OFFSET: 0x00BA93C0
// FUNCTION: fn_45542
void CTimeScheduler::RemoveAllSchedules() {
  for (auto it = this->m_schedules.begin(); it != this->m_schedules.end(); ++it) {
    if (*it != nullptr) {
      delete *it;
      *it = nullptr;
    }
  }
  this->m_schedules.clear();
  this->m_processingStopped = false;
}

// OFFSET: 0x00BA9430
// FUNCTION: fn_45540
CSchedule* CTimeScheduler::CreateSchedule(const std::int64_t& interval, int scheduleType) {
  CSchedule* schedule = new CSchedule(_Xtime_get_ticks(), interval, scheduleType, ++g_schedulerSerial, 0);
  if (schedule != nullptr) {
    this->m_schedules.push_back(schedule);
  }
  return schedule;
}

// OFFSET: 0x00BA94E0
// FUNCTION: fn_19737
CSchedule* CTimeScheduler::AddSchedule(CSchedule* schedule) {
  if (schedule != 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_processingStopped) {
    return;
  }

  auto it = this->m_schedules.begin();
  while (it != this->m_schedules.end()) {
    CSchedule* schedule = *it;
    if (schedule != nullptr) {
      if (schedule->active) {
        uint64_t now = _Xtime_get_ticks();
        if (!schedule->pending) {
          if (schedule->CheckTime(now) == true) {
            schedule->Process(now);
          }
        }
      } else {
        it = this->m_schedules.erase(it);
        delete schedule;
        continue;
      }
    }
    ++it;
  }
}

// OFFSET: 0x00BA95F0
// FUNCTION: fn_19739
void CTimeScheduler::RemoveSchedulesByKey(int value) {
  for (CSchedule* schedule : this->m_schedules) {
    if (schedule->userValue == value) {
      schedule->active = false;
    }
  }
}