Copy JKernel (#126)

* start JSystem * JKRAram and JUTGamePad * started heap and thread * more JKernel * mostly finished JKernel * delete unused asm * JKRFileFinder * delete unused asm and match findNextFile * format * fix mtx_vec
2026-08-18 12:52:51 -04:00 · 2021-05-03 02:03:24 +02:00
parent 913bb08f51
commit 0b8db42226
360 changed files with 6646 additions and 12699 deletions
@@ -1,6 +1,116 @@
 #ifndef JKRTHREAD_H
 #define JKRTHREAD_H

+#include "JSystem/JKernel/JKRDisposer.h"
+#include "JSystem/JSupport/JSUList.h"
+#include "dolphin/os/OS.h"
 #include "dolphin/types.h"

+class JKRThreadName_;
+class JUTConsole;
+class JKRHeap;
+class JKRThread : JKRDisposer {
+public:
+    JKRThread(u32 stack_size, int message_count, int param_3);
+    JKRThread(JKRHeap* heap, u32 stack_size, int message_count, int param_4);
+    JKRThread(OSThread* thread, int message_count);
+    virtual ~JKRThread();
+
+    /* vt[03] */ virtual void* run();
+
+    void setCommon_mesgQueue(JKRHeap* heap, int message_count);
+    void setCommon_heapSpecified(JKRHeap* heap, u32 stack_size, int param_3);
+
+    OSThread* getThreadRecord() const { return mThreadRecord; }
+    void* getStack() const { return mStackMemory; }
+    u8 getLoadInfo() const { return field_0x60; }
+    JKRHeap* getCurrentHeap() const { return mCurrentHeap; }
+    JKRHeap* getCurrentHeapError() const { return mCurrentHeapError; }
+
+protected:
+    void resume() { OSResumeThread(mThreadRecord); }
+    void sendMessage(OSMessage message) {
+        OSSendMessage(&mMessageQueue, message, OS_MESSAGE_NON_BLOCKING);
+    }
+    void sendMessageBlock(OSMessage message) {
+        OSSendMessage(&mMessageQueue, message, OS_MESSAGE_BLOCKING);
+    }
+    OSMessage waitMessage() {
+        OSMessage message;
+        OSReceiveMessage(&mMessageQueue, &message, OS_MESSAGE_NON_BLOCKING);
+        return message;
+    }
+    OSMessage waitMessageBlock() {
+        OSMessage message;
+        OSReceiveMessage(&mMessageQueue, &message, OS_MESSAGE_BLOCKING);
+        return message;
+    }
+    void jamMessageBlock(OSMessage message) {
+        OSJamMessage(&mMessageQueue, message, OS_MESSAGE_BLOCKING);
+    }
+
+private:
+    /* 0x00 */  // vtable
+    /* 0x04 */  // JKRDisposer
+    /* 0x18 */ JSULink<JKRThread> mThreadListLink;
+    /* 0x28 */ JKRHeap* mHeap;
+    /* 0x2C */ OSThread* mThreadRecord;
+    /* 0x30 */ OSMessageQueue mMessageQueue;
+    /* 0x50 */ OSMessage* mMessages;
+    /* 0x54 */ s32 mMessageCount;
+    /* 0x58 */ void* mStackMemory;
+    /* 0x5C */ u32 mStackSize;
+    /* 0x60 */ u8 field_0x60;
+    /* 0x61 */ u8 padding_0x61[3];
+    /* 0x64 */ u32 mCost;
+    /* 0x68 */ u32 mSwitchCount;
+    /* 0x6C */ u32 field_0x6c;
+    /* 0x70 */ u32 field_0x70;
+    /* 0x74 */ JKRHeap* mCurrentHeap;
+    /* 0x78 */ JKRHeap* mCurrentHeapError;
+
+public:
+    static void* start(void* param_1);
+    static JKRThread* searchThread(OSThread* thread);
+    static JSUList<JKRThread>& getList() { return (JSUList<JKRThread>&)sThreadList; }
+
+    static JSUList<JKRThread> sThreadList;
+    // static u8 sThreadList[12];
+};
+
+class JKRThreadSwitch {
+public:
+    JKRThreadSwitch(JKRHeap*);
+    virtual void draw(JKRThreadName_* param_1, JUTConsole* param_2);
+    virtual void draw(JKRThreadName_* param_1);
+    virtual ~JKRThreadSwitch();
+
+    static JKRThreadSwitch* createManager(JKRHeap* heap);
+
+    JKRThread* enter(JKRThread* param_1, int param_2);
+    static void callback(OSThread* param_1, OSThread* param_2);
+
+    // TODO: fix types
+    static u8 sManager[4];
+    static u8 sTotalCount[4];
+    static u8 sTotalStart[4];
+    static u8 mUserPreCallback[4];
+    static u8 mUserPostCallback[4];
+
+public:
+    JKRHeap* heap;
+    u8 field_0x8[4];
+    u32 field_0xC[2];
+    u8 field_0x14[4];
+    u32 field_0x18;
+    u32 field_0x1C;
+    u32 field_0x20;
+    u32 field_0x24;
+};
+
+struct JKRTask {
+    static JSUList<JKRTask> sTaskList;
+    static u8 sEndMesgQueue[32];
+};
+
 #endif /* JKRTHREAD_H */