Petari/source/Game/System/OSThreadWrapper.cpp

#include "Game/System/OSThreadWrapper.hpp"
#include "JSystem/JKernel/JKRHeap.hpp"

OSThreadWrapper::OSThreadWrapper(u32 a1, int a2, int a3, JKRHeap *pHeap) {
    if (!pHeap) {
        pHeap = JKRHeap::sCurrentHeap;
    }

    initHeapSpecified(pHeap, a1, a3);
    initMessageQueue(_4, a2);
}

OSThreadWrapper::~OSThreadWrapper() {
    if (_4) {
        if (!OSIsThreadTerminated(mThread)) {
            OSDetachThread(mThread);
            OSCancelThread(mThread);
        }

        delete[] _34;
        delete mThread;
    }

    delete[] mMessageArray;
}

void OSThreadWrapper::initMessageQueue(JKRHeap *pHeap, int messageCount) {
    mMessageCount = messageCount;
    mMessageArray = new(pHeap, 0) OSMessage[mMessageCount];
    OSInitMessageQueue(&mQueue, mMessageArray, mMessageCount);
}

/*
void OSThreadWrapper::initHeapSpecified(JKRHeap *pHeap, u32 a2, int priority) {
    _4 = pHeap;
    _38 = a2 & 0xFFFFFFE0;
    _34 = new(pHeap, 32) u8[_38];
    OSThread* thread = new(pHeap, 32) OSThread();
    mThread = thread;
    OSCreateThread(mThread, OSThreadWrapper::start, this, &_34[_38], _38, priority, 1);
}
*/

s32 OSThreadWrapper::start(void * /* unused */) {
    return run();
}

s32 OSThreadWrapper::run() {
    return 0;
}