Function KernelReaderShutdown

RedEdr/kernelreader.cpp:93–127

void KernelReaderShutdown() {
    // Signal stop
    if (hStopEventKernel != NULL) {
        SetEvent(hStopEventKernel);
    }

    // Cancel any pending synchronous I/O in the reader thread.
    // The thread may be blocked in ConnectNamedPipe (WaitForClient) or in
    // ReadFile (ReceiveBatch, which holds pipe_mutex).  CancelSynchronousIo
    // unblocks both cases without trying to acquire the mutex.
    if (hKernelThreadHandle != NULL) {
        CancelSynchronousIo(hKernelThreadHandle);
    }

    // Wait for thread to exit cleanly
    if (hKernelThreadHandle != NULL) {
        if (WaitForSingleObject(hKernelThreadHandle, 5000) == WAIT_TIMEOUT) {
            LOG_A(LOG_WARNING, "KernelReader: Thread did not exit in time, force-terminating");
            TerminateThread(hKernelThreadHandle, 1);
        }
        CloseHandle(hKernelThreadHandle);
        hKernelThreadHandle = NULL;
    }

    // Clean up pipe server if the thread left it behind (e.g. cancelled in WaitForClient path)
    if (kernelPipeServer != NULL) {
        delete kernelPipeServer;
        kernelPipeServer = NULL;
    }

    if (hStopEventKernel != NULL) {
        CloseHandle(hStopEventKernel);
        hStopEventKernel = NULL;
    }
}