#include #include #include #include #include #include "PS2OS.h" #include "Ps2Const.h" #include "StdStream.h" #include "PtrMacro.h" #include "Utils.h" #include "DMAC.h" #include "INTC.h" #include "SIF.h" #include "ElfFile.h" #include "COP_SCU.h" #include "uint128.h" #include "MIPSAssembler.h" #include "Profiler.h" #include "PathUtils.h" #include "xml/Node.h" #include "xml/Parser.h" #include "xml/FilteringNodeIterator.h" #include "Log.h" #include "iop/IopBios.h" #include "StdStreamUtils.h" // PS2OS Memory Allocation // Start End Description // 0x80000000 0x80000004 Current Thread ID // 0x80008000 0x8000A000 DECI2 Handlers // 0x8000A000 0x8000C000 INTC Handlers // 0x8000C000 0x8000E000 DMAC Handlers // 0x8000E000 0x80010000 Semaphores // 0x80010000 0x80010800 Custom System Call addresses (0x200 entries) // 0x80011000 0x80020000 Threads // 0x80020000 0x80030000 Kernel Stack // 0x80030000 0x80032000 Thread Linked List // BIOS area // Start End Description // 0x1FC00100 0x1FC00200 Custom System Call handling code // 0x1FC00200 0x1FC01000 Interrupt Handler // 0x1FC01000 0x1FC02000 DMAC Interrupt Handler // 0x1FC02000 0x1FC03000 GS Interrupt Handler // 0x1FC03000 0x1FC03100 Thread epilogue // 0x1FC03100 0x1FC03200 Wait Thread Proc #define BIOS_ADDRESS_KERNELSTACK_TOP 0x00030000 #define BIOS_ADDRESS_BASE 0x1FC00000 #define BIOS_ADDRESS_WAITTHREADPROC 0x1FC03100 #define CONFIGPATH "./config/" #define PATCHESFILENAME "patches.xml" #define LOG_NAME ("ps2os") #define THREAD_INIT_QUOTA (15) #define SYSCALL_NAME_LOADEXECPS2 "osLoadExecPS2" #define SYSCALL_NAME_ADDINTCHANDLER "osAddIntcHandler" #define SYSCALL_NAME_ENABLEINTC "osEnableIntc" #define SYSCALL_NAME_DISABLEINTC "osDisableIntc" #define SYSCALL_NAME_ENABLEDMAC "osEnableDmac" #define SYSCALL_NAME_DISABLEDMAC "osDisableDmac" #define SYSCALL_NAME_CREATETHREAD "osCreateThread" #define SYSCALL_NAME_STARTTHREAD "osStartThread" #define SYSCALL_NAME_ICHANGETHREADPRIORITY "osiChangeThreadPriority" #define SYSCALL_NAME_ROTATETHREADREADYQUEUE "osRotateThreadReadyQueue" #define SYSCALL_NAME_GETTHREADID "osGetThreadId" #define SYSCALL_NAME_REFERTHREADSTATUS "osReferThreadStatus" #define SYSCALL_NAME_IREFERTHREADSTATUS "osiReferThreadStatus" #define SYSCALL_NAME_SLEEPTHREAD "osSleepThread" #define SYSCALL_NAME_WAKEUPTHREAD "osWakeupThread" #define SYSCALL_NAME_IWAKEUPTHREAD "osiWakeupThread" #define SYSCALL_NAME_SUSPENDTHREAD "osSuspendThread" #define SYSCALL_NAME_RESUMETHREAD "osResumeThread" #define SYSCALL_NAME_ENDOFHEAP "osEndOfHeap" #define SYSCALL_NAME_CREATESEMA "osCreateSema" #define SYSCALL_NAME_DELETESEMA "osDeleteSema" #define SYSCALL_NAME_SIGNALSEMA "osSignalSema" #define SYSCALL_NAME_ISIGNALSEMA "osiSignalSema" #define SYSCALL_NAME_WAITSEMA "osWaitSema" #define SYSCALL_NAME_POLLSEMA "osPollSema" #define SYSCALL_NAME_REFERSEMASTATUS "osReferSemaStatus" #define SYSCALL_NAME_IREFERSEMASTATUS "osiReferSemaStatus" #define SYSCALL_NAME_FLUSHCACHE "osFlushCache" #define SYSCALL_NAME_GSGETIMR "osGsGetIMR" #define SYSCALL_NAME_GSPUTIMR "osGsPutIMR" #define SYSCALL_NAME_SETVSYNCFLAG "osSetVSyncFlag" #define SYSCALL_NAME_SIFDMASTAT "osSifDmaStat" #define SYSCALL_NAME_SIFSETDMA "osSifSetDma" #define SYSCALL_NAME_SIFSETDCHAIN "osSifSetDChain" #ifdef DEBUGGER_INCLUDED const CPS2OS::SYSCALL_NAME CPS2OS::g_syscallNames[] = { { 0x0006, SYSCALL_NAME_LOADEXECPS2 }, { 0x0010, SYSCALL_NAME_ADDINTCHANDLER }, { 0x0014, SYSCALL_NAME_ENABLEINTC }, { 0x0015, SYSCALL_NAME_DISABLEINTC }, { 0x0016, SYSCALL_NAME_ENABLEDMAC }, { 0x0017, SYSCALL_NAME_DISABLEDMAC }, { 0x0020, SYSCALL_NAME_CREATETHREAD }, { 0x0022, SYSCALL_NAME_STARTTHREAD }, { 0x002A, SYSCALL_NAME_ICHANGETHREADPRIORITY }, { 0x002B, SYSCALL_NAME_ROTATETHREADREADYQUEUE }, { 0x002F, SYSCALL_NAME_GETTHREADID }, { 0x0030, SYSCALL_NAME_REFERTHREADSTATUS }, { 0x0031, SYSCALL_NAME_IREFERTHREADSTATUS }, { 0x0032, SYSCALL_NAME_SLEEPTHREAD }, { 0x0033, SYSCALL_NAME_WAKEUPTHREAD }, { 0x0034, SYSCALL_NAME_IWAKEUPTHREAD }, { 0x0037, SYSCALL_NAME_SUSPENDTHREAD }, { 0x0039, SYSCALL_NAME_RESUMETHREAD }, { 0x003E, SYSCALL_NAME_ENDOFHEAP }, { 0x0040, SYSCALL_NAME_CREATESEMA }, { 0x0041, SYSCALL_NAME_DELETESEMA }, { 0x0042, SYSCALL_NAME_SIGNALSEMA }, { 0x0043, SYSCALL_NAME_ISIGNALSEMA }, { 0x0044, SYSCALL_NAME_WAITSEMA }, { 0x0045, SYSCALL_NAME_POLLSEMA }, { 0x0047, SYSCALL_NAME_REFERSEMASTATUS }, { 0x0048, SYSCALL_NAME_IREFERSEMASTATUS }, { 0x0064, SYSCALL_NAME_FLUSHCACHE }, { 0x0070, SYSCALL_NAME_GSGETIMR }, { 0x0071, SYSCALL_NAME_GSPUTIMR }, { 0x0073, SYSCALL_NAME_SETVSYNCFLAG }, { 0x0076, SYSCALL_NAME_SIFDMASTAT }, { 0x0077, SYSCALL_NAME_SIFSETDMA }, { 0x0078, SYSCALL_NAME_SIFSETDCHAIN }, { 0x0000, NULL } }; #endif namespace filesystem = boost::filesystem; CPS2OS::CPS2OS(CMIPS& ee, uint8* ram, uint8* bios, CGSHandler*& gs, CSIF& sif, CIopBios& iopBios) : m_ee(ee) , m_gs(gs) , m_pELF(NULL) , m_ram(ram) , m_bios(bios) , m_pThreadSchedule(NULL) , m_sif(sif) , m_iopBios(iopBios) { Initialize(); } CPS2OS::~CPS2OS() { Release(); } void CPS2OS::Initialize() { m_pELF = NULL; m_pThreadSchedule = new CRoundRibbon(m_ram + 0x30000, 0x2000); m_semaWaitId = -1; m_semaWaitCount = 0; m_semaWaitCaller = 0; m_semaWaitThreadId = -1; } void CPS2OS::Release() { UnloadExecutable(); DELETEPTR(m_pThreadSchedule); } bool CPS2OS::IsIdle() const { return (GetCurrentThreadId() == m_semaWaitThreadId); } void CPS2OS::DumpIntcHandlers() { printf("INTC Handlers Information\r\n"); printf("-------------------------\r\n"); for(unsigned int i = 0; i < MAX_INTCHANDLER; i++) { INTCHANDLER* pHandler = GetIntcHandler(i + 1); if(pHandler->nValid == 0) continue; printf("ID: %0.2i, Line: %i, Address: 0x%0.8X.\r\n", \ i + 1, pHandler->nCause, pHandler->nAddress); } } void CPS2OS::DumpDmacHandlers() { printf("DMAC Handlers Information\r\n"); printf("-------------------------\r\n"); for(unsigned int i = 0; i < MAX_DMACHANDLER; i++) { DMACHANDLER* pHandler = GetDmacHandler(i + 1); if(pHandler->nValid == 0) continue; printf("ID: %0.2i, Channel: %i, Address: 0x%0.8X.\r\n", \ i + 1, pHandler->nChannel, pHandler->nAddress); } } void CPS2OS::BootFromFile(const char* sPath) { filesystem::path ExecPath(sPath); Framework::CStdStream stream(fopen(ExecPath.string().c_str(), "rb")); LoadELF(stream, ExecPath.filename().string().c_str(), ArgumentList()); } void CPS2OS::BootFromCDROM(const ArgumentList& arguments) { std::string executablePath; Iop::CIoman* ioman = m_iopBios.GetIoman(); { uint32 handle = ioman->Open(Iop::Ioman::CDevice::OPEN_FLAG_RDONLY, "cdrom0:SYSTEM.CNF"); if(static_cast(handle) < 0) { throw std::runtime_error("No 'SYSTEM.CNF' file found on the cdrom0 device."); } { Framework::CStream* file(ioman->GetFileStream(handle)); auto line = Utils::GetLine(file); while(!file->IsEOF()) { auto trimmedEnd = std::remove_if(line.begin(), line.end(), isspace); auto trimmedLine = std::string(line.begin(), trimmedEnd); std::vector components; boost::split(components, trimmedLine, boost::is_any_of("="), boost::algorithm::token_compress_on); if(components.size() >= 2) { if(components[0] == "BOOT2") { executablePath = components[1]; } } line = Utils::GetLine(file); } } ioman->Close(handle); } if(executablePath.length() == 0) { throw std::runtime_error("Error parsing 'SYSTEM.CNF' for a BOOT2 value."); } { uint32 handle = ioman->Open(Iop::Ioman::CDevice::OPEN_FLAG_RDONLY, executablePath.c_str()); if(static_cast(handle) < 0) { throw std::runtime_error("Couldn't open executable specified in SYSTEM.CNF."); } try { const char* executableName = strchr(executablePath.c_str(), ':') + 1; if(executableName[0] == '/' || executableName[0] == '\\') executableName++; Framework::CStream* file(ioman->GetFileStream(handle)); LoadELF(*file, executableName, arguments); } catch(...) { throw std::runtime_error("Error occured while reading ELF executable from disk."); } ioman->Close(handle); } } CELF* CPS2OS::GetELF() { return m_pELF; } const char* CPS2OS::GetExecutableName() const { return m_executableName.c_str(); } std::pair CPS2OS::GetExecutableRange() const { uint32 nMinAddr = 0xFFFFFFF0; uint32 nMaxAddr = 0x00000000; const ELFHEADER& header = m_pELF->GetHeader(); for(unsigned int i = 0; i < header.nProgHeaderCount; i++) { ELFPROGRAMHEADER* p = m_pELF->GetProgram(i); if(p != NULL) { //Wild Arms: Alter Code F has zero sized program headers if(p->nFileSize == 0) continue; uint32 end = p->nVAddress + p->nFileSize; if(end >= PS2::EE_RAM_SIZE) continue; nMinAddr = std::min(nMinAddr, p->nVAddress); nMaxAddr = std::max(nMaxAddr, end); } } return std::pair(nMinAddr, nMaxAddr); } void CPS2OS::LoadELF(Framework::CStream& stream, const char* sExecName, const ArgumentList& arguments) { CELF* pELF(new CElfFile(stream)); const ELFHEADER& header = pELF->GetHeader(); //Check for MIPS CPU if(header.nCPU != 8) { DELETEPTR(pELF); throw std::runtime_error("Invalid target CPU. Must be MIPS."); } if(header.nType != 2) { DELETEPTR(pELF); throw std::runtime_error("Not an executable ELF file."); } UnloadExecutable(); m_pELF = pELF; m_executableName = sExecName; m_currentArguments = arguments; LoadExecutableInternal(); ApplyPatches(); OnExecutableChange(); printf("PS2OS: Loaded '%s' executable file.\r\n", sExecName); } void CPS2OS::LoadExecutableInternal() { //Copy program in main RAM const ELFHEADER& header = m_pELF->GetHeader(); for(unsigned int i = 0; i < header.nProgHeaderCount; i++) { ELFPROGRAMHEADER* p = m_pELF->GetProgram(i); if(p != NULL) { memcpy(m_ram + p->nVAddress, m_pELF->GetContent() + p->nOffset, p->nFileSize); } } m_ee.m_State.nPC = header.nEntryPoint; AssembleCustomSyscallHandler(); AssembleInterruptHandler(); AssembleDmacHandler(); AssembleIntcHandler(); AssembleThreadEpilog(); AssembleWaitThreadProc(); CreateWaitThread(); #ifdef DEBUGGER_INCLUDED std::pair executableRange = GetExecutableRange(); uint32 nMinAddr = executableRange.first; uint32 nMaxAddr = executableRange.second & ~0x03; m_ee.m_pAnalysis->Clear(); m_ee.m_pAnalysis->Analyse(nMinAddr, nMaxAddr, header.nEntryPoint); //Tag system calls for(uint32 address = nMinAddr; address < nMaxAddr; address += 4) { //Check for SYSCALL opcode uint32 opcode = *reinterpret_cast(m_ram + address); if(opcode == 0x0000000C) { //Check the opcode before and after it uint32 addiu = *reinterpret_cast(m_ram + address - 4); uint32 jr = *reinterpret_cast(m_ram + address + 4); if( (jr == 0x03E00008) && (addiu & 0xFFFF0000) == 0x24030000 ) { //We have it! int16 syscallId = static_cast(addiu); if(syscallId & 0x8000) { syscallId = 0 - syscallId; } char syscallName[256]; int syscallNameIndex = -1; for(int i = 0; g_syscallNames[i].name != NULL; i++) { if(g_syscallNames[i].id == syscallId) { syscallNameIndex = i; break; } } if(syscallNameIndex != -1) { strncpy(syscallName, g_syscallNames[syscallNameIndex].name, 256); } else { sprintf(syscallName, "syscall_%0.4X", syscallId); } m_ee.m_Functions.InsertTag(address - 4, syscallName); } } } #endif } void CPS2OS::UnloadExecutable() { if(m_pELF == NULL) return; OnExecutableUnloading(); DELETEPTR(m_pELF); } uint32 CPS2OS::LoadExecutable(const char* path, const char* section) { auto ioman = m_iopBios.GetIoman(); uint32 handle = ioman->Open(Iop::Ioman::CDevice::OPEN_FLAG_RDONLY, path); if(static_cast(handle) < 0) { return -1; } uint32 result = 0; //We don't support loading anything else than all sections assert(strcmp(section, "all") == 0); auto fileStream(ioman->GetFileStream(handle)); //Load all program sections { CElfFile executable(*fileStream); const auto& header = executable.GetHeader(); for(unsigned int i = 0; i < header.nProgHeaderCount; i++) { auto p = executable.GetProgram(i); if(p) { memcpy(m_ram + p->nVAddress, executable.GetContent() + p->nOffset, p->nFileSize); } } result = executable.GetHeader().nEntryPoint; } //Flush all instruction cache OnRequestInstructionCacheFlush(); ioman->Close(handle); return result; } void CPS2OS::ApplyPatches() { auto patchesPath = Framework::PathUtils::GetAppResourcesPath() / PATCHESFILENAME; std::unique_ptr document; try { Framework::CStdStream patchesStream(Framework::CreateInputStdStream(patchesPath.native())); document = std::unique_ptr(Framework::Xml::CParser::ParseDocument(patchesStream)); if(!document) return; } catch(const std::exception& exception) { printf("Failed to open patch definition file: %s.\r\n", exception.what()); return; } auto patchesNode = document->Select("Patches"); if(patchesNode == NULL) { return; } for(Framework::Xml::CFilteringNodeIterator itNode(patchesNode, "Executable"); !itNode.IsEnd(); itNode++) { auto executableNode = (*itNode); const char* sName = executableNode->GetAttribute("Name"); if(sName == NULL) continue; if(!strcmp(sName, GetExecutableName())) { //Found the right executable unsigned int nPatchCount = 0; for(Framework::Xml::CFilteringNodeIterator itNode(executableNode, "Patch"); !itNode.IsEnd(); itNode++) { auto pPatch = (*itNode); const char* sAddress = pPatch->GetAttribute("Address"); const char* sValue = pPatch->GetAttribute("Value"); if(sAddress == NULL) continue; if(sValue == NULL) continue; uint32 nValue = 0, nAddress = 0; if(sscanf(sAddress, "%x", &nAddress) == 0) continue; if(sscanf(sValue, "%x", &nValue) == 0) continue; *(uint32*)&m_ram[nAddress] = nValue; nPatchCount++; } printf("PS2OS: Applied %i patch(es).\r\n", nPatchCount); break; } } } void CPS2OS::AssembleCustomSyscallHandler() { CMIPSAssembler Asm((uint32*)&m_bios[0x100]); //Epilogue Asm.ADDIU(CMIPS::SP, CMIPS::SP, 0xFFF0); Asm.SD(CMIPS::RA, 0x0000, CMIPS::SP); //Load the function address off the table at 0x80010000 Asm.SLL(CMIPS::T0, CMIPS::V1, 2); Asm.LUI(CMIPS::T1, 0x8001); Asm.ADDU(CMIPS::T0, CMIPS::T0, CMIPS::T1); Asm.LW(CMIPS::T0, 0x0000, CMIPS::T0); //And the address with 0x1FFFFFFF Asm.LUI(CMIPS::T1, 0x1FFF); Asm.ORI(CMIPS::T1, CMIPS::T1, 0xFFFF); Asm.AND(CMIPS::T0, CMIPS::T0, CMIPS::T1); //Jump to the system call address Asm.JALR(CMIPS::T0); Asm.NOP(); //Prologue Asm.LD(CMIPS::RA, 0x0000, CMIPS::SP); Asm.ADDIU(CMIPS::SP, CMIPS::SP, 0x0010); Asm.ERET(); } void CPS2OS::AssembleInterruptHandler() { CMIPSAssembler Asm((uint32*)&m_bios[0x200]); const uint32 stackFrameSize = 0x230; //Epilogue (allocate stackFrameSize bytes) Asm.LI(CMIPS::K0, BIOS_ADDRESS_KERNELSTACK_TOP); Asm.ADDIU(CMIPS::K0, CMIPS::K0, 0x10000 - stackFrameSize); //Save context for(unsigned int i = 0; i < 32; i++) { Asm.SQ(i, (i * 0x10), CMIPS::K0); } Asm.MFLO(CMIPS::V0); Asm.MFLO1(CMIPS::V1); Asm.SD(CMIPS::V0, 0x0200, CMIPS::K0); Asm.SD(CMIPS::V1, 0x0208, CMIPS::K0); Asm.MFHI(CMIPS::V0); Asm.MFHI1(CMIPS::V1); Asm.SD(CMIPS::V0, 0x0210, CMIPS::K0); Asm.SD(CMIPS::V1, 0x0218, CMIPS::K0); //Save EPC Asm.MFC0(CMIPS::T0, CCOP_SCU::EPC); Asm.SW(CMIPS::T0, 0x0220, CMIPS::K0); //Set SP Asm.ADDU(CMIPS::SP, CMIPS::K0, CMIPS::R0); //Get INTC status Asm.LUI(CMIPS::T0, 0x1000); Asm.ORI(CMIPS::T0, CMIPS::T0, 0xF000); Asm.LW(CMIPS::S0, 0x0000, CMIPS::T0); //Get INTC mask Asm.LUI(CMIPS::T1, 0x1000); Asm.ORI(CMIPS::T1, CMIPS::T1, 0xF010); Asm.LW(CMIPS::S1, 0x0000, CMIPS::T1); //Get cause Asm.AND(CMIPS::S0, CMIPS::S0, CMIPS::S1); //Clear cause //Asm.SW(CMIPS::S0, 0x0000, CMIPS::T0); Asm.NOP(); static const auto generateIntHandler = [](CMIPSAssembler& assembler, uint32 line) { auto skipIntHandlerLabel = assembler.CreateLabel(); //Check cause assembler.ANDI(CMIPS::T0, CMIPS::S0, (1 << line)); assembler.BEQ(CMIPS::R0, CMIPS::T0, skipIntHandlerLabel); assembler.NOP(); //Process handlers assembler.LUI(CMIPS::T0, 0x1FC0); assembler.ORI(CMIPS::T0, CMIPS::T0, 0x2000); assembler.ADDIU(CMIPS::A0, CMIPS::R0, line); assembler.JALR(CMIPS::T0); assembler.NOP(); assembler.MarkLabel(skipIntHandlerLabel); }; generateIntHandler(Asm, CINTC::INTC_LINE_GS); { auto skipIntHandlerLabel = Asm.CreateLabel(); //Check if INT1 (DMAC) Asm.ANDI(CMIPS::T0, CMIPS::S0, (1 << CINTC::INTC_LINE_DMAC)); Asm.BEQ(CMIPS::R0, CMIPS::T0, skipIntHandlerLabel); Asm.NOP(); //Go to DMAC interrupt handler Asm.LUI(CMIPS::T0, 0x1FC0); Asm.ORI(CMIPS::T0, CMIPS::T0, 0x1000); Asm.JALR(CMIPS::T0); Asm.NOP(); Asm.MarkLabel(skipIntHandlerLabel); } generateIntHandler(Asm, CINTC::INTC_LINE_VBLANK_START); generateIntHandler(Asm, CINTC::INTC_LINE_VBLANK_END); generateIntHandler(Asm, CINTC::INTC_LINE_TIMER0); generateIntHandler(Asm, CINTC::INTC_LINE_TIMER1); generateIntHandler(Asm, CINTC::INTC_LINE_TIMER2); generateIntHandler(Asm, CINTC::INTC_LINE_TIMER3); //Move back SP into K0 before restoring state Asm.ADDIU(CMIPS::K0, CMIPS::SP, CMIPS::R0); //Restore EPC Asm.LW(CMIPS::T0, 0x0220, CMIPS::K0); Asm.MTC0(CMIPS::T0, CCOP_SCU::EPC); //Restore Context Asm.LD(CMIPS::V0, 0x0210, CMIPS::K0); Asm.LD(CMIPS::V1, 0x0218, CMIPS::K0); Asm.MTHI(CMIPS::V0); Asm.MTHI1(CMIPS::V1); Asm.LD(CMIPS::V0, 0x0200, CMIPS::K0); Asm.LD(CMIPS::V1, 0x0208, CMIPS::K0); Asm.MTLO(CMIPS::V0); Asm.MTLO1(CMIPS::V1); for(unsigned int i = 0; i < 32; i++) { Asm.LQ(i, (i * 0x10), CMIPS::K0); } //Prologue Asm.ERET(); } void CPS2OS::AssembleDmacHandler() { CMIPSAssembler Asm((uint32*)&m_bios[0x1000]); auto testHandlerLabel = Asm.CreateLabel(); auto testChannelLabel = Asm.CreateLabel(); auto skipHandlerLabel = Asm.CreateLabel(); auto skipChannelLabel = Asm.CreateLabel(); //Prologue //S0 -> Channel Counter //S1 -> DMA Interrupt Status //S2 -> Handler Counter Asm.ADDIU(CMIPS::SP, CMIPS::SP, 0xFFE0); Asm.SD(CMIPS::RA, 0x0000, CMIPS::SP); Asm.SD(CMIPS::S0, 0x0008, CMIPS::SP); Asm.SD(CMIPS::S1, 0x0010, CMIPS::SP); Asm.SD(CMIPS::S2, 0x0018, CMIPS::SP); //Clear INTC cause Asm.LI(CMIPS::T1, CINTC::INTC_STAT); Asm.ADDIU(CMIPS::T0, CMIPS::R0, (1 << CINTC::INTC_LINE_DMAC)); Asm.SW(CMIPS::T0, 0x0000, CMIPS::T1); //Load the DMA interrupt status Asm.LI(CMIPS::T0, CDMAC::D_STAT); Asm.LW(CMIPS::T0, 0x0000, CMIPS::T0); Asm.SRL(CMIPS::T1, CMIPS::T0, 16); Asm.AND(CMIPS::S1, CMIPS::T0, CMIPS::T1); //Initialize channel counter Asm.ADDIU(CMIPS::S0, CMIPS::R0, 0x0009); Asm.MarkLabel(testChannelLabel); //Check if that specific DMA channel interrupt is the cause Asm.ORI(CMIPS::T0, CMIPS::R0, 0x0001); Asm.SLLV(CMIPS::T0, CMIPS::T0, CMIPS::S0); Asm.AND(CMIPS::T0, CMIPS::T0, CMIPS::S1); Asm.BEQ(CMIPS::T0, CMIPS::R0, skipChannelLabel); Asm.NOP(); //Clear interrupt Asm.LI(CMIPS::T1, CDMAC::D_STAT); Asm.SW(CMIPS::T0, 0x0000, CMIPS::T1); //Initialize DMAC handler loop Asm.ADDU(CMIPS::S2, CMIPS::R0, CMIPS::R0); Asm.MarkLabel(testHandlerLabel); //Get the address to the current DMACHANDLER structure Asm.ADDIU(CMIPS::T0, CMIPS::R0, sizeof(DMACHANDLER)); Asm.MULTU(CMIPS::T0, CMIPS::S2, CMIPS::T0); Asm.LI(CMIPS::T1, 0x8000C000); Asm.ADDU(CMIPS::T0, CMIPS::T0, CMIPS::T1); //Check validity Asm.LW(CMIPS::T1, 0x0000, CMIPS::T0); Asm.BEQ(CMIPS::T1, CMIPS::R0, skipHandlerLabel); Asm.NOP(); //Check if the channel is good one Asm.LW(CMIPS::T1, 0x0004, CMIPS::T0); Asm.BNE(CMIPS::S0, CMIPS::T1, skipHandlerLabel); Asm.NOP(); //Load the necessary stuff Asm.LW(CMIPS::T1, 0x0008, CMIPS::T0); Asm.ADDU(CMIPS::A0, CMIPS::S0, CMIPS::R0); Asm.LW(CMIPS::A1, 0x000C, CMIPS::T0); Asm.LW(CMIPS::GP, 0x0010, CMIPS::T0); //Jump Asm.JALR(CMIPS::T1); Asm.NOP(); Asm.MarkLabel(skipHandlerLabel); //Increment handler counter and test Asm.ADDIU(CMIPS::S2, CMIPS::S2, 0x0001); Asm.ADDIU(CMIPS::T0, CMIPS::R0, MAX_DMACHANDLER - 1); Asm.BNE(CMIPS::S2, CMIPS::T0, testHandlerLabel); Asm.NOP(); Asm.MarkLabel(skipChannelLabel); //Decrement channel counter and test Asm.ADDIU(CMIPS::S0, CMIPS::S0, 0xFFFF); Asm.BGEZ(CMIPS::S0, testChannelLabel); Asm.NOP(); //Epilogue Asm.LD(CMIPS::RA, 0x0000, CMIPS::SP); Asm.LD(CMIPS::S0, 0x0008, CMIPS::SP); Asm.LD(CMIPS::S1, 0x0010, CMIPS::SP); Asm.LD(CMIPS::S2, 0x0018, CMIPS::SP); Asm.ADDIU(CMIPS::SP, CMIPS::SP, 0x20); Asm.JR(CMIPS::RA); Asm.NOP(); } void CPS2OS::AssembleIntcHandler() { CMIPSAssembler assembler(reinterpret_cast(&m_bios[0x2000])); CMIPSAssembler::LABEL checkHandlerLabel = assembler.CreateLabel(); CMIPSAssembler::LABEL moveToNextHandler = assembler.CreateLabel(); //Prologue //S0 -> Handler Counter assembler.ADDIU(CMIPS::SP, CMIPS::SP, 0xFFE0); assembler.SD(CMIPS::RA, 0x0000, CMIPS::SP); assembler.SD(CMIPS::S0, 0x0008, CMIPS::SP); assembler.SD(CMIPS::S1, 0x0010, CMIPS::SP); //Clear INTC cause assembler.LUI(CMIPS::T1, 0x1000); assembler.ORI(CMIPS::T1, CMIPS::T1, 0xF000); assembler.ADDIU(CMIPS::T0, CMIPS::R0, 0x0001); assembler.SLLV(CMIPS::T0, CMIPS::T0, CMIPS::A0); assembler.SW(CMIPS::T0, 0x0000, CMIPS::T1); //Initialize INTC handler loop assembler.ADDU(CMIPS::S0, CMIPS::R0, CMIPS::R0); assembler.ADDU(CMIPS::S1, CMIPS::A0, CMIPS::R0); assembler.MarkLabel(checkHandlerLabel); //Get the address to the current INTCHANDLER structure assembler.ADDIU(CMIPS::T0, CMIPS::R0, sizeof(INTCHANDLER)); assembler.MULTU(CMIPS::T0, CMIPS::S0, CMIPS::T0); assembler.LUI(CMIPS::T1, 0x8000); assembler.ORI(CMIPS::T1, CMIPS::T1, 0xA000); assembler.ADDU(CMIPS::T0, CMIPS::T0, CMIPS::T1); //Check validity assembler.LW(CMIPS::T1, 0x0000, CMIPS::T0); assembler.BEQ(CMIPS::T1, CMIPS::R0, moveToNextHandler); assembler.NOP(); //Check if the cause is good one assembler.LW(CMIPS::T1, 0x0004, CMIPS::T0); assembler.BNE(CMIPS::S1, CMIPS::T1, moveToNextHandler); assembler.NOP(); //Load the necessary stuff assembler.LW(CMIPS::T1, 0x0008, CMIPS::T0); assembler.ADDU(CMIPS::A0, CMIPS::S1, CMIPS::R0); assembler.LW(CMIPS::A1, 0x000C, CMIPS::T0); assembler.LW(CMIPS::GP, 0x0010, CMIPS::T0); //Jump assembler.JALR(CMIPS::T1); assembler.NOP(); assembler.MarkLabel(moveToNextHandler); //Increment handler counter and test assembler.ADDIU(CMIPS::S0, CMIPS::S0, 0x0001); assembler.ADDIU(CMIPS::T0, CMIPS::R0, MAX_INTCHANDLER - 1); assembler.BNE(CMIPS::S0, CMIPS::T0, checkHandlerLabel); assembler.NOP(); //Epilogue assembler.LD(CMIPS::RA, 0x0000, CMIPS::SP); assembler.LD(CMIPS::S0, 0x0008, CMIPS::SP); assembler.LD(CMIPS::S1, 0x0010, CMIPS::SP); assembler.ADDIU(CMIPS::SP, CMIPS::SP, 0x20); assembler.JR(CMIPS::RA); assembler.NOP(); } void CPS2OS::AssembleThreadEpilog() { CMIPSAssembler Asm((uint32*)&m_bios[0x3000]); Asm.ADDIU(CMIPS::V1, CMIPS::R0, 0x23); Asm.SYSCALL(); } void CPS2OS::AssembleWaitThreadProc() { CMIPSAssembler Asm((uint32*)&m_bios[BIOS_ADDRESS_WAITTHREADPROC - BIOS_ADDRESS_BASE]); Asm.ADDIU(CMIPS::V1, CMIPS::R0, 0x666); Asm.SYSCALL(); Asm.BEQ(CMIPS::R0, CMIPS::R0, 0xFFFD); Asm.NOP(); } uint32* CPS2OS::GetCustomSyscallTable() { return (uint32*)&m_ram[0x00010000]; } uint32 CPS2OS::GetCurrentThreadId() const { return *(uint32*)&m_ram[0x00000000]; } void CPS2OS::SetCurrentThreadId(uint32 nThread) { *(uint32*)&m_ram[0x00000000] = nThread; } uint32 CPS2OS::GetNextAvailableThreadId() { for(uint32 i = 0; i < MAX_THREAD; i++) { THREAD* pThread = GetThread(i); if(pThread->nValid != 1) { return i; } } return 0xFFFFFFFF; } CPS2OS::THREAD* CPS2OS::GetThread(uint32 nID) const { return &((THREAD*)&m_ram[0x00011000])[nID]; } void CPS2OS::ThreadShakeAndBake() { //Don't play with fire (don't switch if we're in exception mode) if(m_ee.m_State.nCOP0[CCOP_SCU::STATUS] & CMIPS::STATUS_EXL) { return; } //Don't switch if interrupts are disabled if(!(m_ee.m_State.nCOP0[CCOP_SCU::STATUS] & CMIPS::STATUS_INT)) { return; } //First of all, revoke the current's thread right to execute itself { unsigned int nId = GetCurrentThreadId(); if(nId != 0) { THREAD* pThread = GetThread(nId); pThread->nQuota--; } } //Check if all quotas expired if(ThreadHasAllQuotasExpired()) { CRoundRibbon::ITERATOR itThread(m_pThreadSchedule); //If so, regive a quota to everyone for(itThread = m_pThreadSchedule->Begin(); !itThread.IsEnd(); itThread++) { unsigned int nId = itThread.GetValue(); THREAD* pThread = GetThread(nId); pThread->nQuota = THREAD_INIT_QUOTA; } } //Select thread to execute { unsigned int nId = 0; THREAD* pThread = NULL; CRoundRibbon::ITERATOR itThread(m_pThreadSchedule); //Next, find the next suitable thread to execute for(itThread = m_pThreadSchedule->Begin(); !itThread.IsEnd(); itThread++) { nId = itThread.GetValue(); pThread = GetThread(nId); if(pThread->nStatus != THREAD_RUNNING) continue; //if(pThread->nQuota == 0) continue; break; } if(itThread.IsEnd()) { //Deadlock or something here //printf("%s: Warning, no thread to execute.\r\n", LOG_NAME); nId = 0; } else { //Remove and readd the thread into the queue m_pThreadSchedule->Remove(pThread->nScheduleID); pThread->nScheduleID = m_pThreadSchedule->Insert(nId, pThread->nPriority); } ThreadSwitchContext(nId); } } bool CPS2OS::ThreadHasAllQuotasExpired() { CRoundRibbon::ITERATOR itThread(m_pThreadSchedule); for(itThread = m_pThreadSchedule->Begin(); !itThread.IsEnd(); itThread++) { unsigned int nId = itThread.GetValue(); THREAD* pThread = GetThread(nId); if(pThread->nStatus != THREAD_RUNNING) continue; if(pThread->nQuota == 0) continue; return false; } return true; } void CPS2OS::ThreadSwitchContext(unsigned int nID) { if(nID == GetCurrentThreadId()) return; //Save the context of the current thread { THREAD* pThread = GetThread(GetCurrentThreadId()); THREADCONTEXT* pContext = reinterpret_cast(&m_ram[pThread->nContextPtr]); //Save the context for(uint32 i = 0; i < 0x20; i++) { if(i == CMIPS::R0) continue; if(i == CMIPS::K0) continue; if(i == CMIPS::K1) continue; pContext->nGPR[i] = m_ee.m_State.nGPR[i]; } pContext->nLO.nV[0] = m_ee.m_State.nLO[0]; pContext->nLO.nV[1] = m_ee.m_State.nLO[1]; pContext->nHI.nV[0] = m_ee.m_State.nHI[0]; pContext->nHI.nV[1] = m_ee.m_State.nHI[1]; pContext->nLO.nV[2] = m_ee.m_State.nLO1[0]; pContext->nLO.nV[3] = m_ee.m_State.nLO1[1]; pContext->nHI.nV[2] = m_ee.m_State.nHI1[0]; pContext->nHI.nV[3] = m_ee.m_State.nHI1[1]; pThread->nEPC = m_ee.m_State.nPC; } SetCurrentThreadId(nID); //Load the new context { THREAD* pThread = GetThread(GetCurrentThreadId()); THREADCONTEXT* pContext = reinterpret_cast(&m_ram[pThread->nContextPtr]); m_ee.m_State.nPC = pThread->nEPC; for(uint32 i = 0; i < 0x20; i++) { if(i == CMIPS::R0) continue; if(i == CMIPS::K0) continue; if(i == CMIPS::K1) continue; m_ee.m_State.nGPR[i] = pContext->nGPR[i]; } m_ee.m_State.nLO[0] = pContext->nLO.nV[0]; m_ee.m_State.nLO[1] = pContext->nLO.nV[1]; m_ee.m_State.nHI[0] = pContext->nHI.nV[0]; m_ee.m_State.nHI[1] = pContext->nHI.nV[1]; m_ee.m_State.nLO1[0] = pContext->nLO.nV[2]; m_ee.m_State.nLO1[1] = pContext->nLO.nV[3]; m_ee.m_State.nHI1[0] = pContext->nHI.nV[2]; m_ee.m_State.nHI1[1] = pContext->nHI.nV[3]; } CLog::GetInstance().Print(LOG_NAME, "New thread elected (id = %i).\r\n", nID); } void CPS2OS::CreateWaitThread() { THREAD* pThread = GetThread(0); pThread->nValid = 1; pThread->nEPC = BIOS_ADDRESS_WAITTHREADPROC; pThread->nStatus = THREAD_ZOMBIE; } uint32 CPS2OS::GetNextAvailableSemaphoreId() { for(uint32 i = 1; i < MAX_SEMAPHORE; i++) { SEMAPHORE* pSemaphore = GetSemaphore(i); if(pSemaphore->nValid != 1) { return i; } } return 0xFFFFFFFF; } CPS2OS::SEMAPHORE* CPS2OS::GetSemaphore(uint32 nID) { if(nID == 0) { return NULL; } nID--; return &((SEMAPHORE*)&m_ram[0x0000E000])[nID]; } uint32 CPS2OS::GetNextAvailableDmacHandlerId() { for(uint32 i = 1; i < MAX_DMACHANDLER; i++) { DMACHANDLER* pHandler = GetDmacHandler(i); if(pHandler->nValid != 1) { return i; } } return 0xFFFFFFFF; } CPS2OS::DMACHANDLER* CPS2OS::GetDmacHandler(uint32 nID) { nID--; return &((DMACHANDLER*)&m_ram[0x0000C000])[nID]; } uint32 CPS2OS::GetNextAvailableIntcHandlerId() { for(uint32 i = 1; i < MAX_INTCHANDLER; i++) { INTCHANDLER* pHandler = GetIntcHandler(i); if(pHandler->nValid != 1) { return i; } } return 0xFFFFFFFF; } CPS2OS::INTCHANDLER* CPS2OS::GetIntcHandler(uint32 nID) { nID--; return &((INTCHANDLER*)&m_ram[0x0000A000])[nID]; } uint32 CPS2OS::GetNextAvailableDeci2HandlerId() { for(uint32 i = 1; i < MAX_DECI2HANDLER; i++) { DECI2HANDLER* pHandler = GetDeci2Handler(i); if(pHandler->nValid != 1) { return i; } } return 0xFFFFFFFF; } CPS2OS::DECI2HANDLER* CPS2OS::GetDeci2Handler(uint32 nID) { nID--; return &((DECI2HANDLER*)&m_ram[0x00008000])[nID]; } void CPS2OS::HandleInterrupt() { m_semaWaitCount = 0; m_ee.GenerateInterrupt(0x1FC00200); } void CPS2OS::HandleReturnFromException() { ThreadShakeAndBake(); } uint32 CPS2OS::TranslateAddress(CMIPS* pCtx, uint32 nVAddrLO) { if(nVAddrLO >= 0x70000000 && nVAddrLO <= 0x70003FFF) { return (nVAddrLO - 0x6E000000); } if(nVAddrLO >= 0x30100000 && nVAddrLO <= 0x31FFFFFF) { return (nVAddrLO - 0x30000000); } return nVAddrLO & 0x1FFFFFFF; } ////////////////////////////////////////////////// //System Calls ////////////////////////////////////////////////// void CPS2OS::sc_Unhandled() { printf("PS2OS: Unknown system call (0x%X) called from 0x%0.8X.\r\n", m_ee.m_State.nGPR[3].nV[0], m_ee.m_State.nPC); } //02 void CPS2OS::sc_GsSetCrt() { bool nIsInterlaced = (m_ee.m_State.nGPR[SC_PARAM0].nV[0] != 0); unsigned int nMode = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; bool nIsFrameMode = (m_ee.m_State.nGPR[SC_PARAM2].nV[0] != 0); if(m_gs != NULL) { m_gs->SetCrt(nIsInterlaced, nMode, nIsFrameMode); } } //06 void CPS2OS::sc_LoadExecPS2() { uint32 fileNamePtr = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 argCount = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; uint32 argValuesPtr = m_ee.m_State.nGPR[SC_PARAM2].nV[0]; ArgumentList arguments; for(uint32 i = 0; i < argCount; i++) { uint32 argValuePtr = *reinterpret_cast(m_ram + argValuesPtr + i * 4); arguments.push_back(reinterpret_cast(m_ram + argValuePtr)); } std::string fileName = reinterpret_cast(m_ram + fileNamePtr); OnRequestLoadExecutable(fileName.c_str(), arguments); } //10 void CPS2OS::sc_AddIntcHandler() { uint32 nCause = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nAddress = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; uint32 nNext = m_ee.m_State.nGPR[SC_PARAM2].nV[0]; uint32 nArg = m_ee.m_State.nGPR[SC_PARAM3].nV[0]; /* if(nNext != 0) { assert(0); } */ uint32 nID = GetNextAvailableIntcHandlerId(); if(nID == 0xFFFFFFFF) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } INTCHANDLER* pHandler = GetIntcHandler(nID); pHandler->nValid = 1; pHandler->nAddress = nAddress; pHandler->nCause = nCause; pHandler->nArg = nArg; pHandler->nGP = m_ee.m_State.nGPR[CMIPS::GP].nV[0]; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //11 void CPS2OS::sc_RemoveIntcHandler() { uint32 nCause = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nID = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; INTCHANDLER* pHandler = GetIntcHandler(nID); if(pHandler->nValid != 1) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } pHandler->nValid = 0; m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //12 void CPS2OS::sc_AddDmacHandler() { uint32 nChannel = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nAddress = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; uint32 nNext = m_ee.m_State.nGPR[SC_PARAM2].nV[0]; uint32 nArg = m_ee.m_State.nGPR[SC_PARAM3].nV[0]; //The Next parameter indicates at which moment we'd want our DMAC handler to be called. //-1 -> At the end //0 -> At the start //n -> After handler 'n' if(nNext != 0) { assert(0); } uint32 nID = GetNextAvailableDmacHandlerId(); if(nID == 0xFFFFFFFF) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } DMACHANDLER* pHandler = GetDmacHandler(nID); pHandler->nValid = 1; pHandler->nAddress = nAddress; pHandler->nChannel = nChannel; pHandler->nArg = nArg; pHandler->nGP = m_ee.m_State.nGPR[CMIPS::GP].nV[0]; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //13 void CPS2OS::sc_RemoveDmacHandler() { uint32 nChannel = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nID = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; DMACHANDLER* pHandler = GetDmacHandler(nID); pHandler->nValid = 0x00; m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //14 void CPS2OS::sc_EnableIntc() { uint32 nCause = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nMask = 1 << nCause; if(!(m_ee.m_pMemoryMap->GetWord(CINTC::INTC_MASK) & nMask)) { m_ee.m_pMemoryMap->SetWord(CINTC::INTC_MASK, nMask); } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 1; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //15 void CPS2OS::sc_DisableIntc() { uint32 nCause = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nMask = 1 << nCause; if(m_ee.m_pMemoryMap->GetWord(CINTC::INTC_MASK) & nMask) { m_ee.m_pMemoryMap->SetWord(CINTC::INTC_MASK, nMask); } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 1; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //16 void CPS2OS::sc_EnableDmac() { uint32 nChannel = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nRegister = 0x10000 << nChannel; if(!(m_ee.m_pMemoryMap->GetWord(CDMAC::D_STAT) & nRegister)) { m_ee.m_pMemoryMap->SetWord(CDMAC::D_STAT, nRegister); } //Enable INT1 if(!(m_ee.m_pMemoryMap->GetWord(CINTC::INTC_MASK) & 0x02)) { m_ee.m_pMemoryMap->SetWord(CINTC::INTC_MASK, 0x02); } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 1; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //17 void CPS2OS::sc_DisableDmac() { uint32 nChannel = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nRegister = 0x10000 << nChannel; if(m_ee.m_pMemoryMap->GetWord(CDMAC::D_STAT) & nRegister) { m_ee.m_pMemoryMap->SetWord(CDMAC::D_STAT, nRegister); m_ee.m_State.nGPR[SC_RETURN].nD0 = 1; } else { m_ee.m_State.nGPR[SC_RETURN].nD0 = 0; } } //20 void CPS2OS::sc_CreateThread() { THREADPARAM* pThreadParam = (THREADPARAM*)&m_ram[m_ee.m_State.nGPR[SC_PARAM0].nV[0]]; uint32 nID = GetNextAvailableThreadId(); if(nID == 0xFFFFFFFF) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; return; } THREAD* pThread = GetThread(GetCurrentThreadId()); uint32 nHeapBase = pThread->nHeapBase; assert(pThreadParam->nPriority < 128); pThread = GetThread(nID); pThread->nValid = 1; pThread->nStatus = THREAD_ZOMBIE; pThread->nStackBase = pThreadParam->nStackBase; pThread->nEPC = pThreadParam->nThreadProc; pThread->nPriority = pThreadParam->nPriority; pThread->nHeapBase = nHeapBase; pThread->nWakeUpCount = 0; pThread->nQuota = THREAD_INIT_QUOTA; pThread->nScheduleID = m_pThreadSchedule->Insert(nID, pThreadParam->nPriority); pThread->nStackSize = pThreadParam->nStackSize; uint32 nStackAddr = pThreadParam->nStackBase + pThreadParam->nStackSize - STACKRES; pThread->nContextPtr = nStackAddr; assert(sizeof(THREADCONTEXT) == STACKRES); THREADCONTEXT* pContext = reinterpret_cast(&m_ram[pThread->nContextPtr]); memset(pContext, 0, sizeof(THREADCONTEXT)); pContext->nGPR[CMIPS::SP].nV0 = nStackAddr; pContext->nGPR[CMIPS::FP].nV0 = nStackAddr; pContext->nGPR[CMIPS::GP].nV0 = pThreadParam->nGP; pContext->nGPR[CMIPS::RA].nV0 = 0x1FC03000; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //21 void CPS2OS::sc_DeleteThread() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; THREAD* pThread = GetThread(nID); if(!pThread->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } m_pThreadSchedule->Remove(pThread->nScheduleID); pThread->nValid = 0; m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //22 void CPS2OS::sc_StartThread() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nArg = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; THREAD* pThread = GetThread(nID); if(!pThread->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } assert(pThread->nStatus == THREAD_ZOMBIE); pThread->nStatus = THREAD_RUNNING; THREADCONTEXT* pContext = reinterpret_cast(&m_ram[pThread->nContextPtr]); pContext->nGPR[CMIPS::A0].nV0 = nArg; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //23 void CPS2OS::sc_ExitThread() { THREAD* pThread = GetThread(GetCurrentThreadId()); pThread->nStatus = THREAD_ZOMBIE; ThreadShakeAndBake(); } //25 void CPS2OS::sc_TerminateThread() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; THREAD* pThread = GetThread(nID); if(!pThread->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } pThread->nStatus = THREAD_ZOMBIE; m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //29 //2A void CPS2OS::sc_ChangeThreadPriority() { bool nInt = m_ee.m_State.nGPR[3].nV[0] == 0x2A; uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nPrio = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; THREAD* pThread = GetThread(nID); if(!pThread->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } uint32 nPrevPrio = pThread->nPriority; pThread->nPriority = nPrio; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nPrevPrio; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; //Reschedule? m_pThreadSchedule->Remove(pThread->nScheduleID); pThread->nScheduleID = m_pThreadSchedule->Insert(nID, pThread->nPriority); if(!nInt) { ThreadShakeAndBake(); } } //2B void CPS2OS::sc_RotateThreadReadyQueue() { CRoundRibbon::ITERATOR itThread(m_pThreadSchedule); uint32 nPrio = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; //TODO: Rescheduling isn't always necessary and will cause the current thread's priority queue to be //rotated too since each time a thread is picked to be executed it's placed at the end of the queue... //Find first of this priority and reinsert if it's the same as the current thread //If it's not the same, the schedule will be rotated when another thread is choosen for(itThread = m_pThreadSchedule->Begin(); !itThread.IsEnd(); itThread++) { if(itThread.GetWeight() == nPrio) { uint32 nID = itThread.GetValue(); if(nID == GetCurrentThreadId()) { throw std::runtime_error("Need to reverify that."); THREAD* thread(GetThread(nID)); m_pThreadSchedule->Remove(itThread.GetIndex()); thread->nScheduleID = m_pThreadSchedule->Insert(nID, nPrio); } break; } } m_ee.m_State.nGPR[SC_RETURN].nV[0] = nPrio; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; if(!itThread.IsEnd()) { //Change has been made ThreadShakeAndBake(); } } //2F void CPS2OS::sc_GetThreadId() { m_ee.m_State.nGPR[SC_RETURN].nV[0] = GetCurrentThreadId(); m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //30 void CPS2OS::sc_ReferThreadStatus() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nStatusPtr = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; nStatusPtr &= (PS2::EE_RAM_SIZE - 1); THREAD* pThread = GetThread(nID); if(!pThread->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } //THS_RUN = 0x01, THS_READY = 0x02, THS_WAIT = 0x04, THS_SUSPEND = 0x08, THS_DORMANT = 0x10 uint32 nRet = 0; switch(pThread->nStatus) { case THREAD_RUNNING: nRet = 0x01; break; case THREAD_WAITING: case THREAD_SLEEPING: nRet = 0x04; break; case THREAD_SUSPENDED: nRet = 0x08; break; case THREAD_SUSPENDED_WAITING: case THREAD_SUSPENDED_SLEEPING: nRet = 0x0C; break; case THREAD_ZOMBIE: nRet = 0x10; break; } if(nStatusPtr != 0) { THREADPARAM* pThreadParam = reinterpret_cast(&m_ram[nStatusPtr]); pThreadParam->nStatus = nRet; pThreadParam->nPriority = pThread->nPriority; pThreadParam->nCurrentPriority = pThread->nPriority; pThreadParam->nStackBase = pThread->nStackBase; pThreadParam->nStackSize = pThread->nStackSize; } m_ee.m_State.nGPR[SC_RETURN].nV[0] = nRet; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //32 void CPS2OS::sc_SleepThread() { THREAD* pThread = GetThread(GetCurrentThreadId()); if(pThread->nWakeUpCount == 0) { assert(pThread->nStatus == THREAD_RUNNING); pThread->nStatus = THREAD_SLEEPING; ThreadShakeAndBake(); return; } pThread->nWakeUpCount--; } //33 //34 void CPS2OS::sc_WakeupThread() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; bool nInt = m_ee.m_State.nGPR[3].nV[0] == 0x34; THREAD* pThread = GetThread(nID); if( (pThread->nStatus == THREAD_SLEEPING) || (pThread->nStatus == THREAD_SUSPENDED_SLEEPING)) { switch(pThread->nStatus) { case THREAD_SLEEPING: pThread->nStatus = THREAD_RUNNING; break; case THREAD_SUSPENDED_SLEEPING: pThread->nStatus = THREAD_SUSPENDED; break; default: assert(0); break; } ThreadShakeAndBake(); } else { pThread->nWakeUpCount++; } } //37 void CPS2OS::sc_SuspendThread() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; THREAD* pThread = GetThread(nID); if(!pThread->nValid) { return; } switch(pThread->nStatus) { case THREAD_RUNNING: pThread->nStatus = THREAD_SUSPENDED; break; case THREAD_WAITING: pThread->nStatus = THREAD_SUSPENDED_WAITING; break; case THREAD_SLEEPING: pThread->nStatus = THREAD_SUSPENDED_SLEEPING; break; default: assert(0); break; } ThreadShakeAndBake(); } //39 void CPS2OS::sc_ResumeThread() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; THREAD* pThread = GetThread(nID); if(!pThread->nValid) { return; } switch(pThread->nStatus) { case THREAD_SUSPENDED: pThread->nStatus = THREAD_RUNNING; break; case THREAD_SUSPENDED_WAITING: pThread->nStatus = THREAD_WAITING; break; case THREAD_SUSPENDED_SLEEPING: pThread->nStatus = THREAD_SLEEPING; break; default: assert(0); break; } ThreadShakeAndBake(); } //3C void CPS2OS::sc_SetupThread() { uint32 nStackBase = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; uint32 nStackSize = m_ee.m_State.nGPR[SC_PARAM2].nV[0]; uint32 nStackAddr = 0; if(nStackBase == 0xFFFFFFFF) { nStackAddr = 0x02000000; } else { nStackAddr = nStackBase + nStackSize; } uint32 argsBase = m_ee.m_State.nGPR[SC_PARAM3].nV[0]; //Copy arguments { ArgumentList completeArgList; completeArgList.push_back(m_executableName); completeArgList.insert(completeArgList.end(), m_currentArguments.begin(), m_currentArguments.end()); uint32 argsCount = static_cast(completeArgList.size()); *reinterpret_cast(m_ram + argsBase) = argsCount; uint32 argsPtrs = argsBase + 4; uint32 argsPayload = argsPtrs + (argsCount * 4); for(uint32 i = 0; i < argsCount; i++) { const auto& currentArg = completeArgList[i]; *reinterpret_cast(m_ram + argsPtrs + (i * 4)) = argsPayload; uint32 argSize = static_cast(currentArg.size()) + 1; memcpy(m_ram + argsPayload, currentArg.c_str(), argSize); argsPayload += argSize; } } //Set up the main thread THREAD* pThread = GetThread(1); pThread->nValid = 0x01; pThread->nStatus = THREAD_RUNNING; pThread->nStackBase = nStackAddr - nStackSize; pThread->nPriority = 0; pThread->nQuota = THREAD_INIT_QUOTA; pThread->nScheduleID = m_pThreadSchedule->Insert(1, pThread->nPriority); nStackAddr -= STACKRES; pThread->nContextPtr = nStackAddr; SetCurrentThreadId(1); m_ee.m_State.nGPR[SC_RETURN].nV[0] = nStackAddr; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //3D void CPS2OS::sc_SetupHeap() { THREAD* pThread = GetThread(GetCurrentThreadId()); uint32 nHeapBase = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nHeapSize = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; if(nHeapSize == 0xFFFFFFFF) { pThread->nHeapBase = pThread->nStackBase; } else { pThread->nHeapBase = nHeapBase + nHeapSize; } m_ee.m_State.nGPR[SC_RETURN].nV[0] = pThread->nHeapBase; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //3E void CPS2OS::sc_EndOfHeap() { THREAD* pThread = GetThread(GetCurrentThreadId()); m_ee.m_State.nGPR[SC_RETURN].nV[0] = pThread->nHeapBase; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //40 void CPS2OS::sc_CreateSema() { SEMAPHOREPARAM* pSemaParam = reinterpret_cast(m_ram + m_ee.m_State.nGPR[SC_PARAM0].nV[0]); uint32 nID = GetNextAvailableSemaphoreId(); if(nID == 0xFFFFFFFF) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } SEMAPHORE* pSema = GetSemaphore(nID); pSema->nValid = 1; pSema->nCount = pSemaParam->nInitCount; pSema->nMaxCount = pSemaParam->nMaxCount; pSema->nWaitCount = 0; assert(pSema->nCount <= pSema->nMaxCount); m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //41 void CPS2OS::sc_DeleteSema() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; SEMAPHORE* pSema = GetSemaphore(nID); if(!pSema->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } //Check if any threads are waiting for this? if(pSema->nWaitCount != 0) { assert(0); } pSema->nValid = 0; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //42 //43 void CPS2OS::sc_SignalSema() { bool nInt = m_ee.m_State.nGPR[3].nV[0] == 0x43; uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; SEMAPHORE* pSema = GetSemaphore(nID); if(!pSema || !pSema->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } if(pSema->nWaitCount != 0) { //Unsleep all threads if they were waiting for(uint32 i = 0; i < MAX_THREAD; i++) { THREAD* pThread = GetThread(i); if(!pThread->nValid) continue; if((pThread->nStatus != THREAD_WAITING) && (pThread->nStatus != THREAD_SUSPENDED_WAITING)) continue; if(pThread->nSemaWait != nID) continue; switch(pThread->nStatus) { case THREAD_WAITING: pThread->nStatus = THREAD_RUNNING; break; case THREAD_SUSPENDED_WAITING: pThread->nStatus = THREAD_SUSPENDED; break; default: assert(0); break; } pThread->nQuota = THREAD_INIT_QUOTA; pSema->nWaitCount--; if(pSema->nWaitCount == 0) { break; } } m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; if(!nInt) { ThreadShakeAndBake(); } } else { pSema->nCount++; } m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //44 void CPS2OS::sc_WaitSema() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; SEMAPHORE* pSema = GetSemaphore(nID); if(!pSema || !pSema->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } if((m_semaWaitId == nID) && (m_semaWaitCaller == m_ee.m_State.nGPR[CMIPS::RA].nV0)) { m_semaWaitCount++; if(m_semaWaitCount > 100) { m_semaWaitThreadId = GetCurrentThreadId(); } } else { m_semaWaitId = nID; m_semaWaitCaller = m_ee.m_State.nGPR[CMIPS::RA].nV0; m_semaWaitCount = 0; } if(pSema->nCount == 0) { //Put this thread in sleep mode and reschedule... pSema->nWaitCount++; THREAD* pThread = GetThread(GetCurrentThreadId()); assert(pThread->nStatus == THREAD_RUNNING); pThread->nStatus = THREAD_WAITING; pThread->nSemaWait = nID; ThreadShakeAndBake(); return; } if(pSema->nCount != 0) { pSema->nCount--; } m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //45 void CPS2OS::sc_PollSema() { uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; SEMAPHORE* pSema = GetSemaphore(nID); if(!pSema->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } if(pSema->nCount == 0) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } pSema->nCount--; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //47 //48 void CPS2OS::sc_ReferSemaStatus() { bool isInt = m_ee.m_State.nGPR[3].nV[0] != 0x47; uint32 nID = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; SEMAPHOREPARAM* pSemaParam = (SEMAPHOREPARAM*)(m_ram + (m_ee.m_State.nGPR[SC_PARAM1].nV[0] & 0x1FFFFFFF)); SEMAPHORE* pSema = GetSemaphore(nID); if(!pSema || !pSema->nValid) { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; return; } pSemaParam->nCount = pSema->nCount; pSemaParam->nMaxCount = pSema->nMaxCount; pSemaParam->nWaitThreads = pSema->nWaitCount; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //64 void CPS2OS::sc_FlushCache() { uint32 operationType = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; if(operationType == 2) { //Flush instruction cache OnRequestInstructionCacheFlush(); } } //70 void CPS2OS::sc_GsGetIMR() { uint32 result = 0; if(m_gs != NULL) { result = m_gs->ReadPrivRegister(CGSHandler::GS_IMR); } m_ee.m_State.nGPR[SC_RETURN].nD0 = static_cast(result); } //71 void CPS2OS::sc_GsPutIMR() { uint32 nIMR = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; if(m_gs != NULL) { m_gs->WritePrivRegister(CGSHandler::GS_IMR, nIMR); } } //73 void CPS2OS::sc_SetVSyncFlag() { uint32 nPtr1 = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nPtr2 = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; *(uint32*)&m_ram[nPtr1] = 0x01; if(m_gs != NULL) { //*(uint32*)&m_ram[nPtr2] = 0x2000; *(uint32*)&m_ram[nPtr2] = m_gs->ReadPrivRegister(CGSHandler::GS_CSR) & 0x2000; } else { //Humm... *(uint32*)&m_ram[nPtr2] = 0; } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //74 void CPS2OS::sc_SetSyscall() { uint32 number = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 address = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; if(number < 0x100) { GetCustomSyscallTable()[number] = address; } else if(number == 0x12C) { //This syscall doesn't do any bounds checking and it's possible to //set INTC handler for timer 3 through this system call (a particular version of libcdvd does this) //My guess is that the BIOS doesn't process custom INTC handlers for INT12 (timer 3) and the //only way to have an handler placed on that interrupt line is to do that trick. unsigned int line = 12; uint32 handlerId = GetNextAvailableIntcHandlerId(); if(handlerId == 0xFFFFFFFF) { CLog::GetInstance().Print(LOG_NAME, "Couldn't set INTC handler through SetSyscall"); return; } INTCHANDLER* pHandler = GetIntcHandler(handlerId); pHandler->nValid = 1; pHandler->nAddress = address & 0x1FFFFFFF; pHandler->nCause = line; pHandler->nArg = 0; pHandler->nGP = 0; if(!(m_ee.m_pMemoryMap->GetWord(CINTC::INTC_MASK) & (1 << line))) { m_ee.m_pMemoryMap->SetWord(CINTC::INTC_MASK, (1 << line)); } } else { CLog::GetInstance().Print(LOG_NAME, "Unknown syscall set.", number); } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } //76 void CPS2OS::sc_SifDmaStat() { m_ee.m_State.nGPR[SC_RETURN].nV[0] = 0xFFFFFFFF; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0xFFFFFFFF; } //77 void CPS2OS::sc_SifSetDma() { struct DMAREG { uint32 nSrcAddr; uint32 nDstAddr; uint32 nSize; uint32 nFlags; }; uint32 xferAddress = m_ee.m_State.nGPR[SC_PARAM0].nV[0] & (PS2::EE_RAM_SIZE - 1); DMAREG* pXfer = reinterpret_cast(m_ram + xferAddress); uint32 nCount = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; //Returns count //DMA might call an interrupt handler m_ee.m_State.nGPR[SC_RETURN].nD0 = static_cast(nCount); for(unsigned int i = 0; i < nCount; i++) { uint32 nSize = (pXfer[i].nSize + 0x0F) / 0x10; m_ee.m_pMemoryMap->SetWord(CDMAC::D6_MADR, pXfer[i].nSrcAddr); m_ee.m_pMemoryMap->SetWord(CDMAC::D6_TADR, pXfer[i].nDstAddr); m_ee.m_pMemoryMap->SetWord(CDMAC::D6_QWC, nSize); m_ee.m_pMemoryMap->SetWord(CDMAC::D6_CHCR, 0x00000100); } } //78 void CPS2OS::sc_SifSetDChain() { //Humm, set the SIF0 DMA channel in destination chain mode? //This syscall is invoked by the SIF dma interrupt handler (when a packet has been received) //To make sure every packet generates an interrupt, the SIF will hold into any packet //that it might have in its queue while a packet is being processed. //The MarkPacketProcess function will tell the SIF that the packet has been processed //and that it can continue sending packets over. (Needed for Guilty Gear XX Accent Core Plus) bool isInt = m_ee.m_State.nGPR[3].nV[1] == ~0; if(isInt) { m_sif.MarkPacketProcessed(); } } //79 void CPS2OS::sc_SifSetReg() { uint32 nRegister = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nValue = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; m_sif.SetRegister(nRegister, nValue); m_ee.m_State.nGPR[SC_RETURN].nD0 = 0; } //7A void CPS2OS::sc_SifGetReg() { uint32 nRegister = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; m_ee.m_State.nGPR[SC_RETURN].nD0 = static_cast(m_sif.GetRegister(nRegister)); } //7C void CPS2OS::sc_Deci2Call() { uint32 nFunction = m_ee.m_State.nGPR[SC_PARAM0].nV[0]; uint32 nParam = m_ee.m_State.nGPR[SC_PARAM1].nV[0]; switch(nFunction) { case 0x01: //Deci2Open { uint32 nID = GetNextAvailableDeci2HandlerId(); DECI2HANDLER* pHandler = GetDeci2Handler(nID); pHandler->nValid = 1; pHandler->nDevice = *(uint32*)&m_ram[nParam + 0x00]; pHandler->nBufferAddr = *(uint32*)&m_ram[nParam + 0x04]; m_ee.m_State.nGPR[SC_RETURN].nV[0] = nID; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } break; case 0x03: //Deci2Send { uint32 nID = *reinterpret_cast(&m_ram[nParam + 0x00]); DECI2HANDLER* pHandler = GetDeci2Handler(nID); if(pHandler->nValid != 0) { uint32 stringAddr = *reinterpret_cast(&m_ram[pHandler->nBufferAddr + 0x10]); stringAddr &= (PS2::EE_RAM_SIZE - 1); uint32 nLength = m_ram[stringAddr + 0x00] - 0x0C; uint8* sString = &m_ram[stringAddr + 0x0C]; m_iopBios.GetIoman()->Write(1, nLength, sString); } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 1; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } break; case 0x04: //Deci2Poll { uint32 nID = *reinterpret_cast(&m_ram[nParam + 0x00]); DECI2HANDLER* pHandler = GetDeci2Handler(nID); if(pHandler->nValid != 0) { *(uint32*)&m_ram[pHandler->nBufferAddr + 0x0C] = 0; } m_ee.m_State.nGPR[SC_RETURN].nV[0] = 1; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } break; case 0x10: //kPuts { uint32 stringAddr = *reinterpret_cast(&m_ram[nParam]); uint8* sString = &m_ram[stringAddr]; m_iopBios.GetIoman()->Write(1, static_cast(strlen(reinterpret_cast(sString))), sString); } break; default: CLog::GetInstance().Print(LOG_NAME, "Unknown Deci2Call function (0x%0.8X) called. PC: 0x%0.8X.\r\n", nFunction, m_ee.m_State.nPC); break; } } //7F void CPS2OS::sc_GetMemorySize() { m_ee.m_State.nGPR[SC_RETURN].nV[0] = PS2::EE_RAM_SIZE; m_ee.m_State.nGPR[SC_RETURN].nV[1] = 0; } ////////////////////////////////////////////////// //System Call Handler ////////////////////////////////////////////////// void CPS2OS::HandleSyscall() { #ifdef PROFILE CProfilerZone profilerZone(PROFILE_OTHERZONE); #endif uint32 searchAddress = m_ee.m_State.nCOP0[CCOP_SCU::EPC]; uint32 callInstruction = m_ee.m_pMemoryMap->GetInstruction(searchAddress); if(callInstruction != 0x0000000C) { throw std::runtime_error("Not a SYSCALL."); } uint32 nFunc = m_ee.m_State.nGPR[3].nV[0]; if(nFunc == 0x666) { //Reschedule ThreadShakeAndBake(); } else { if(nFunc & 0x80000000) { nFunc = 0 - nFunc; } //Save for custom handler m_ee.m_State.nGPR[3].nV[0] = nFunc; if(GetCustomSyscallTable()[nFunc] == NULL) { #ifdef _DEBUG DisassembleSysCall(static_cast(nFunc & 0xFF)); #endif if(nFunc < 0x80) { ((this)->*(m_pSysCall[nFunc & 0xFF]))(); } } else { m_ee.GenerateException(0x1FC00100); } } m_ee.m_State.nHasException = 0; } void CPS2OS::DisassembleSysCall(uint8 nFunc) { #ifdef _DEBUG std::string sDescription(GetSysCallDescription(nFunc)); if(sDescription.length() != 0) { CLog::GetInstance().Print(LOG_NAME, "%d: %s\r\n", GetCurrentThreadId(), sDescription.c_str()); } #endif } std::string CPS2OS::GetSysCallDescription(uint8 nFunction) { char sDescription[256]; strcpy(sDescription, ""); switch(nFunction) { case 0x02: sprintf(sDescription, "GsSetCrt(interlace = %i, mode = %i, field = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0], \ m_ee.m_State.nGPR[SC_PARAM2].nV[0]); break; case 0x06: sprintf(sDescription, SYSCALL_NAME_LOADEXECPS2 "(exec = 0x%0.8X, argc = %d, argv = 0x%0.8X);", m_ee.m_State.nGPR[SC_PARAM0].nV[0], m_ee.m_State.nGPR[SC_PARAM1].nV[0], m_ee.m_State.nGPR[SC_PARAM2].nV[0]); break; case 0x10: sprintf(sDescription, SYSCALL_NAME_ADDINTCHANDLER "(cause = %i, address = 0x%0.8X, next = 0x%0.8X, arg = 0x%0.8X);", m_ee.m_State.nGPR[SC_PARAM0].nV[0], m_ee.m_State.nGPR[SC_PARAM1].nV[0], m_ee.m_State.nGPR[SC_PARAM2].nV[0], m_ee.m_State.nGPR[SC_PARAM3].nV[0]); break; case 0x11: sprintf(sDescription, "RemoveIntcHandler(cause = %i, id = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x12: sprintf(sDescription, "AddDmacHandler(channel = %i, address = 0x%0.8X, next = %i, arg = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0], \ m_ee.m_State.nGPR[SC_PARAM2].nV[0], \ m_ee.m_State.nGPR[SC_PARAM3].nV[0]); break; case 0x13: sprintf(sDescription, "RemoveDmacHandler(channel = %i, handler = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x14: sprintf(sDescription, SYSCALL_NAME_ENABLEINTC "(cause = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x15: sprintf(sDescription, SYSCALL_NAME_DISABLEINTC "(cause = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x16: sprintf(sDescription, SYSCALL_NAME_ENABLEDMAC "(channel = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x17: sprintf(sDescription, SYSCALL_NAME_DISABLEDMAC "(channel = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x20: sprintf(sDescription, SYSCALL_NAME_CREATETHREAD "(thread = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x21: sprintf(sDescription, "DeleteThread(id = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x22: sprintf(sDescription, SYSCALL_NAME_STARTTHREAD "(id = 0x%0.8X, a0 = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x23: sprintf(sDescription, "ExitThread();"); break; case 0x25: sprintf(sDescription, "TerminateThread(id = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x29: sprintf(sDescription, "ChangeThreadPriority(id = 0x%0.8X, priority = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x2A: sprintf(sDescription, SYSCALL_NAME_ICHANGETHREADPRIORITY "(id = 0x%0.8X, priority = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x2B: sprintf(sDescription, SYSCALL_NAME_ROTATETHREADREADYQUEUE "(prio = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x2F: sprintf(sDescription, SYSCALL_NAME_GETTHREADID "();"); break; case 0x30: sprintf(sDescription, SYSCALL_NAME_REFERTHREADSTATUS "(threadId = %d, infoPtr = 0x%0.8X);", m_ee.m_State.nGPR[SC_PARAM0].nV[0], m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x31: sprintf(sDescription, SYSCALL_NAME_IREFERTHREADSTATUS "(threadId = %d, infoPtr = 0x%0.8X);", m_ee.m_State.nGPR[SC_PARAM0].nV[0], m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x32: sprintf(sDescription, SYSCALL_NAME_SLEEPTHREAD "();"); break; case 0x33: sprintf(sDescription, SYSCALL_NAME_WAKEUPTHREAD "(id = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x34: sprintf(sDescription, SYSCALL_NAME_IWAKEUPTHREAD "(id = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x37: sprintf(sDescription, SYSCALL_NAME_SUSPENDTHREAD "(id = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x39: sprintf(sDescription, SYSCALL_NAME_RESUMETHREAD "(id = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x3C: sprintf(sDescription, "SetupThread(gp = 0x%0.8X, stack = 0x%0.8X, stack_size = 0x%0.8X, args = 0x%0.8X, root_func = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0], \ m_ee.m_State.nGPR[SC_PARAM2].nV[0], \ m_ee.m_State.nGPR[SC_PARAM3].nV[0], \ m_ee.m_State.nGPR[SC_PARAM4].nV[0]); break; case 0x3D: sprintf(sDescription, "SetupHeap(heap_start = 0x%0.8X, heap_size = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x3E: sprintf(sDescription, SYSCALL_NAME_ENDOFHEAP "();"); break; case 0x40: sprintf(sDescription, SYSCALL_NAME_CREATESEMA "(sema = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x41: sprintf(sDescription, SYSCALL_NAME_DELETESEMA "(semaid = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x42: sprintf(sDescription, SYSCALL_NAME_SIGNALSEMA "(semaid = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x43: sprintf(sDescription, SYSCALL_NAME_ISIGNALSEMA "(semaid = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x44: sprintf(sDescription, SYSCALL_NAME_WAITSEMA "(semaid = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x45: sprintf(sDescription, SYSCALL_NAME_POLLSEMA "(semaid = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x46: sprintf(sDescription, "iPollSema(semaid = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x47: sprintf(sDescription, SYSCALL_NAME_REFERSEMASTATUS "(semaid = %i, status = 0x%0.8X);", m_ee.m_State.nGPR[SC_PARAM0].nV[0], m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x48: sprintf(sDescription, SYSCALL_NAME_IREFERSEMASTATUS "(semaid = %i, status = 0x%0.8X);", m_ee.m_State.nGPR[SC_PARAM0].nV[0], m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x64: case 0x68: #ifdef _DEBUG // sprintf(sDescription, SYSCALL_NAME_FLUSHCACHE "();"); #endif break; case 0x70: sprintf(sDescription, SYSCALL_NAME_GSGETIMR "();"); break; case 0x71: sprintf(sDescription, SYSCALL_NAME_GSPUTIMR "(GS_IMR = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x73: sprintf(sDescription, SYSCALL_NAME_SETVSYNCFLAG "(ptr1 = 0x%0.8X, ptr2 = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x74: sprintf(sDescription, "SetSyscall(num = 0x%0.2X, address = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x76: sprintf(sDescription, SYSCALL_NAME_SIFDMASTAT "();"); break; case 0x77: sprintf(sDescription, SYSCALL_NAME_SIFSETDMA "(list = 0x%0.8X, count = %i);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x78: sprintf(sDescription, SYSCALL_NAME_SIFSETDCHAIN "();"); break; case 0x79: sprintf(sDescription, "SifSetReg(register = 0x%0.8X, value = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x7A: sprintf(sDescription, "SifGetReg(register = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0]); break; case 0x7C: sprintf(sDescription, "Deci2Call(func = 0x%0.8X, param = 0x%0.8X);", \ m_ee.m_State.nGPR[SC_PARAM0].nV[0], \ m_ee.m_State.nGPR[SC_PARAM1].nV[0]); break; case 0x7F: sprintf(sDescription, "GetMemorySize();"); break; } return std::string(sDescription); } ////////////////////////////////////////////////// //System Call Handlers Table ////////////////////////////////////////////////// CPS2OS::SystemCallHandler CPS2OS::m_pSysCall[0x80] = { //0x00 &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_GsSetCrt, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_LoadExecPS2, &CPS2OS::sc_Unhandled, //0x08 &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x10 &CPS2OS::sc_AddIntcHandler, &CPS2OS::sc_RemoveIntcHandler, &CPS2OS::sc_AddDmacHandler, &CPS2OS::sc_RemoveDmacHandler, &CPS2OS::sc_EnableIntc, &CPS2OS::sc_DisableIntc, &CPS2OS::sc_EnableDmac, &CPS2OS::sc_DisableDmac, //0x18 &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x20 &CPS2OS::sc_CreateThread, &CPS2OS::sc_DeleteThread, &CPS2OS::sc_StartThread, &CPS2OS::sc_ExitThread, &CPS2OS::sc_Unhandled, &CPS2OS::sc_TerminateThread,&CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x28 &CPS2OS::sc_Unhandled, &CPS2OS::sc_ChangeThreadPriority, &CPS2OS::sc_ChangeThreadPriority, &CPS2OS::sc_RotateThreadReadyQueue, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_GetThreadId, //0x30 &CPS2OS::sc_ReferThreadStatus, &CPS2OS::sc_ReferThreadStatus, &CPS2OS::sc_SleepThread, &CPS2OS::sc_WakeupThread, &CPS2OS::sc_WakeupThread, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_SuspendThread, //0x38 &CPS2OS::sc_Unhandled, &CPS2OS::sc_ResumeThread, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_SetupThread, &CPS2OS::sc_SetupHeap, &CPS2OS::sc_EndOfHeap, &CPS2OS::sc_Unhandled, //0x40 &CPS2OS::sc_CreateSema, &CPS2OS::sc_DeleteSema, &CPS2OS::sc_SignalSema, &CPS2OS::sc_SignalSema, &CPS2OS::sc_WaitSema, &CPS2OS::sc_PollSema, &CPS2OS::sc_PollSema, &CPS2OS::sc_ReferSemaStatus, //0x48 &CPS2OS::sc_ReferSemaStatus, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x50 &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x58 &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x60 &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_FlushCache, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x68 &CPS2OS::sc_FlushCache, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, //0x70 &CPS2OS::sc_GsGetIMR, &CPS2OS::sc_GsPutIMR, &CPS2OS::sc_Unhandled, &CPS2OS::sc_SetVSyncFlag, &CPS2OS::sc_SetSyscall, &CPS2OS::sc_Unhandled, &CPS2OS::sc_SifDmaStat, &CPS2OS::sc_SifSetDma, //0x78 &CPS2OS::sc_SifSetDChain, &CPS2OS::sc_SifSetReg, &CPS2OS::sc_SifGetReg, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Deci2Call, &CPS2OS::sc_Unhandled, &CPS2OS::sc_Unhandled, &CPS2OS::sc_GetMemorySize, }; ////////////////////////////////////////////////// //Round Ribbon Implementation ////////////////////////////////////////////////// CPS2OS::CRoundRibbon::CRoundRibbon(void* pMemory, uint32 nSize) : m_pNode(reinterpret_cast(pMemory)) , m_nMaxNode(nSize / sizeof(NODE)) { memset(pMemory, 0, nSize); NODE* pHead = GetNode(0); pHead->nIndexNext = -1; pHead->nWeight = -1; pHead->nValid = 1; } CPS2OS::CRoundRibbon::~CRoundRibbon() { } unsigned int CPS2OS::CRoundRibbon::Insert(uint32 nValue, uint32 nWeight) { //Initialize the new node NODE* pNode = AllocateNode(); if(pNode == NULL) return -1; pNode->nWeight = nWeight; pNode->nValue = nValue; //Insert node in list NODE* pNext = GetNode(0); NODE* pPrev = NULL; while(1) { if(pNext == NULL) { //We must insert there... pNode->nIndexNext = pPrev->nIndexNext; pPrev->nIndexNext = GetNodeIndex(pNode); break; } if(pNext->nWeight == -1) { pPrev = pNext; pNext = GetNode(pNext->nIndexNext); continue; } if(pNode->nWeight < pNext->nWeight) { pNext = NULL; continue; } pPrev = pNext; pNext = GetNode(pNext->nIndexNext); } return GetNodeIndex(pNode); } void CPS2OS::CRoundRibbon::Remove(unsigned int nIndex) { if(nIndex == 0) return; NODE* pCurr = GetNode(nIndex); if(pCurr == NULL) return; if(pCurr->nValid != 1) return; NODE* pNode = GetNode(0); while(1) { if(pNode == NULL) break; assert(pNode->nValid); if(pNode->nIndexNext == nIndex) { pNode->nIndexNext = pCurr->nIndexNext; break; } pNode = GetNode(pNode->nIndexNext); } FreeNode(pCurr); } unsigned int CPS2OS::CRoundRibbon::Begin() { return GetNode(0)->nIndexNext; } CPS2OS::CRoundRibbon::NODE* CPS2OS::CRoundRibbon::GetNode(unsigned int nIndex) { if(nIndex >= m_nMaxNode) return NULL; return m_pNode + nIndex; } unsigned int CPS2OS::CRoundRibbon::GetNodeIndex(NODE* pNode) { return (unsigned int)(pNode - m_pNode); } CPS2OS::CRoundRibbon::NODE* CPS2OS::CRoundRibbon::AllocateNode() { for(unsigned int i = 1; i < m_nMaxNode; i++) { NODE* pNode = GetNode(i); if(pNode->nValid == 1) continue; pNode->nValid = 1; return pNode; } return NULL; } void CPS2OS::CRoundRibbon::FreeNode(NODE* pNode) { pNode->nValid = 0; } CPS2OS::CRoundRibbon::ITERATOR::ITERATOR(CRoundRibbon* pRibbon) : m_pRibbon(pRibbon) , m_nIndex(0) { } CPS2OS::CRoundRibbon::ITERATOR& CPS2OS::CRoundRibbon::ITERATOR::operator =(unsigned int nIndex) { m_nIndex = nIndex; return (*this); } CPS2OS::CRoundRibbon::ITERATOR& CPS2OS::CRoundRibbon::ITERATOR::operator ++(int nAmount) { if(!IsEnd()) { NODE* pNode = m_pRibbon->GetNode(m_nIndex); m_nIndex = pNode->nIndexNext; } return (*this); } uint32 CPS2OS::CRoundRibbon::ITERATOR::GetValue() { if(!IsEnd()) { return m_pRibbon->GetNode(m_nIndex)->nValue; } return 0; } uint32 CPS2OS::CRoundRibbon::ITERATOR::GetWeight() { if(!IsEnd()) { return m_pRibbon->GetNode(m_nIndex)->nWeight; } return -1; } unsigned int CPS2OS::CRoundRibbon::ITERATOR::GetIndex() { return m_nIndex; } bool CPS2OS::CRoundRibbon::ITERATOR::IsEnd() { if(m_pRibbon == NULL) return true; return m_pRibbon->GetNode(m_nIndex) == NULL; } ////////////////////////////////////////////////////////////////////////////////////////////////////////// //Debug Stuff #ifdef DEBUGGER_INCLUDED BiosDebugModuleInfoArray CPS2OS::GetModulesDebugInfo() const { BiosDebugModuleInfoArray result; if(m_pELF) { auto executableRange = GetExecutableRange(); BIOS_DEBUG_MODULE_INFO module; module.name = m_executableName; module.begin = executableRange.first; module.end = executableRange.second; module.param = m_pELF; result.push_back(module); } return result; } BiosDebugThreadInfoArray CPS2OS::GetThreadsDebugInfo() const { BiosDebugThreadInfoArray threadInfos; CRoundRibbon::ITERATOR threadIterator(m_pThreadSchedule); for(threadIterator = m_pThreadSchedule->Begin(); !threadIterator.IsEnd(); threadIterator++) { auto thread = GetThread(threadIterator.GetValue()); THREADCONTEXT* threadContext = reinterpret_cast(m_ram + thread->nContextPtr); BIOS_DEBUG_THREAD_INFO threadInfo; threadInfo.id = threadIterator.GetValue(); threadInfo.priority = thread->nPriority; if(GetCurrentThreadId() == threadIterator.GetValue()) { threadInfo.pc = m_ee.m_State.nPC; threadInfo.ra = m_ee.m_State.nGPR[CMIPS::RA].nV0; threadInfo.sp = m_ee.m_State.nGPR[CMIPS::SP].nV0; } else { threadInfo.pc = thread->nEPC; threadInfo.ra = threadContext->nGPR[CMIPS::RA].nV0; threadInfo.sp = threadContext->nGPR[CMIPS::SP].nV0; } switch(thread->nStatus) { case THREAD_RUNNING: threadInfo.stateDescription = "Running"; break; case THREAD_SLEEPING: threadInfo.stateDescription = "Sleeping"; break; case THREAD_WAITING: threadInfo.stateDescription = "Waiting (Semaphore: " + boost::lexical_cast(thread->nSemaWait) + ")"; break; case THREAD_SUSPENDED: threadInfo.stateDescription = "Suspended"; break; case THREAD_SUSPENDED_SLEEPING: threadInfo.stateDescription = "Suspended+Sleeping"; break; case THREAD_SUSPENDED_WAITING: threadInfo.stateDescription = "Suspended+Waiting (Semaphore: " + boost::lexical_cast(thread->nSemaWait) + ")"; break; case THREAD_ZOMBIE: threadInfo.stateDescription = "Zombie"; break; default: threadInfo.stateDescription = "Unknown"; break; } threadInfos.push_back(threadInfo); } return threadInfos; } #endif