Function DllReaderThread

RedEdr/dllreader.cpp:63–105

Pipe Reader Thread: Server

// Pipe Reader Thread: Server
DWORD WINAPI DllReaderThread(LPVOID param) {
    LOG_A(LOG_DEBUG, "!DllReader Thread: begin");

    // Loop which accepts new clients
    while (WaitForSingleObject(hStopEventDll, 0) != WAIT_OBJECT_0) {
        std::unique_ptr<PipeServer> pipeServer = std::make_unique<PipeServer>("DllReader", (wchar_t*) DLL_PIPE_NAME);
        if (!pipeServer) {
            LOG_A(LOG_ERROR, "DllReader: Failed to create PipeServer");
            Sleep(1000); // Brief delay before retry
            continue;
        }
        
        SetEvent(threadReadynessDll);
        
        if (!pipeServer->StartAndWaitForClient(TRUE)) {
            LOG_A(LOG_ERROR, "DllReader: Failed to start pipe server or wait for client");
            pipeServer->Shutdown();
            Sleep(1000); // Brief delay before retry
            continue;
        }

        LOG_A(LOG_INFO, "DllReader: Client connected (handle in new thread)");
        try {
            // Transfer ownership to the thread
            PipeServer* rawPtr = pipeServer.release();
            ConnectedDllReaderThreads.push_back(std::thread(DllReaderClientThread, rawPtr));
        }
        catch (const std::exception& e) {
            LOG_A(LOG_ERROR, "DllReader: Failed to create client thread: %s", e.what());
            pipeServer->Shutdown();
        }
    }
    
    // Wait for all client threads to exit
    for (auto& t : ConnectedDllReaderThreads) {
        if (t.joinable()) {
            t.join();
        }
    }

    LOG_A(LOG_DEBUG, "!DllReader Thread: end");
    return 0;
}


// Pipe Reader Thread: Process Client