NpfsCreate.c File Reference

#include <kmt_test.h>
#include "npfs.h"

Include dependency graph for NpfsCreate.c:

Go to the source code of this file.

Functions
static VOID	TestCreateNamedPipe (VOID)
static VOID	TestCreate (VOID)
static VOID NTAPI	RunTest (IN PVOID Context)
	START_TEST (NpfsCreate)

Variables
static KSTART_ROUTINE	RunTest

Function Documentation

RunTest()

static VOID NTAPI RunTest ( IN PVOID  Context )

static

Definition at line 104 of file NpfsCreate.c.

{
    UNREFERENCED_PARAMETER(Context);
    TestCreateNamedPipe();
    TestCreate();
}

START_TEST()

START_TEST

(

NpfsCreate

)

Definition at line 112 of file NpfsCreate.c.

{
    PKTHREAD Thread;
 
    Thread = KmtStartThread(RunTest, NULL);
    KmtFinishThread(Thread, NULL);
}

TestCreate()

static VOID TestCreate ( VOID  )

static

Definition at line 96 of file NpfsCreate.c.

{
}

Referenced by RunTest().

TestCreateNamedPipe()

static VOID TestCreateNamedPipe ( VOID  )

static

Definition at line 13 of file NpfsCreate.c.

{
    NTSTATUS Status;
    HANDLE ServerHandle;
    ULONG MaxInstances;
    ULONG InQuota, OutQuota;
    ULONG Quotas[] = { 0, 1, 2, 1024, PAGE_SIZE - 1, PAGE_SIZE, PAGE_SIZE + 1, 2 * PAGE_SIZE, 8 * PAGE_SIZE, 64 * PAGE_SIZE, 64 * PAGE_SIZE + 1, 128 * PAGE_SIZE };
    ULONG i;
    LARGE_INTEGER Timeout;
 
    /* Invalid pipe name */
    MaxInstances = 1;
    InQuota = 4096;
    OutQuota = 4096;
    ServerHandle = INVALID_HANDLE_VALUE;
    Status = NpCreatePipe(&ServerHandle,
                          DEVICE_NAMED_PIPE L"",
                          BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX,
                          MaxInstances,
                          InQuota,
                          OutQuota);
    ok_eq_hex(Status, STATUS_OBJECT_NAME_INVALID);
    ok_eq_pointer(ServerHandle, INVALID_HANDLE_VALUE);
    if (ServerHandle != NULL && ServerHandle != INVALID_HANDLE_VALUE)
        ObCloseHandle(ServerHandle, KernelMode);
 
    ServerHandle = INVALID_HANDLE_VALUE;
    Status = NpCreatePipe(&ServerHandle,
                          DEVICE_NAMED_PIPE L"\\",
                          BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX,
                          MaxInstances,
                          InQuota,
                          OutQuota);
    ok_eq_hex(Status, STATUS_OBJECT_NAME_INVALID);
    ok_eq_pointer(ServerHandle, INVALID_HANDLE_VALUE);
    if (ServerHandle != NULL && ServerHandle != INVALID_HANDLE_VALUE)
        ObCloseHandle(ServerHandle, KernelMode);
 
    ServerHandle = INVALID_HANDLE_VALUE;
    Status = NpCreatePipe(&ServerHandle,
                          DEVICE_NAMED_PIPE L"\\\\",
                          BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX,
                          MaxInstances,
                          InQuota,
                          OutQuota);
    ok_eq_hex(Status, STATUS_OBJECT_NAME_INVALID);
    ok_eq_pointer(ServerHandle, INVALID_HANDLE_VALUE);
    if (ServerHandle != NULL && ServerHandle != INVALID_HANDLE_VALUE)
        ObCloseHandle(ServerHandle, KernelMode);
 
    /* Test in-quota */
    MaxInstances = 1;
    OutQuota = 4096;
    for (i = 0; i < RTL_NUMBER_OF(Quotas); i++)
    {
        InQuota = Quotas[i];
        ServerHandle = INVALID_HANDLE_VALUE;
        Status = NpCreatePipe(&ServerHandle,
                              DEVICE_NAMED_PIPE L"\\KmtestNpfsCreateTestPipe",
                              BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX,
                              MaxInstances,
                              InQuota,
                              OutQuota);
        ok_eq_hex(Status, STATUS_SUCCESS);
        ok(ServerHandle != NULL && ServerHandle != INVALID_HANDLE_VALUE, "ServerHandle = %p\n", ServerHandle);
        if (!skip(NT_SUCCESS(Status) && ServerHandle != NULL && ServerHandle != INVALID_HANDLE_VALUE, "No pipe\n"))
        {
            NpCheckServerPipe(ServerHandle,
                              BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX,
                              MaxInstances, 1,
                              InQuota, 0,
                              OutQuota, OutQuota,
                              FILE_PIPE_LISTENING_STATE);
            ObCloseHandle(ServerHandle, KernelMode);
            Timeout.QuadPart = -100 * 1000 * 10;
            Status = KeDelayExecutionThread(KernelMode, FALSE, &Timeout);
            ok_eq_hex(Status, STATUS_SUCCESS);
        }
    }
}

Referenced by RunTest().

Variable Documentation

RunTest

KSTART_ROUTINE RunTest

static

Definition at line 100 of file NpfsCreate.c.

Referenced by START_TEST().