Function KernelReaderProcessingThread

RedEdr/kernelreader.cpp:60–90

DWORD WINAPI KernelReaderProcessingThread(LPVOID param) {
    // Loop which accepts new clients
    while (WaitForSingleObject(hStopEventKernel, 0) != WAIT_OBJECT_0) {
        LOG_A(LOG_DEBUG, "KernelReader: Waiting for kernel");
        kernelPipeServer = new PipeServer("RedEdr KernelReader", (wchar_t*) KERNEL_PIPE_NAME);
        kernelPipeServer->Start(TRUE);
        SetEvent(threadReadynessKernel); // signal the event
        if (!kernelPipeServer->WaitForClient()) {
            LOG_A(LOG_ERROR, "KernelReader: WaitForClient failed");
            kernelPipeServer->Shutdown();
            continue;
        }
		LOG_A(LOG_INFO, "KernelReader: Kernel connected");
        while (WaitForSingleObject(hStopEventKernel, 0) != WAIT_OBJECT_0) {
            std::vector<std::string> events = kernelPipeServer->ReceiveBatch();
            if (events.empty()) {
                break;
            }
            for (const auto& event : events) {
                g_EventAggregator.NewEvent(event);
            }
        }

        kernelPipeServer->Shutdown();
        delete kernelPipeServer;
        kernelPipeServer = NULL;
    }

    LOG_A(LOG_DEBUG, "!Kernel Reader: Thread finished");
    return 0;
}


void KernelReaderShutdown() {