Pipes.c File Reference

#include "precomp.h"

Include dependency graph for Pipes.c:

Go to the source code of this file.

Macros
#define	MINBUFFERSIZE   1
#define	MAXBUFFERSIZE   255
#define	TEST_MESSAGE   "Test"
#define	TEST_MESSAGE_SIZE   (sizeof(TEST_MESSAGE) - sizeof(ANSI_NULL))

Functions
DWORD WINAPI	PipeWriter (_In_ PVOID Param)
DWORD WINAPI	PipeReader (_In_ PVOID Param)
VOID	StartTestCORE17376 (_In_ DWORD adReadBufferSize)
	START_TEST (Pipes)

Variables
static PCWSTR	g_PipeName = L"\\\\.\\pipe\\rostest_pipe"
static DWORD	g_dwReadBufferSize

Macro Definition Documentation

MAXBUFFERSIZE

#define MAXBUFFERSIZE   255

Definition at line 14 of file Pipes.c.

MINBUFFERSIZE

#define MINBUFFERSIZE   1

Definition at line 13 of file Pipes.c.

TEST_MESSAGE

#define TEST_MESSAGE   "Test"

Definition at line 15 of file Pipes.c.

TEST_MESSAGE_SIZE

#define TEST_MESSAGE_SIZE   (sizeof(TEST_MESSAGE) - sizeof(ANSI_NULL))

Definition at line 16 of file Pipes.c.

Function Documentation

PipeReader()

DWORD WINAPI PipeReader

(

_In_ PVOID

Param

)

Definition at line 32 of file Pipes.c.

{
    HANDLE hPipe = (HANDLE)Param;
    CHAR outMsg[MAXBUFFERSIZE];
 
    DWORD cbRead = 0;
    BOOL Success = ReadFile(hPipe, outMsg, g_dwReadBufferSize, &cbRead, NULL);
 
    if (g_dwReadBufferSize == MINBUFFERSIZE)
        ok(!Success, "ReadFile() succeeded unexpectedly\n");
    else
        ok(Success, "ReadFile() failed, last error = 0x%lx\n", GetLastError());
 
    ok(cbRead != 0, "cbRead == 0\n");
 
    if (g_dwReadBufferSize == MINBUFFERSIZE)
        ok_hex(GetLastError(), ERROR_MORE_DATA);
 
    return 0;
}

Referenced by StartTestCORE17376().

PipeWriter()

DWORD WINAPI PipeWriter

(

_In_ PVOID

Param

)

Definition at line 20 of file Pipes.c.

{
    HANDLE hPipe = (HANDLE)Param;
    DWORD cbWritten = 0;
    BOOL Success = WriteFile(hPipe, TEST_MESSAGE, TEST_MESSAGE_SIZE, &cbWritten, NULL);
 
    ok(Success, "WriteFile() failed, last error = 0x%lx\n", GetLastError());
    ok_int(cbWritten, TEST_MESSAGE_SIZE);
 
    return 0;
}

Referenced by StartTestCORE17376().

START_TEST()

START_TEST

(

Pipes

)

Definition at line 110 of file Pipes.c.

{
    StartTestCORE17376(MINBUFFERSIZE);
    StartTestCORE17376(MAXBUFFERSIZE);
}

StartTestCORE17376()

VOID StartTestCORE17376

(

_In_ DWORD

adReadBufferSize

)

Definition at line 53 of file Pipes.c.

{
    HANDLE hPipeReader, hPipeWriter, hThreadReader, hThreadWriter;
    trace("adReadBufferSize = %lu - START\n", adReadBufferSize);
 
    g_dwReadBufferSize = adReadBufferSize;
 
    hPipeReader = CreateNamedPipeW(
        g_PipeName,
        PIPE_ACCESS_DUPLEX,
        PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE,
        1,
        MAXBUFFERSIZE,
        MAXBUFFERSIZE,
        0,
        NULL);
    ok(hPipeReader != INVALID_HANDLE_VALUE, "CreateNamedPipeW failed\n");
 
    if (hPipeReader == INVALID_HANDLE_VALUE)
        return;
 
    hThreadReader = CreateThread(NULL, 0, PipeReader, hPipeReader, 0, NULL);
    ok(hThreadReader != INVALID_HANDLE_VALUE, "CreateThread failed\n");
 
    hPipeWriter = CreateFileW(
        g_PipeName,
        GENERIC_READ | GENERIC_WRITE,
        FILE_SHARE_READ | FILE_SHARE_WRITE,
        NULL,
        OPEN_EXISTING,
        FILE_ATTRIBUTE_NORMAL,
        NULL);
    ok(hPipeWriter != INVALID_HANDLE_VALUE, "CreateFileW failed\n");
 
    if (hPipeWriter != INVALID_HANDLE_VALUE)
    {
        hThreadWriter = CreateThread(NULL, 0, PipeWriter, hPipeWriter, 0, NULL);
        ok(hThreadWriter != INVALID_HANDLE_VALUE, "CreateThread failed\n");
 
        if (hThreadWriter != INVALID_HANDLE_VALUE)
        {
            WaitForSingleObject(hThreadWriter, INFINITE);
            CloseHandle(hThreadWriter);
        }
        CloseHandle(hPipeWriter);
    }
 
    if (hThreadReader != INVALID_HANDLE_VALUE)
    {
        WaitForSingleObject(hThreadReader, INFINITE);
        CloseHandle(hThreadReader);
    }
    CloseHandle(hPipeReader);
 
    trace("adReadBufferSize = %lu - COMPLETED\n", adReadBufferSize);
}

Referenced by START_TEST().

Variable Documentation

g_dwReadBufferSize

DWORD g_dwReadBufferSize

static

Definition at line 18 of file Pipes.c.

Referenced by PipeReader(), and StartTestCORE17376().

g_PipeName

PCWSTR g_PipeName = L"\\\\.\\pipe\\rostest_pipe"

static

Definition at line 11 of file Pipes.c.

Referenced by StartTestCORE17376().