1 files changed, 145 insertions, 145 deletions

diff --git a/src/frontend/qt_sdl/Platform.cpp b/src/frontend/qt_sdl/Platform.cpp
index 812c953..f9eaf42 100644
--- a/src/frontend/qt_sdl/Platform.cpp
+++ b/src/frontend/qt_sdl/Platform.cpp
@@ -1,5 +1,5 @@
 /*
-    Copyright 2016-2021 Arisotura
+    Copyright 2016-2022 melonDS team
 
     This file is part of melonDS.
 
@@ -20,28 +20,7 @@
 #include <stdlib.h>
 #include <string.h>
 
-#ifdef __WIN32__
-    #define NTDDI_VERSION        0x06000000 // GROSS FUCKING HACK
-    #include <winsock2.h>
-    #include <windows.h>
-    //#include <knownfolders.h> // FUCK THAT SHIT
-    #include <shlobj.h>
-    #include <ws2tcpip.h>
-    #include <io.h>
-    #define dup _dup
-    #define socket_t    SOCKET
-    #define sockaddr_t  SOCKADDR
-#else
-    #include <unistd.h>
-    #include <netinet/in.h>
-    #include <sys/select.h>
-    #include <sys/socket.h>
-
-    #define socket_t    int
-    #define sockaddr_t  struct sockaddr
-    #define closesocket close
-#endif
-
+#include <string>
 #include <QStandardPaths>
 #include <QString>
 #include <QDir>
@@ -49,31 +28,83 @@
 #include <QSemaphore>
 #include <QMutex>
 #include <QOpenGLContext>
+#include <QSharedMemory>
 
 #include "Platform.h"
 #include "Config.h"
+#include "ROMManager.h"
+#include "CameraManager.h"
 #include "LAN_Socket.h"
 #include "LAN_PCap.h"
-#include <string>
-
-#ifndef INVALID_SOCKET
-    #define INVALID_SOCKET  (socket_t)-1
-#endif
+#include "LocalMP.h"
 
 
 std::string EmuDirectory;
 
+extern CameraManager* camManager[2];
+
 void emuStop();
 
 
 namespace Platform
 {
 
-socket_t MPSocket;
-sockaddr_t MPSendAddr;
-u8 PacketBuffer[2048];
+QSharedMemory* IPCBuffer = nullptr;
+int IPCInstanceID;
+
+void IPCInit()
+{
+    IPCInstanceID = 0;
+
+    IPCBuffer = new QSharedMemory("melonIPC");
+
+    if (!IPCBuffer->attach())
+    {
+        printf("IPC sharedmem doesn't exist. creating\n");
+        if (!IPCBuffer->create(1024))
+        {
+            printf("IPC sharedmem create failed :(\n");
+            delete IPCBuffer;
+            IPCBuffer = nullptr;
+            return;
+        }
+
+        IPCBuffer->lock();
+        memset(IPCBuffer->data(), 0, IPCBuffer->size());
+        IPCBuffer->unlock();
+    }
+
+    IPCBuffer->lock();
+    u8* data = (u8*)IPCBuffer->data();
+    u16 mask = *(u16*)&data[0];
+    for (int i = 0; i < 16; i++)
+    {
+        if (!(mask & (1<<i)))
+        {
+            IPCInstanceID = i;
+            *(u16*)&data[0] |= (1<<i);
+            break;
+        }
+    }
+    IPCBuffer->unlock();
+
+    printf("IPC: instance ID %d\n", IPCInstanceID);
+}
+
+void IPCDeInit()
+{
+    if (IPCBuffer)
+    {
+        IPCBuffer->lock();
+        u8* data = (u8*)IPCBuffer->data();
+        *(u16*)&data[0] &= ~(1<<IPCInstanceID);
+        IPCBuffer->unlock();
 
-#define NIFI_VER 1
+        IPCBuffer->detach();
+        delete IPCBuffer;
+    }
+    IPCBuffer = nullptr;
+}
 
 
 void Init(int argc, char** argv)
@@ -109,10 +140,13 @@ void Init(int argc, char** argv)
     confdir = config.absolutePath() + "/melonDS/";
     EmuDirectory = confdir.toStdString();
 #endif
+
+    IPCInit();
 }
 
 void DeInit()
 {
+    IPCDeInit();
 }
 
 
@@ -122,6 +156,22 @@ void StopEmu()
 }
 
 
+int InstanceID()
+{
+    return IPCInstanceID;
+}
+
+std::string InstanceFileSuffix()
+{
+    int inst = IPCInstanceID;
+    if (inst == 0) return "";
+
+    char suffix[16] = {0};
+    snprintf(suffix, 15, ".%d", inst+1);
+    return suffix;
+}
+
+
 int GetConfigInt(ConfigEntry entry)
 {
     const int imgsizes[] = {0, 256, 512, 1024, 2048, 4096};
@@ -168,7 +218,6 @@ bool GetConfigBool(ConfigEntry entry)
     case DSiSD_ReadOnly: return Config::DSiSDReadOnly != 0;
     case DSiSD_FolderSync: return Config::DSiSDFolderSync != 0;
 
-    case Firm_RandomizeMAC: return Config::RandomizeMAC != 0;
     case Firm_OverrideSettings: return Config::FirmwareOverrideSettings != 0;
     }
 
@@ -207,7 +256,7 @@ bool GetConfigArray(ConfigEntry entry, void* data)
     {
     case Firm_MAC:
         {
-            char* mac_in = Config::FirmwareMAC;
+            std::string& mac_in = Config::FirmwareMAC;
             u8* mac_out = (u8*)data;
 
             int o = 0;
@@ -371,140 +420,80 @@ bool Mutex_TryLock(Mutex* mutex)
     return ((QMutex*) mutex)->try_lock();
 }
 
-
-bool MP_Init()
+void Sleep(u64 usecs)
 {
-    int opt_true = 1;
-    int res;
+    QThread::usleep(usecs);
+}
 
-#ifdef __WIN32__
-    WSADATA wsadata;
-    if (WSAStartup(MAKEWORD(2, 2), &wsadata) != 0)
-    {
-        return false;
-    }
-#endif // __WIN32__
 
-    MPSocket = socket(AF_INET, SOCK_DGRAM, 0);
-    if (MPSocket < 0)
-    {
-        return false;
-    }
-
-    res = setsockopt(MPSocket, SOL_SOCKET, SO_REUSEADDR, (const char*)&opt_true, sizeof(int));
-    if (res < 0)
-    {
-        closesocket(MPSocket);
-        MPSocket = INVALID_SOCKET;
-        return false;
-    }
+void WriteNDSSave(const u8* savedata, u32 savelen, u32 writeoffset, u32 writelen)
+{
+    if (ROMManager::NDSSave)
+        ROMManager::NDSSave->RequestFlush(savedata, savelen, writeoffset, writelen);
+}
 
-    sockaddr_t saddr;
-    saddr.sa_family = AF_INET;
-    *(u32*)&saddr.sa_data[2] = htonl(Config::SocketBindAnyAddr ? INADDR_ANY : INADDR_LOOPBACK);
-    *(u16*)&saddr.sa_data[0] = htons(7064);
-    res = bind(MPSocket, &saddr, sizeof(sockaddr_t));
-    if (res < 0)
-    {
-        closesocket(MPSocket);
-        MPSocket = INVALID_SOCKET;
-        return false;
-    }
+void WriteGBASave(const u8* savedata, u32 savelen, u32 writeoffset, u32 writelen)
+{
+    if (ROMManager::GBASave)
+        ROMManager::GBASave->RequestFlush(savedata, savelen, writeoffset, writelen);
+}
 
-    res = setsockopt(MPSocket, SOL_SOCKET, SO_BROADCAST, (const char*)&opt_true, sizeof(int));
-    if (res < 0)
-    {
-        closesocket(MPSocket);
-        MPSocket = INVALID_SOCKET;
-        return false;
-    }
 
-    MPSendAddr.sa_family = AF_INET;
-    *(u32*)&MPSendAddr.sa_data[2] = htonl(INADDR_BROADCAST);
-    *(u16*)&MPSendAddr.sa_data[0] = htons(7064);
 
-    return true;
+bool MP_Init()
+{
+    return LocalMP::Init();
 }
 
 void MP_DeInit()
 {
-    if (MPSocket >= 0)
-        closesocket(MPSocket);
-
-#ifdef __WIN32__
-    WSACleanup();
-#endif // __WIN32__
+    return LocalMP::DeInit();
 }
 
-int MP_SendPacket(u8* data, int len)
+void MP_Begin()
 {
-    if (MPSocket < 0)
-        return 0;
-
-    if (len > 2048-8)
-    {
-        printf("MP_SendPacket: error: packet too long (%d)\n", len);
-        return 0;
-    }
-
-    *(u32*)&PacketBuffer[0] = htonl(0x4946494E); // NIFI
-    PacketBuffer[4] = NIFI_VER;
-    PacketBuffer[5] = 0;
-    *(u16*)&PacketBuffer[6] = htons(len);
-    memcpy(&PacketBuffer[8], data, len);
-
-    int slen = sendto(MPSocket, (const char*)PacketBuffer, len+8, 0, &MPSendAddr, sizeof(sockaddr_t));
-    if (slen < 8) return 0;
-    return slen - 8;
+    return LocalMP::Begin();
 }
 
-int MP_RecvPacket(u8* data, bool block)
+void MP_End()
 {
-    if (MPSocket < 0)
-        return 0;
-
-    fd_set fd;
-    struct timeval tv;
-
-    FD_ZERO(&fd);
-    FD_SET(MPSocket, &fd);
-    tv.tv_sec = 0;
-    tv.tv_usec = block ? 5000 : 0;
-
-    if (!select(MPSocket+1, &fd, 0, 0, &tv))
-    {
-        return 0;
-    }
+    return LocalMP::End();
+}
 
-    sockaddr_t fromAddr;
-    socklen_t fromLen = sizeof(sockaddr_t);
-    int rlen = recvfrom(MPSocket, (char*)PacketBuffer, 2048, 0, &fromAddr, &fromLen);
-    if (rlen < 8+24)
-    {
-        return 0;
-    }
-    rlen -= 8;
+int MP_SendPacket(u8* data, int len, u64 timestamp)
+{
+    return LocalMP::SendPacket(data, len, timestamp);
+}
 
-    if (ntohl(*(u32*)&PacketBuffer[0]) != 0x4946494E)
-    {
-        return 0;
-    }
+int MP_RecvPacket(u8* data, u64* timestamp)
+{
+    return LocalMP::RecvPacket(data, timestamp);
+}
 
-    if (PacketBuffer[4] != NIFI_VER)
-    {
-        return 0;
-    }
+int MP_SendCmd(u8* data, int len, u64 timestamp)
+{
+    return LocalMP::SendCmd(data, len, timestamp);
+}
 
-    if (ntohs(*(u16*)&PacketBuffer[6]) != rlen)
-    {
-        return 0;
-    }
+int MP_SendReply(u8* data, int len, u64 timestamp, u16 aid)
+{
+    return LocalMP::SendReply(data, len, timestamp, aid);
+}
 
-    memcpy(data, &PacketBuffer[8], rlen);
-    return rlen;
+int MP_SendAck(u8* data, int len, u64 timestamp)
+{
+    return LocalMP::SendAck(data, len, timestamp);
 }
 
+int MP_RecvHostPacket(u8* data, u64* timestamp)
+{
+    return LocalMP::RecvHostPacket(data, timestamp);
+}
 
+u16 MP_RecvReplies(u8* data, u64 timestamp, u16 aidmask)
+{
+    return LocalMP::RecvReplies(data, timestamp, aidmask);
+}
 
 bool LAN_Init()
 {
@@ -549,9 +538,20 @@ int LAN_RecvPacket(u8* data)
         return LAN_Socket::RecvPacket(data);
 }
 
-void Sleep(u64 usecs)
+
+void Camera_Start(int num)
 {
-    QThread::usleep(usecs);
+    return camManager[num]->start();
+}
+
+void Camera_Stop(int num)
+{
+    return camManager[num]->stop();
+}
+
+void Camera_CaptureFrame(int num, u32* frame, int width, int height, bool yuv)
+{
+    return camManager[num]->captureFrame(frame, width, height, yuv);
 }
 
 }