Fennix/Kernel
1
0
Fork 0
mirror of https://github.com/Fennix-Project/Kernel.git synced 2025-05-30 00:08:03 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add InterpreterIPCData

Browse Source
This commit is contained in:
Alex 2023-03-20 04:42:10 +02:00
parent 82911c8559
commit 6492da3237
Signed by untrusted user who does not match committer: enderice2
GPG Key ID: EACC3AD603BAB4DD
1 changed files with 34 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
Execute/Elf/BaseLoad.cpp
View File

@ -17,6 +17,18 @@ using VirtualFileSystem::NodeFlags;
namespace Execute namespace Execute
{ {
struct InterpreterIPCDataLibrary
{
char Name[128];
};
typedef struct
{
char Path[256];
void *MemoryImage;
struct InterpreterIPCDataLibrary Libraries[256];
} InterpreterIPCData;
/* Passing arguments as a sanity check and debugging. */ /* Passing arguments as a sanity check and debugging. */
void ELFInterpreterIPCThread(PCB *Process, char *Path, void *MemoryImage, Vector<String> NeededLibraries) void ELFInterpreterIPCThread(PCB *Process, char *Path, void *MemoryImage, Vector<String> NeededLibraries)
{ {
@ -35,11 +47,18 @@ namespace Execute
debug("Retrying..."); debug("Retrying...");
} }
debug("IPC found, sending data..."); debug("IPC found, sending data...");
InterpreterIPCData *TmpBuffer = new InterpreterIPCData;
strcpy(TmpBuffer->Path, Path);
TmpBuffer->MemoryImage = MemoryImage;
if (NeededLibraries.size() > 256)
warn("Too many libraries! (max 256)");
for (size_t i = 0; i < NeededLibraries.size(); i++)
{
strcpy(TmpBuffer->Libraries[i].Name, NeededLibraries[i].c_str());
}
int NotFoundRetry = 0;
RetryIPCWrite: RetryIPCWrite:
uintptr_t *TmpBuffer = new uintptr_t[0x1000]; InterProcessCommunication::IPCErrorCode ret = Process->IPC->Write(Handle->ID, TmpBuffer, sizeof(InterpreterIPCData));
*(int *)TmpBuffer = 2545;
InterProcessCommunication::IPCErrorCode ret = Process->IPC->Write(Handle->ID, TmpBuffer, 0x1000);
delete[] TmpBuffer, TmpBuffer = nullptr;
debug("Write returned %d", ret); debug("Write returned %d", ret);
if (ret == InterProcessCommunication::IPCErrorCode::IPCNotListening) if (ret == InterProcessCommunication::IPCErrorCode::IPCNotListening)
{ {
@ -47,6 +66,17 @@ namespace Execute
TaskManager->Sleep(100); TaskManager->Sleep(100);
goto RetryIPCWrite; goto RetryIPCWrite;
} }
else if (ret == InterProcessCommunication::IPCErrorCode::IPCIDNotFound)
{
if (NotFoundRetry < 100)
{
debug("IPC not found, retrying...");
TaskManager->Sleep(1000);
NotFoundRetry++;
goto RetryIPCWrite;
}
}
delete TmpBuffer;
CPU::Halt(true); CPU::Halt(true);
} }