Передача данных между консолью с использованием Pipe

int main(){
 
    BOOL   fConnected;
    HANDLE hNamedPipe;
    LPCWSTR   lpszPipeName = L"\\\\.\\pipe\\$MyPipe$";
    wchar_t   szBuf[1024];
    DWORD  cbRead;
    DWORD  cbWritten;
 
    hNamedPipe = CreateNamedPipe(
        lpszPipeName,
        PIPE_ACCESS_DUPLEX,
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
        PIPE_UNLIMITED_INSTANCES,
        1024, 1024, 5000, NULL);
 
    if (hNamedPipe == INVALID_HANDLE_VALUE)
    {
        fprintf(stdout, "CreateNamedPipe: Error %ld\n",
            GetLastError());
        _getch();
        return 0;
    }
 
 
    fprintf(stdout, "Waiting for connect...\n");
 
    fConnected = ConnectNamedPipe(hNamedPipe, NULL);
 
    if (CheckConnect(fConnected, hNamedPipe) == 0)
        return 0;
    
    fprintf(stdout, "\nConnected. Waiting for command...\n");
 
    // Цикл получения команд через канал
    while (1)
    {
        // Получаем очередную команду через канал Pipe
        if (ReadFile(hNamedPipe, &szBuf, 1024, &cbRead, NULL))
        {
            // Посылаем эту команду обратно клиентскому
            // приложению
            if (!WriteFile(hNamedPipe, szBuf, wcslen(szBuf) + 1, &cbWritten, NULL))
                break;
 
            // Выводим принятую команду на консоль 
            wprintf(L"Received: <%s>\n", szBuf);
 
            // Если пришла команда "exit", 
            // завершаем работу приложения
            if (!wcscmp(szBuf, L"exit"))
                break;
        }
        else
        {
            fprintf(stdout, "ReadFile: Error %ld\n", GetLastError());
 
            hNamedPipe = CreateNamedPipe(
                lpszPipeName,
                PIPE_ACCESS_DUPLEX,
                PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
                PIPE_UNLIMITED_INSTANCES,
                512, 512, 5000, NULL);
            if (hNamedPipe == INVALID_HANDLE_VALUE)
            {
                fprintf(stdout, "CreateNamedPipe: Error %ld\n",
                    GetLastError());
                _getch();
                return 0;
            }
            fConnected = ConnectNamedPipe(hNamedPipe, NULL);
            if (CheckConnect(fConnected, hNamedPipe) == 0)
                return 0;
            //break;
        }
    }
 
    CloseHandle(hNamedPipe);
    return 0;
}

#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include  <fstream>
#include <iostream>
 
int main(int argc, char* argv[]){
 
    HANDLE hNamedPipe;
    DWORD  cbWritten;
    DWORD  cbRead;
    wchar_t   szBuf[512];
 
    LPCWSTR   szPipeName = L"\\\\.\\pipe\\$MyPipe$";
 
    hNamedPipe = CreateFile(szPipeName, GENERIC_READ | GENERIC_WRITE,0, NULL, OPEN_EXISTING, 0, NULL);
 
    if (hNamedPipe == INVALID_HANDLE_VALUE)
    {
        fprintf_s(stdout, "CreateFile: Error %ld\n",
            GetLastError());
        _getch();
        return 0;
    }
 
    fprintf(stdout, "\nConnected. Type 'exit' to terminate\n");
 
    // Цикл обмена данными с серверным процессом
    while (1)
    {
        // Выводим приглашение для ввода команды
        printf("cmd>");
 
        // Вводим текстовую строку
        _getws_s(szBuf);
 
        // Передаем введенную строку серверному процессу
        // в качестве команды
        if (!WriteFile(hNamedPipe, szBuf, wcslen(szBuf) + 1,&cbWritten, NULL))
            break;
 
        // Получаем эту же команду обратно от сервера
        if (ReadFile(hNamedPipe, szBuf, 1024, &cbRead, NULL))
            //std::wcout << szBuf << std::endl;
            wprintf_s(L"Received back: <%s>\n", szBuf);
 
        // Если произошла ошибка, выводим ее код и
        // завершаем работу приложения
        else
        {
            fprintf(stdout, "ReadFile: Error %ld\n",
                GetLastError());
            _getch();
            break;
        }
 
        // В ответ на команду "exit" завершаем цикл
        // обмена данными с серверным процессом
        if (!wcscmp(szBuf, L"exit"))
            break;
    }
 
    // Закрываем идентификатор канала
    CloseHandle(hNamedPipe);
    return 0;
}