Style refactor omni/system components (#974)

* Style refactor omni/system components

* Fix

* Fix
This commit is contained in:
Christian Semmler 2024-05-30 15:03:43 -04:00 committed by GitHub
parent ac41854149
commit 76435d803f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
16 changed files with 106 additions and 84 deletions

View file

@ -259,6 +259,7 @@ add_library(omni STATIC
LEGO1/omni/src/system/mxscheduler.cpp
LEGO1/omni/src/system/mxsemaphore.cpp
LEGO1/omni/src/system/mxthread.cpp
LEGO1/omni/src/system/mxticklethread.cpp
LEGO1/omni/src/video/flic.cpp
LEGO1/omni/src/video/mxbitmap.cpp
LEGO1/omni/src/video/mxdisplaysurface.cpp

View file

@ -11,7 +11,7 @@ class MxAutoLock {
~MxAutoLock();
private:
MxCriticalSection* m_criticalSection;
MxCriticalSection* m_criticalSection; // 0x00
};
#endif // MXAUTOLOCK_H

View file

@ -8,7 +8,9 @@ class MxCriticalSection {
public:
MxCriticalSection();
~MxCriticalSection();
static void SetDoMutex();
void Enter();
void Leave();

View file

@ -6,6 +6,7 @@
class MxScheduler {
public:
static MxScheduler* GetInstance();
void StartMultiTasking(MxULong);
};

View file

@ -1,5 +1,5 @@
#ifndef MX_SEMAPHORE_H
#define MX_SEMAPHORE_H
#ifndef MXSEMAPHORE_H
#define MXSEMAPHORE_H
#include "mxtypes.h"
@ -23,4 +23,4 @@ class MxSemaphore {
HANDLE m_hSemaphore; // 0x04
};
#endif // MX_SEMAPHORE_H
#endif // MXSEMAPHORE_H

View file

@ -42,19 +42,4 @@ class MxThread {
MxCore* m_target; // 0x18
};
// VTABLE: LEGO1 0x100dc6d8
// SIZE 0x20
class MxTickleThread : public MxThread {
public:
MxTickleThread(MxCore* p_target, MxS32 p_frequencyMS);
MxResult Run() override;
// SYNTHETIC: LEGO1 0x100b8c20
// MxTickleThread::`scalar deleting destructor'
private:
MxS32 m_frequencyMS; // 0x1c
};
#endif // MXTHREAD_H

View file

@ -0,0 +1,21 @@
#ifndef MXTICKLETHREAD_H
#define MXTICKLETHREAD_H
#include "mxthread.h"
// VTABLE: LEGO1 0x100dc6d8
// SIZE 0x20
class MxTickleThread : public MxThread {
public:
MxTickleThread(MxCore* p_target, MxS32 p_frequencyMS);
MxResult Run() override;
// SYNTHETIC: LEGO1 0x100b8c20
// MxTickleThread::`scalar deleting destructor'
private:
MxS32 m_frequencyMS; // 0x1c
};
#endif // MXTICKLETHREAD_H

View file

@ -1,8 +1,8 @@
#include "mxmusicmanager.h"
#include "mxmisc.h"
#include "mxthread.h"
#include "mxticklemanager.h"
#include "mxticklethread.h"
#include <windows.h>

View file

@ -5,8 +5,8 @@
#include "mxmisc.h"
#include "mxomni.h"
#include "mxpresenter.h"
#include "mxthread.h"
#include "mxticklemanager.h"
#include "mxticklethread.h"
#include "mxwavepresenter.h"
DECOMP_SIZE_ASSERT(MxSoundManager, 0x3c);

View file

@ -2,8 +2,8 @@
#include "mxcriticalsection.h"
#include "mxmisc.h"
#include "mxthread.h"
#include "mxticklemanager.h"
#include "mxticklethread.h"
// FUNCTION: LEGO1 0x100c0360
MxEventManager::MxEventManager()

View file

@ -5,16 +5,17 @@
// FUNCTION: LEGO1 0x100b8ed0
MxAutoLock::MxAutoLock(MxCriticalSection* p_criticalSection)
{
this->m_criticalSection = p_criticalSection;
if (this->m_criticalSection != 0) {
this->m_criticalSection->Enter();
m_criticalSection = p_criticalSection;
if (m_criticalSection != NULL) {
m_criticalSection->Enter();
}
}
// FUNCTION: LEGO1 0x100b8ef0
MxAutoLock::~MxAutoLock()
{
if (this->m_criticalSection != 0) {
this->m_criticalSection->Leave();
if (m_criticalSection != NULL) {
m_criticalSection->Leave();
}
}

View file

@ -4,35 +4,35 @@
#include <stdio.h>
DECOMP_SIZE_ASSERT(MxCriticalSection, 0x1c);
DECOMP_SIZE_ASSERT(MxCriticalSection, 0x1c)
// GLOBAL: LEGO1 0x10101e78
int g_useMutex = 0;
BOOL g_useMutex = FALSE;
// FUNCTION: LEGO1 0x100b6d20
MxCriticalSection::MxCriticalSection()
{
HANDLE mutex;
if (g_useMutex != 0) {
if (g_useMutex) {
mutex = CreateMutexA(NULL, FALSE, NULL);
this->m_mutex = mutex;
return;
m_mutex = mutex;
}
else {
InitializeCriticalSection(&m_criticalSection);
m_mutex = NULL;
}
InitializeCriticalSection(&this->m_criticalSection);
this->m_mutex = NULL;
}
// FUNCTION: LEGO1 0x100b6d60
MxCriticalSection::~MxCriticalSection()
{
if (this->m_mutex != NULL) {
CloseHandle(this->m_mutex);
return;
if (m_mutex != NULL) {
CloseHandle(m_mutex);
}
else {
DeleteCriticalSection(&m_criticalSection);
}
DeleteCriticalSection(&this->m_criticalSection);
}
// FUNCTION: LEGO1 0x100b6d80
@ -41,8 +41,8 @@ void MxCriticalSection::Enter()
DWORD result;
FILE* file;
if (this->m_mutex != NULL) {
result = WaitForSingleObject(this->m_mutex, 5000);
if (m_mutex != NULL) {
result = WaitForSingleObject(m_mutex, 5000);
if (result == WAIT_FAILED) {
file = fopen("C:\\DEADLOCK.TXT", "a");
if (file != NULL) {
@ -54,23 +54,23 @@ void MxCriticalSection::Enter()
}
}
else {
EnterCriticalSection(&this->m_criticalSection);
EnterCriticalSection(&m_criticalSection);
}
}
// FUNCTION: LEGO1 0x100b6de0
void MxCriticalSection::Leave()
{
if (this->m_mutex != NULL) {
ReleaseMutex(this->m_mutex);
return;
if (m_mutex != NULL) {
ReleaseMutex(m_mutex);
}
else {
LeaveCriticalSection(&m_criticalSection);
}
LeaveCriticalSection(&this->m_criticalSection);
}
// FUNCTION: LEGO1 0x100b6e00
void MxCriticalSection::SetDoMutex()
{
g_useMutex = 1;
g_useMutex = TRUE;
}

View file

@ -15,9 +15,11 @@ MxSemaphore::MxSemaphore()
MxResult MxSemaphore::Init(MxU32 p_initialCount, MxU32 p_maxCount)
{
MxResult result = FAILURE;
if ((m_hSemaphore = CreateSemaphoreA(NULL, p_initialCount, p_maxCount, NULL))) {
result = SUCCESS;
}
return result;
}

View file

@ -1,44 +1,10 @@
#include "mxthread.h"
#include "decomp.h"
#include "mxmisc.h"
#include "mxtimer.h"
#include <process.h>
DECOMP_SIZE_ASSERT(MxThread, 0x1c)
DECOMP_SIZE_ASSERT(MxTickleThread, 0x20)
// FUNCTION: LEGO1 0x100b8bb0
MxTickleThread::MxTickleThread(MxCore* p_target, MxS32 p_frequencyMS)
{
m_target = p_target;
m_frequencyMS = p_frequencyMS;
}
// Match except for register allocation
// FUNCTION: LEGO1 0x100b8c90
MxResult MxTickleThread::Run()
{
MxTimer* timer = Timer();
MxS32 lastTickled = -m_frequencyMS;
while (IsRunning()) {
MxLong currentTime = timer->GetTime();
if (currentTime < lastTickled) {
lastTickled = -m_frequencyMS;
}
MxS32 timeRemainingMS = (m_frequencyMS - currentTime) + lastTickled;
if (timeRemainingMS <= 0) {
m_target->Tickle();
timeRemainingMS = 0;
lastTickled = currentTime;
}
Sleep(timeRemainingMS);
}
return MxThread::Run();
}
// FUNCTION: LEGO1 0x100bf510
MxThread::MxThread()
@ -62,12 +28,14 @@ typedef unsigned(__stdcall* ThreadFunc)(void*);
MxResult MxThread::Start(MxS32 p_stack, MxS32 p_flag)
{
MxResult result = FAILURE;
if (m_semaphore.Init(0, 1) == SUCCESS) {
if ((m_hThread =
_beginthreadex(NULL, p_stack << 2, (ThreadFunc) &MxThread::ThreadProc, this, p_flag, &m_threadId))) {
result = SUCCESS;
}
}
return result;
}

View file

@ -0,0 +1,41 @@
#include "mxticklethread.h"
#include "decomp.h"
#include "mxmisc.h"
#include "mxtimer.h"
DECOMP_SIZE_ASSERT(MxTickleThread, 0x20)
// FUNCTION: LEGO1 0x100b8bb0
MxTickleThread::MxTickleThread(MxCore* p_target, MxS32 p_frequencyMS)
{
m_target = p_target;
m_frequencyMS = p_frequencyMS;
}
// Match except for register allocation
// FUNCTION: LEGO1 0x100b8c90
MxResult MxTickleThread::Run()
{
MxTimer* timer = Timer();
MxS32 lastTickled = -m_frequencyMS;
while (IsRunning()) {
MxLong currentTime = timer->GetTime();
if (currentTime < lastTickled) {
lastTickled = -m_frequencyMS;
}
MxS32 timeRemainingMS = (m_frequencyMS - currentTime) + lastTickled;
if (timeRemainingMS <= 0) {
m_target->Tickle();
timeRemainingMS = 0;
lastTickled = currentTime;
}
Sleep(timeRemainingMS);
}
return MxThread::Run();
}

View file

@ -7,8 +7,8 @@
#include "mxpalette.h"
#include "mxpresenter.h"
#include "mxregion.h"
#include "mxthread.h"
#include "mxticklemanager.h"
#include "mxticklethread.h"
DECOMP_SIZE_ASSERT(MxVideoManager, 0x64)