Чтение stdout дочернего процесса

#include <stdio.h>
#include <conio.h>
#include <string.h>
#include <windows.h>
 
// Проверка запуска под Windows NT.
bool IsWinNT()
{
    OSVERSIONINFO osv;
    osv.dwOSVersionInfoSize = sizeof(osv);
    GetVersionEx(&osv);
    return (osv.dwPlatformId == VER_PLATFORM_WIN32_NT);
}
 
// Вывод подробной информации об ошибке.
void ErrorMessage(const char *str)
{
    LPVOID msg;
    
    FormatMessage(
        FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
        NULL,
        GetLastError(),
        MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), // Язык по умолчанию.
        (LPTSTR)&msg,
        0,
        NULL
    );
    
    fprintf(stderr, "%s: %s\n", str, msg);
    LocalFree(msg);
}
 
 
int main(int argc, char *argv[])
{
    char buf[1024]; // Буфер ввода/вывода.
    
    STARTUPINFO si;
    SECURITY_ATTRIBUTES sa;
    SECURITY_DESCRIPTOR sd; // Структура security для пайпов.
    PROCESS_INFORMATION pi;
    
    HANDLE newstdin, newstdout, read_stdout, write_stdin; // Дескрипторы пайпов.
    
    if (IsWinNT()) // Инициализация security для Windows NT.
    {
        InitializeSecurityDescriptor(&sd, SECURITY_DESCRIPTOR_REVISION);
        SetSecurityDescriptorDacl(&sd, true, NULL, false);
        sa.lpSecurityDescriptor = &sd;
    }
    else
        sa.lpSecurityDescriptor = NULL;
    
    sa.nLength = sizeof(SECURITY_ATTRIBUTES);
    sa.bInheritHandle = true; // Разрешаем наследование дескрипторов.
    
    if (!CreatePipe(&newstdin, &write_stdin, &sa, 0)) // Создаем пайп для stdin.
    {
        ErrorMessage("CreatePipe");
        getch();
        return 1;
    }
    
    if (!CreatePipe(&read_stdout, &newstdout, &sa, 0)) // Создаем пайп для stdout.
    {
        ErrorMessage("CreatePipe");
        getch();
        CloseHandle(newstdin);
        CloseHandle(write_stdin);
        return 1;
    }
    
    GetStartupInfo(&si); // Создаем startupinfo для дочернего процесса.
    
    /*
    Параметр dwFlags сообщает функции CreateProcess как именно надо создать процесс.
    STARTF_USESTDHANDLES управляет полями hStd*.
    STARTF_USESHOWWINDOW управляет полем wShowWindow.
    */
    
    si.dwFlags = STARTF_USESTDHANDLES | STARTF_USESHOWWINDOW;
    si.wShowWindow = SW_HIDE;
    si.hStdOutput = newstdout;
    si.hStdError = newstdout; // Подменяем дескрипторы для
    si.hStdInput = newstdin; // Дочернего процесса.
    
    char app_spawn[] = "C:\\Windows\\System32\\cmd.exe";
    
    // Создаем дочерний процесс.
    if (!CreateProcess(app_spawn, NULL, NULL, NULL, TRUE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pi))
    {
        ErrorMessage("CreateProcess");
        getch();
        CloseHandle(newstdin);
        CloseHandle(newstdout);
        CloseHandle(read_stdout);
        CloseHandle(write_stdin);
        return 1;
    }
    
    unsigned long exit = 0; // Код завершения процесса.
    unsigned long bread; // Кол-во прочитанных байт.
    unsigned long avail; // Кол-во доступных байт.
    
    memset(buf, 0, sizeof(buf));
    
    for(;;) // Основной цикл программы.
    {
        GetExitCodeProcess(pi.hProcess, &exit); // Пока дочерний процесс не закрыт.
        if (exit != STILL_ACTIVE)
            break;
        
        PeekNamedPipe(read_stdout, buf, 1023, &bread, &avail, NULL);
        
        // Проверяем, есть ли данные для чтения в stdout.
        if (bread != 0)
        {
            memset(buf, 0, sizeof(buf));
            if (avail > 1023)
            {
                while (bread >= 1023)
                {
                    ReadFile(read_stdout, buf, 1023, &bread, NULL); // Читаем из пайпа stdout.
                    printf("%s", buf);
                    memset(buf, 0, sizeof(buf));
                }
            }
            else
            {
                ReadFile(read_stdout, buf, 1023, &bread, NULL);
                printf("%s", buf);
            }
        }
        
        if (kbhit()) // Проверяем, введено ли что-нибудь с клавиатуры.
        {
            memset(buf, 0, sizeof(buf));
            *buf = (char)getche();
            
            WriteFile(write_stdin, buf, 1, &bread, NULL); // Отправляем это в stdin
            
            if (*buf == '\r')
            {
                *buf = '\n';
                printf("%c", *buf);
                WriteFile(write_stdin, buf, 1, &bread, NULL); // Формирум конец строки, если нужно.
            }
        }
    }
    
    CloseHandle(pi.hThread);
    CloseHandle(pi.hProcess);
    CloseHandle(newstdin); 
    CloseHandle(newstdout);
    CloseHandle(read_stdout);
    CloseHandle(write_stdin);
    return 0;
}