Форум программистов [Powered by Invision Power Board]

Код


#include <tchar.h>
#include <stdio.h>
#include <Io.h>
#include <Fcntl.h>
#include <windows.h>

DWORD CALLBACK ThdProc(LPVOID /*lpParam*/)
{
    DWORD dwBytes = 0;
    char buf[0x1000] = {0};

    HANDLE hPipe = CreateFile(_T("\\\\.\\pipe\\SomePipeName"), 
        GENERIC_READ, 0, NULL, OPEN_EXISTING, 0, NULL);

    if(hPipe != INVALID_HANDLE_VALUE)
    {
        //for(;;)
        {
            DWORD dwBytes = 0;
            DWORD dwLeft  = 0;
            DWORD dwOfst  = 0;

            ReadFile(hPipe, buf, 0x1000, &dwBytes, NULL);

            dwOfst = dwBytes;

            PeekNamedPipe(hPipe, NULL, NULL, NULL, &dwLeft, 0);

            while(dwLeft > 0)
            {
                ReadFile(hPipe, buf + dwOfst, dwLeft, &dwBytes, NULL);
                dwOfst += dwBytes;

                PeekNamedPipe(hPipe, NULL, NULL, NULL, &dwLeft, 0);
            }

            MessageBoxA(NULL, buf, "Buffer", 0);
        }

        CloseHandle(hPipe);
    }

    return 0;
}

int APIENTRY _tWinMain(HINSTANCE, HINSTANCE, LPTSTR, int)
{
    HANDLE hPipe = CreateNamedPipe(_T("\\\\.\\pipe\\SomePipeName"), PIPE_ACCESS_OUTBOUND,
        PIPE_TYPE_BYTE, 1, 0x1000, 0x1000, 0, NULL);

    if(hPipe != INVALID_HANDLE_VALUE)
    {
        HANDLE hThd = CreateThread(NULL, 0, &ThdProc, NULL, 0, NULL);

        if(hThd && ConnectNamedPipe(hPipe, NULL))
        {
            int pipeDesc = _open_osfhandle((intptr_t)hPipe, 0);

            if(pipeDesc > 0)
            {
                FILE *fp = _fdopen(pipeDesc, "w");

                if(fp)
                {
                    *stdout = *fp;
                    setvbuf(stdout, NULL, _IONBF, 0);

                    printf("This is test message\n");

                    WaitForSingleObject(hThd, INFINITE);
                    fclose(fp);
                }
            }
        }
    }
    
    return 0;
}

Цитата

Line buffering: On output, data is written when a newline character is inserted into the stream or when the buffer is full (or flushed), whatever happens first. On Input, the buffer is filled up to the next newline character when an input operation is requested and the buffer is empty.