プロセス間通信をしてみた(2)
Windows10の名前付きパイプでの通信の続き

typedef struct _PIPE_HANDLES {
    HANDLE  hPipe;
    HANDLE  hEvent;
} PIPE_HANDLES, * PPIPE_HANDLES;

DWORD   WINAPI  ServerThreadProc(LPVOID threadParam);

int main()
{
    //
    //...(省略)...
    //
    int recvCount = 0;
    do {
        pipeHandles.hPipe = INVALID_HANDLE_VALUE;
        pipeHandles.hPipe = CreateNamedPipe(_T("\\\\.\\pipe\\sample_pipe"),
            PIPE_ACCESS_INBOUND,
            PIPE_TYPE_BYTE | PIPE_WAIT,
            1,
            0,
            0,
            100,
            NULL);
        if (INVALID_HANDLE_VALUE == pipeHandles.hPipe) {
            _tprintf(_T("The pipe can not open.\r\n"));
        }
        else {
            _tprintf(_T("The pipe can open.\r\n"));
        }

        pipeHandles.hEvent = CreateEvent(NULL, FALSE, FALSE, _T("IPC_SAMPLE"));
        WaitForSingleObject(pipeHandles.hEvent, INFINITE);

        while (1) {
            _TCHAR  readBuffer[256];
            DWORD   readBufferSizeInByte = sizeof(readBuffer);
            DWORD   readDataSize = 0;
            ZeroMemory(readBuffer, readBufferSizeInByte);

            BOOL readResult = ReadFile(pipeHandles.hPipe, readBuffer, readBufferSizeInByte, (LPDWORD)&readDataSize, NULL);
            ResetEvent(pipeHandles.hEvent);
            if (FALSE == readResult) {
                _tprintf(_T("Can not read data.\r\n"));
                break;
            }
            else {
                _tprintf(_T("Read data : %s\r\n"), readBuffer);
            }

            if (0 == readBuffer[0]) {
                break;
            }
        }
    } while (0);
    SetEvent(pipeHandles.hEvent);
    CloseHandle(pipeHandles.hPipe);
    
    //
    //...(省略)...
    //
    return nRetCode;
}

int main()
{
    //
    //...(省略)...
    //
    HANDLE hEvent = OpenEvent(EVENT_ALL_ACCESS, FALSE, _T("IPC_SAMPLE"));
    if (NULL == hEvent) {
        _tprintf(_T("Error event open.\r\n"));
        return (-1);
    }
    HANDLE hPipe = CreateFile(_T("\\\\.\\pipe\\sample_pipe"),
        GENERIC_WRITE,
        0, 
        NULL, 
        OPEN_EXISTING, 
        FILE_ATTRIBUTE_NORMAL, 
        NULL);
    if (INVALID_HANDLE_VALUE == hPipe) {
            _tprintf(_T("Can not create file, as PIPE\r\n"));
    }
    else {
        _tprintf(_T("Can create file, as PIPE\r\n"));
        int loopCount = 0;
        int maxLoopNum = 13;

        while (1) {
            _TCHAR buffer[256];
            ZeroMemory(buffer, sizeof(buffer));
            DWORD writtenWordSize = 0;
            DWORD numberOfByteToWrite = 0;
            BOOL isExitFlag = FALSE;
            if (loopCount < maxLoopNum) {
                _stprintf_s(buffer, _T("CLIENT SEND DATA = %d"), loopCount);
                numberOfByteToWrite = _tcsclen(buffer) * sizeof(TCHAR);
                isExitFlag = FALSE;
            }
            else {
                buffer[0] = 0;
                numberOfByteToWrite = sizeof(_TCHAR);
                isExitFlag = true;
            }
            SetEvent(hEvent);
            BOOL writeRes = WriteFile(hPipe, buffer, numberOfByteToWrite, (LPDWORD)&writtenWordSize, NULL);
            if (!writeRes) {
                _tprintf(_T("Can not write data into file.\r\n"));
            }
            else {
                _tprintf(_T("Can write data into file.(data size = %d)\r\n"), writtenWordSize);
            }

            if (FALSE != isExitFlag) {
                break;
            }
            loopCount++;
        }

        CloseHandle(hPipe);
        WaitForSingleObject(hEvent, INFINITE);
    }
    CloseHandle(hEvent);
    //
    //...(省略)...
    //
    return nRetCode;
}