Function DllReaderClientThread

RedEdr/dllreader.cpp:109–155

Pipe Reader Thread: Process Client

// Pipe Reader Thread: Process Client
void DllReaderClientThread(PipeServer* pipeServer) {
    // Use RAII to ensure cleanup
    std::unique_ptr<PipeServer> server(pipeServer);
    
    if (!server) {
        LOG_A(LOG_ERROR, "DllReaderClientThread: pipeServer is null");
        return;
    }
    
    try {
        // send config as first packet
        //   this is the only write for this pipe
        char config[DLL_CONFIG_LEN];
        int result = sprintf_s(config, DLL_CONFIG_LEN, "callstack: %d; ", g_Config.do_dllinjection_ucallstack ? 1 : 0);
        if (result < 0) {
            LOG_A(LOG_ERROR, "DllReaderClientThread: Failed to format config string");
            return;
        }
        
        if (!server->Send(config)) {
            LOG_A(LOG_ERROR, "DllReaderClientThread: Failed to send config");
            return;
        }

        // Now receive only
        while (WaitForSingleObject(hStopEventDll, 0) != WAIT_OBJECT_0) {
            std::vector<std::string> results = server->ReceiveBatch();
            if (results.empty()) {
                break; // Client disconnected or error
            }
            for (const auto& result : results) {
                if (!result.empty()) {
                    g_EventAggregator.NewEvent(result);
                }
            }
        }
    }
    catch (const std::exception& e) {
        LOG_A(LOG_ERROR, "DllReaderClientThread: Exception in client processing: %s", e.what());
    }
    catch (...) {
        LOG_A(LOG_ERROR, "DllReaderClientThread: Unknown exception in client processing");
    }

    server->Shutdown();
    // server automatically deleted when unique_ptr goes out of scope
}


// Shutdown