mirror of https://github.com/n64decomp/mk64.git
57 lines
1.8 KiB
C
57 lines
1.8 KiB
C
#include "libultra_internal.h"
|
|
|
|
#define OS_PI_MGR_MESG_BUFF_SIZE 1
|
|
|
|
//! @todo In libreultra this is in an include
|
|
#ifdef VERSION_SH
|
|
extern OSPiHandle* CartRomHandle;
|
|
extern OSPiHandle* LeoDiskHandle;
|
|
#endif
|
|
|
|
OSMgrArgs __osPiDevMgr = { 0 };
|
|
OSPiHandle* __osPiTable = NULL;
|
|
|
|
OSThread piMgrThread;
|
|
u32 piMgrStack[0x400]; // stack bottom
|
|
OSMesgQueue __osPiMesgQueue;
|
|
OSMesg piMgrMesgBuff[OS_PI_MGR_MESG_BUFF_SIZE + 1];
|
|
|
|
extern u32 gOsPiAccessQueueCreated;
|
|
extern OSMesgQueue gOsPiMessageQueue;
|
|
void __osDevMgrMain(void*);
|
|
|
|
void osCreatePiManager(OSPri pri, OSMesgQueue* cmdQ, OSMesg* cmdBuf, s32 cmdMsgCnt) {
|
|
u32 int_disabled;
|
|
OSPri newPri;
|
|
OSPri currentPri;
|
|
|
|
if (!__osPiDevMgr.initialized) {
|
|
osCreateMesgQueue(cmdQ, cmdBuf, cmdMsgCnt);
|
|
osCreateMesgQueue(&__osPiMesgQueue, &piMgrMesgBuff[0], OS_PI_MGR_MESG_BUFF_SIZE);
|
|
if (!gOsPiAccessQueueCreated) {
|
|
__osPiCreateAccessQueue();
|
|
} // what is this constant geez
|
|
osSetEventMesg(OS_EVENT_PI, &__osPiMesgQueue, (void*) 0x22222222);
|
|
newPri = -1;
|
|
currentPri = osGetThreadPri(NULL);
|
|
if (currentPri < pri) {
|
|
newPri = currentPri;
|
|
osSetThreadPri(NULL, pri);
|
|
}
|
|
int_disabled = __osDisableInt();
|
|
__osPiDevMgr.initialized = true;
|
|
__osPiDevMgr.mgrThread = &piMgrThread;
|
|
__osPiDevMgr.cmdQueue = cmdQ;
|
|
__osPiDevMgr.eventQueue = &__osPiMesgQueue;
|
|
__osPiDevMgr.accessQueue = &gOsPiMessageQueue;
|
|
__osPiDevMgr.dma_func = osPiRawStartDma;
|
|
__osPiDevMgr.edma_func = osEPiRawStartDma;
|
|
osCreateThread(&piMgrThread, 0, __osDevMgrMain, (void*) &__osPiDevMgr, &piMgrStack[0x400], pri);
|
|
osStartThread(&piMgrThread);
|
|
__osRestoreInt(int_disabled);
|
|
if (newPri != -1) {
|
|
osSetThreadPri(NULL, newPri);
|
|
}
|
|
}
|
|
}
|