Misc Egg (#37)

* EGG: Archive, DvdFile, DvdRipper

* start eggStream

* FrmHeap and AssertHeap OK

* progress on EggController

* port in WPAD stuff

* update WPAD/WUD/KPAD/SC symbols

* eggController OK

* bytematch more CoreController virtual funcs

* eggDecomp/eggStreamDecomp Ok

* eggDvdRipper OK

* EGG gfx splits

* Finished Splitting EGG

* create egg Files

* eggDecomp.h -> eggStreamDecomp.h

* Revert some format changes

1 files changed, 101 insertions, 0 deletions

diff --git a/src/egg/core/eggDvdFile.cpp b/src/egg/core/eggDvdFile.cpp
new file mode 100644
index 00000000..d067fdce
--- /dev/null
+++ b/src/egg/core/eggDvdFile.cpp
@@ -0,0 +1,101 @@
+#include <egg/core/eggDvdFile.h>
+
+namespace EGG {
+
+bool DvdFile::sIsInitialized;
+nw4r::ut::List DvdFile::sDvdList;
+
+void DvdFile::initialize() {
+    if (!sIsInitialized) {
+        nw4r::ut::List_Init(&sDvdList, offsetof(DvdFile, mNode));
+        sIsInitialized = true;
+    }
+}
+
+DvdFile::DvdFile() {
+    initiate();
+}
+
+DvdFile::~DvdFile() {
+    close();
+}
+
+void DvdFile::initiate() {
+    mFileInfo.dvdFile = this;
+    OSInitMutex(&mMutex);
+    OSInitMutex(&mMutexUnused);
+    OSInitMessageQueue(&mMsgQueue, &mMsg, 1);
+    OSInitMessageQueue(&mMsgQueueUnsued, &mMsgUnused, 1);
+    mThread = nullptr;
+    field_0x38 = 0;
+}
+
+bool DvdFile::open(s32 entryId) {
+    if (!mIsOpen && entryId != -1) {
+        s32 res = DVDFastOpen(entryId, &mFileInfo);
+        mIsOpen = res;
+        if (mIsOpen) {
+            nw4r::ut::List_Append(&sDvdList, this);
+            s32 _status = DVDGetCommandBlockStatus(&mFileInfo.block);
+        }
+    }
+    return mIsOpen;
+}
+
+bool DvdFile::open(const char *path) {
+    return open(DVDConvertPathToEntrynum(path));
+}
+
+bool DvdFile::open(const char *path, void *) {
+    return open(path);
+}
+
+void DvdFile::close() {
+    if (mIsOpen && DVDClose(&mFileInfo)) {
+        mIsOpen = false;
+        nw4r::ut::List_Remove(&sDvdList, this);
+    }
+}
+
+s32 DvdFile::readData(void *buffer, s32 length, s32 offset) {
+    OSLockMutex(&mMutex);
+    if (mThread) {
+        OSUnlockMutex(&mMutex);
+        return -1;
+    }
+
+    mThread = OSGetCurrentThread();
+    s32 res = -1;
+
+    if (DVDReadAsyncPrio(&mFileInfo, buffer, length, offset, doneProcess, DVD_PRIO_MEDIUM)) {
+        res = sync();
+    }
+
+    mThread = nullptr;
+    OSUnlockMutex(&mMutex);
+
+    return res;
+}
+
+s32 DvdFile::writeData(const void *buffer, s32 length, s32 offset) {
+    return -1;
+}
+
+s32 DvdFile::sync() {
+    OSMessage msg;
+    OSLockMutex(&mMutex);
+    OSReceiveMessage(&mMsgQueue, &msg, OS_MSG_PERSISTENT);
+    mThread = nullptr;
+    OSUnlockMutex(&mMutex);
+    return (s32)(msg);
+}
+
+void DvdFile::doneProcess(s32 result, DVDFileInfo *pFileInfo) {
+    OSSendMessage(&((FileInfo *)pFileInfo)->dvdFile->mMsgQueue, (OSMessage)result, 0);
+}
+
+u32 DvdFile::getFileSize() const {
+    return mFileInfo.size;
+}
+
+} // namespace EGG