Принудительный разрыв именованного канала

#include <iostream>
#include <string>
#include <Windows.h>
#include <process.h>
 
 
 
using namespace std;
 
 
 
// #define ABORT_PIPE
 
 
 
unsigned int _stdcall Client_ThreadProc(void * /* pParam */)
{
    cout << "Client: wait 2 seconds..." << endl;
 
    Sleep(2000);
 
    cout << "Client: opening pipe..." << endl;
 
    HANDLE const hPipe = CreateFileW(L"\\\\.\\pipe\\MyPipe-12345",
        GENERIC_READ | GENERIC_WRITE,
        FILE_SHARE_READ | FILE_SHARE_WRITE,
        NULL,
        OPEN_EXISTING,
        0,
        NULL);
 
    if (INVALID_HANDLE_VALUE == hPipe)
    {
        DWORD const GLE = GetLastError();
        cerr << "Client: CreateFileW failed with last error " << GLE << "." << endl;
        return 0;
    }
 
    cout << "Client: wait 4 seconds..." << endl;
    Sleep(4000);
 
    cout << "Client: writting into pipe..." << endl;
 
    DWORD nBytes;
 
    if (FALSE == WriteFile(hPipe, "Hello", 6, &nBytes, NULL))
    {
        DWORD const GLE = GetLastError();
        cerr << "Client: WriteFile failed with last error " << GLE << "." << endl;
        return 0;
    }
 
    cout << "Client: write completed, exiting..." << endl;
 
    return 0;
}
 
 
 
unsigned int _stdcall Stopper_ThreadProc(void *pParam)
{
    HANDLE const hPipe = (HANDLE const)pParam;
 
    cout << "Stopper: wait 4 seconds..." << endl;
 
    Sleep(4000);
 
    cout << "Stopper: disconnecting pipe..." << endl;
    
    if (FALSE == DisconnectNamedPipe(hPipe))
    {
        DWORD const GLE = GetLastError();
        cerr << "Stopper: DisconnectNamedPipe failed with last error " << GLE << "." << endl;
        return 0;
    }    
 
    cout << "Stopper: exiting..." << endl;
 
    return 0;
}
 
 
 
int main()
{
    cout << "main: creating pipe..." << endl;
 
    HANDLE const hPipe = CreateNamedPipeW(L"\\\\.\\pipe\\MyPipe-12345",
        PIPE_ACCESS_DUPLEX,
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
        PIPE_UNLIMITED_INSTANCES,
        4096, // Output buffer size.
        4096, // Input buffer size.
        NMPWAIT_USE_DEFAULT_WAIT,
        NULL // Security attributes
        );
 
    if (INVALID_HANDLE_VALUE == hPipe)
    {
        DWORD const GLE = GetLastError();
        cerr << "main: CreateNamedPipeW failed with last error " << GLE << "." << endl;
        return 0;
    }
 
    _beginthreadex(NULL, 0, Client_ThreadProc, NULL, 0, NULL);
 
    #ifdef ABORT_PIPE
    _beginthreadex(NULL, 0, Stopper_ThreadProc, hPipe, 0, NULL);
    #endif
 
    if (FALSE == ConnectNamedPipe(hPipe, NULL))
    {
        DWORD const GLE = GetLastError();
        cerr << "main: ConnectNamedPipe failed with last error " << GLE << "." << endl;
        return 0;
    }
 
    cout << "main: client connected..." << endl;
 
    char pBuffer[100];
    DWORD nBytes;
 
    if (FALSE == ReadFile(hPipe, pBuffer, 100, &nBytes, NULL))
    {
        DWORD const GLE = GetLastError();
        cerr << "main: ReadFile failed with last error " << GLE << "." << endl;
        return 0;
    }
 
    cout << "main: read completed [msg = " << pBuffer << "], exiting..." << endl;
 
    if (FALSE == DisconnectNamedPipe(hPipe))
    {
        DWORD const GLE = GetLastError();
        cerr << "main: DisconnectNamedPipe failed with last error " << GLE << "." << endl;
        return 0;
    }
 
    CloseHandle(hPipe);
 
    return 0;
}