Function PplReaderShutdown

RedEdr/pplreader.cpp:132–164

Shutdown

// Shutdown
void PplReaderShutdown() {
    LOG_A(LOG_INFO, "PPLReader: Shutdown");

    // Signal stop
    if (hStopEventPpl != NULL) {
        SetEvent(hStopEventPpl);
    }

    // Cancel any blocking I/O (ReceiveBatch or ConnectNamedPipe) on the worker thread
    if (hPplThreadHandle != NULL) {
        CancelSynchronousIo(hPplThreadHandle);
    }

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

    // Close event handles
    if (hStopEventPpl != NULL) {
        CloseHandle(hStopEventPpl);
        hStopEventPpl = NULL;
    }
    if (threadReadynessPpl != NULL) {
        CloseHandle(threadReadynessPpl);
        threadReadynessPpl = NULL;
    }
}