npfs.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	_THREAD_CONTEXT

Macros
#define	DEVICE_NAMED_PIPE   L"\\Device\\NamedPipe"
#define	BYTE_STREAM   FILE_PIPE_BYTE_STREAM_MODE
#define	MESSAGE   FILE_PIPE_MESSAGE_MODE
#define	QUEUE   FILE_PIPE_QUEUE_OPERATION
#define	COMPLETE   FILE_PIPE_COMPLETE_OPERATION
#define	INBOUND   FILE_PIPE_INBOUND
#define	OUTBOUND   FILE_PIPE_OUTBOUND
#define	DUPLEX   FILE_PIPE_FULL_DUPLEX
#define	NpListenPipe(ServerHandle)   NpControlPipe(ServerHandle, FSCTL_PIPE_LISTEN, NULL, 0)
#define	NpDisconnectPipe(ServerHandle)   NpControlPipe(ServerHandle, FSCTL_PIPE_DISCONNECT, NULL, 0)
#define	NpCheckServerPipe(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps)    NpCheckServerPipe__(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, __FILE__, __LINE__)
#define	NpCheckServerPipe__(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, file, line)    NpCheckServerPipe_(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, file ":" KMT_STRINGIZE(line))
#define	NpCheckClientPipe(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps)    NpCheckClientPipe__(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, __FILE__, __LINE__)
#define	NpCheckClientPipe__(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, file, line)    NpCheckClientPipe_(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, file ":" KMT_STRINGIZE(line))
#define	NpQueryPipe(h, es)    NpQueryPipe__(h, es, __FILE__, __LINE__)
#define	NpQueryPipe__(h, es, file, line)    NpQueryPipe_(h, es, file ":" KMT_STRINGIZE(line))

Typedefs
typedef VOID()	WORK_FUNCTION(IN OUT struct _THREAD_CONTEXT *)
typedef WORK_FUNCTION *	PWORK_FUNCTION
typedef struct _THREAD_CONTEXT	THREAD_CONTEXT
typedef struct _THREAD_CONTEXT *	PTHREAD_CONTEXT

Functions
	C_ASSERT (FILE_PIPE_BYTE_STREAM_MODE==FILE_PIPE_BYTE_STREAM_TYPE)
	C_ASSERT (FILE_PIPE_MESSAGE_MODE==FILE_PIPE_MESSAGE_TYPE)
NTSTATUS	NpCreatePipeEx (OUT PHANDLE ServerHandle, IN PCWSTR PipePath, IN ULONG ReadMode, IN ULONG CompletionMode, IN ULONG NamedPipeType, IN ULONG ShareAccess, IN ULONG MaximumInstances, IN ULONG InboundQuota, IN ULONG OutboundQuota, IN ACCESS_MASK DesiredAccess, IN ULONG Disposition, IN ULONG CreateOptions, IN PLARGE_INTEGER DefaultTimeout OPTIONAL)
NTSTATUS	NpCreatePipe (OUT PHANDLE ServerHandle, IN PCWSTR PipePath, IN ULONG ReadMode, IN ULONG CompletionMode, IN ULONG NamedPipeType, IN ULONG NamedPipeConfiguration, IN ULONG MaximumInstances, IN ULONG InboundQuota, IN ULONG OutboundQuota)
NTSTATUS	NpOpenPipeEx (OUT PHANDLE ClientHandle, IN PCWSTR PipePath, IN ACCESS_MASK DesiredAccess, IN ULONG ShareAccess, IN ULONG Disposition, IN ULONG CreateOptions)
NTSTATUS	NpOpenPipe (OUT PHANDLE ClientHandle, IN PCWSTR PipePath, IN ULONG NamedPipeConfiguration)
NTSTATUS	NpControlPipe (IN HANDLE PipeHandle, IN ULONG FsControlCode, IN PVOID InputBuffer, IN ULONG InputBufferLength)
NTSTATUS	NpWaitPipe (IN PCWSTR PipeName, IN PLARGE_INTEGER Timeout)
NTSTATUS	NpReadPipe (IN HANDLE PipeHandle, OUT PVOID Buffer, IN ULONG BufferSize, OUT PULONG_PTR BytesRead)
NTSTATUS	NpWritePipe (IN HANDLE PipeHandle, IN const VOID *Buffer, IN ULONG BufferSize, OUT PULONG_PTR BytesWritten)
VOID	NpCheckServerPipe_ (IN HANDLE ServerHandle, IN ULONG ReadMode, IN ULONG CompletionMode, IN ULONG NamedPipeType, IN ULONG NamedPipeConfiguration, IN ULONG MaximumInstances, IN ULONG CurrentInstances, IN ULONG InboundQuota, IN ULONG ReadDataAvailable, IN ULONG OutboundQuota, IN ULONG WriteQuotaAvailable, IN ULONG NamedPipeState, IN PCSTR FileAndLine)
VOID	NpCheckClientPipe_ (IN HANDLE ClientHandle, IN ULONG ReadMode, IN ULONG CompletionMode, IN ULONG NamedPipeType, IN ULONG NamedPipeConfiguration, IN ULONG MaximumInstances, IN ULONG CurrentInstances, IN ULONG InboundQuota, IN ULONG ReadDataAvailable, IN ULONG OutboundQuota, IN ULONG WriteQuotaAvailable, IN ULONG NamedPipeState, IN PCSTR FileAndLine)
VOID	NpQueryPipe_ (IN HANDLE Handle, IN NTSTATUS ExpectedStatus, IN PCSTR FileAndLine)
VOID	StartWorkerThread (OUT PTHREAD_CONTEXT Context)
VOID	FinishWorkerThread (IN PTHREAD_CONTEXT Context)
BOOLEAN	WaitForWork (IN PTHREAD_CONTEXT Context, IN ULONG MilliSeconds)
BOOLEAN	TriggerWork (IN PTHREAD_CONTEXT Context, IN ULONG MilliSeconds)

Macro Definition Documentation

BYTE_STREAM

#define BYTE_STREAM   FILE_PIPE_BYTE_STREAM_MODE

Definition at line 13 of file npfs.h.

COMPLETE

#define COMPLETE   FILE_PIPE_COMPLETE_OPERATION

Definition at line 18 of file npfs.h.

DEVICE_NAMED_PIPE

#define DEVICE_NAMED_PIPE   L"\\Device\\NamedPipe"

Definition at line 11 of file npfs.h.

DUPLEX

#define DUPLEX   FILE_PIPE_FULL_DUPLEX

Definition at line 21 of file npfs.h.

INBOUND

#define INBOUND   FILE_PIPE_INBOUND

Definition at line 19 of file npfs.h.

MESSAGE

#define MESSAGE   FILE_PIPE_MESSAGE_MODE

Definition at line 15 of file npfs.h.

NpCheckClientPipe

#define NpCheckClientPipe	(		h,
			rm,
			cm,
			npt,
			npc,
			mi,
			ci,
			iq,
			rsa,
			oq,
			wqa,
			nps
	)		NpCheckClientPipe__(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, __FILE__, __LINE__)

Definition at line 121 of file npfs.h.

NpCheckClientPipe__

#define NpCheckClientPipe__	(		h,
			rm,
			cm,
			npt,
			npc,
			mi,
			ci,
			iq,
			rsa,
			oq,
			wqa,
			nps,
			file,
			line
	)		NpCheckClientPipe_(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, file ":" KMT_STRINGIZE(line))

Definition at line 124 of file npfs.h.

NpCheckServerPipe

#define NpCheckServerPipe	(		h,
			rm,
			cm,
			npt,
			npc,
			mi,
			ci,
			iq,
			rsa,
			oq,
			wqa,
			nps
	)		NpCheckServerPipe__(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, __FILE__, __LINE__)

Definition at line 95 of file npfs.h.

NpCheckServerPipe__

#define NpCheckServerPipe__	(		h,
			rm,
			cm,
			npt,
			npc,
			mi,
			ci,
			iq,
			rsa,
			oq,
			wqa,
			nps,
			file,
			line
	)		NpCheckServerPipe_(h, rm, cm, npt, npc, mi, ci, iq, rsa, oq, wqa, nps, file ":" KMT_STRINGIZE(line))

Definition at line 98 of file npfs.h.

NpDisconnectPipe

#define NpDisconnectPipe

(

ServerHandle

)

NpControlPipe(ServerHandle, FSCTL_PIPE_DISCONNECT, NULL, 0)

Definition at line 74 of file npfs.h.

NpListenPipe

#define NpListenPipe

(

ServerHandle

)

NpControlPipe(ServerHandle, FSCTL_PIPE_LISTEN, NULL, 0)

Definition at line 73 of file npfs.h.

NpQueryPipe

#define NpQueryPipe	(		h,
			es
	)		NpQueryPipe__(h, es, __FILE__, __LINE__)

Definition at line 147 of file npfs.h.

NpQueryPipe__

#define NpQueryPipe__	(		h,
			es,
			file,
			line
	)		NpQueryPipe_(h, es, file ":" KMT_STRINGIZE(line))

Definition at line 150 of file npfs.h.

OUTBOUND

#define OUTBOUND   FILE_PIPE_OUTBOUND

Definition at line 20 of file npfs.h.

QUEUE

#define QUEUE   FILE_PIPE_QUEUE_OPERATION

Definition at line 17 of file npfs.h.

Typedef Documentation

PTHREAD_CONTEXT

typedef struct _THREAD_CONTEXT * PTHREAD_CONTEXT

PWORK_FUNCTION

typedef WORK_FUNCTION* PWORK_FUNCTION

Definition at line 162 of file npfs.h.

THREAD_CONTEXT

typedef struct _THREAD_CONTEXT THREAD_CONTEXT

WORK_FUNCTION

typedef VOID() WORK_FUNCTION(IN OUT struct _THREAD_CONTEXT *)

Definition at line 161 of file npfs.h.

Function Documentation

C_ASSERT() [1/2]

C_ASSERT

(

FILE_PIPE_BYTE_STREAM_MODE

= =FILE_PIPE_BYTE_STREAM_TYPE

)

C_ASSERT() [2/2]

C_ASSERT

(

FILE_PIPE_MESSAGE_MODE

= =FILE_PIPE_MESSAGE_TYPE

)

FinishWorkerThread()

VOID FinishWorkerThread

(

IN PTHREAD_CONTEXT

Context

)

Definition at line 685 of file NpfsHelpers.c.

{
    KmtFinishThread(Context->Thread, &Context->ThreadDoneEvent);
}

Referenced by TestConnect(), and TestReadWrite().

NpCheckClientPipe_()

VOID NpCheckClientPipe_	(	IN HANDLE	ClientHandle,
		IN ULONG	ReadMode,
		IN ULONG	CompletionMode,
		IN ULONG	NamedPipeType,
		IN ULONG	NamedPipeConfiguration,
		IN ULONG	MaximumInstances,
		IN ULONG	CurrentInstances,
		IN ULONG	InboundQuota,
		IN ULONG	ReadDataAvailable,
		IN ULONG	OutboundQuota,
		IN ULONG	WriteQuotaAvailable,
		IN ULONG	NamedPipeState,
		IN PCSTR	FileAndLine
	)

Definition at line 520 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
    FILE_PIPE_INFORMATION PipeInfo;
    FILE_PIPE_LOCAL_INFORMATION PipeLocalInfo;
    FILE_PIPE_REMOTE_INFORMATION PipeRemoteInfo;
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeInfo, sizeof(PipeInfo), 0x55);
    Status = ZwQueryInformationFile(ClientHandle,
                                    &IoStatusBlock,
                                    &PipeInfo,
                                    sizeof(PipeInfo),
                                    FilePipeInformation);
    ok_eq_hex_(Status, STATUS_SUCCESS);
    ok_eq_hex_(IoStatusBlock.Status, STATUS_SUCCESS);
    ok_eq_ulongptr_(IoStatusBlock.Information, sizeof(PipeInfo));
    ok_eq_ulong_(PipeInfo.ReadMode, ReadMode);
    ok_eq_ulong_(PipeInfo.CompletionMode, CompletionMode);
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeLocalInfo, sizeof(PipeLocalInfo), 0x55);
    Status = ZwQueryInformationFile(ClientHandle,
                                    &IoStatusBlock,
                                    &PipeLocalInfo,
                                    sizeof(PipeLocalInfo),
                                    FilePipeLocalInformation);
    ok_eq_hex_(Status, STATUS_SUCCESS);
    ok_eq_hex_(IoStatusBlock.Status, STATUS_SUCCESS);
    ok_eq_ulongptr_(IoStatusBlock.Information, sizeof(PipeLocalInfo));
    ok_eq_ulong_(PipeLocalInfo.NamedPipeType, NamedPipeType);
    ok_eq_ulong_(PipeLocalInfo.NamedPipeConfiguration, NamedPipeConfiguration);
    ok_eq_ulong_(PipeLocalInfo.MaximumInstances, MaximumInstances);
    ok_eq_ulong_(PipeLocalInfo.CurrentInstances, CurrentInstances);
    ok_eq_ulong_(PipeLocalInfo.InboundQuota, InboundQuota);
    ok_eq_ulong_(PipeLocalInfo.ReadDataAvailable, ReadDataAvailable);
    ok_eq_ulong_(PipeLocalInfo.OutboundQuota, OutboundQuota);
    ok_eq_ulong_(PipeLocalInfo.WriteQuotaAvailable, WriteQuotaAvailable);
    ok_eq_ulong_(PipeLocalInfo.NamedPipeState, NamedPipeState);
    ok_eq_ulong_(PipeLocalInfo.NamedPipeEnd, (ULONG)FILE_PIPE_CLIENT_END);
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeRemoteInfo, sizeof(PipeRemoteInfo), 0x55);
    Status = ZwQueryInformationFile(ClientHandle,
                                    &IoStatusBlock,
                                    &PipeRemoteInfo,
                                    sizeof(PipeRemoteInfo),
                                    FilePipeInformation);
    ok_eq_hex_(Status, STATUS_SUCCESS);
    ok_eq_hex_(IoStatusBlock.Status, STATUS_SUCCESS);
    ok_eq_ulongptr_(IoStatusBlock.Information, RTL_SIZEOF_THROUGH_FIELD(FILE_PIPE_REMOTE_INFORMATION, CollectDataTime));
    ok_eq_ulonglong_(PipeRemoteInfo.CollectDataTime.QuadPart, 0ULL);
    ok_eq_ulong_(PipeRemoteInfo.MaximumCollectionCount, 0x55555555UL);
}

NpCheckServerPipe_()

VOID NpCheckServerPipe_	(	IN HANDLE	ServerHandle,
		IN ULONG	ReadMode,
		IN ULONG	CompletionMode,
		IN ULONG	NamedPipeType,
		IN ULONG	NamedPipeConfiguration,
		IN ULONG	MaximumInstances,
		IN ULONG	CurrentInstances,
		IN ULONG	InboundQuota,
		IN ULONG	ReadDataAvailable,
		IN ULONG	OutboundQuota,
		IN ULONG	WriteQuotaAvailable,
		IN ULONG	NamedPipeState,
		IN PCSTR	FileAndLine
	)

Definition at line 446 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
    FILE_PIPE_INFORMATION PipeInfo;
    FILE_PIPE_LOCAL_INFORMATION PipeLocalInfo;
    FILE_PIPE_REMOTE_INFORMATION PipeRemoteInfo;
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeInfo, sizeof(PipeInfo), 0x55);
    Status = ZwQueryInformationFile(ServerHandle,
                                    &IoStatusBlock,
                                    &PipeInfo,
                                    sizeof(PipeInfo),
                                    FilePipeInformation);
    ok_eq_hex_(Status, STATUS_SUCCESS);
    ok_eq_hex_(IoStatusBlock.Status, STATUS_SUCCESS);
    ok_eq_ulongptr_(IoStatusBlock.Information, sizeof(PipeInfo));
    ok_eq_ulong_(PipeInfo.ReadMode, ReadMode);
    ok_eq_ulong_(PipeInfo.CompletionMode, CompletionMode);
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeLocalInfo, sizeof(PipeLocalInfo), 0x55);
    Status = ZwQueryInformationFile(ServerHandle,
                                    &IoStatusBlock,
                                    &PipeLocalInfo,
                                    sizeof(PipeLocalInfo),
                                    FilePipeLocalInformation);
    ok_eq_hex_(Status, STATUS_SUCCESS);
    ok_eq_hex_(IoStatusBlock.Status, STATUS_SUCCESS);
    ok_eq_ulongptr_(IoStatusBlock.Information, sizeof(PipeLocalInfo));
    ok_eq_ulong_(PipeLocalInfo.NamedPipeType, NamedPipeType);
    ok_eq_ulong_(PipeLocalInfo.NamedPipeConfiguration, NamedPipeConfiguration);
    ok_eq_ulong_(PipeLocalInfo.MaximumInstances, MaximumInstances);
    ok_eq_ulong_(PipeLocalInfo.CurrentInstances, CurrentInstances);
    ok_eq_ulong_(PipeLocalInfo.InboundQuota, InboundQuota);
    ok_eq_ulong_(PipeLocalInfo.ReadDataAvailable, ReadDataAvailable);
    ok_eq_ulong_(PipeLocalInfo.OutboundQuota, OutboundQuota);
    ok_eq_ulong_(PipeLocalInfo.WriteQuotaAvailable, WriteQuotaAvailable);
    ok_eq_ulong_(PipeLocalInfo.NamedPipeState, NamedPipeState);
    ok_eq_ulong_(PipeLocalInfo.NamedPipeEnd, (ULONG)FILE_PIPE_SERVER_END);
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeRemoteInfo, sizeof(PipeRemoteInfo), 0x55);
    Status = ZwQueryInformationFile(ServerHandle,
                                    &IoStatusBlock,
                                    &PipeRemoteInfo,
                                    sizeof(PipeRemoteInfo),
                                    FilePipeInformation);
    ok_eq_hex_(Status, STATUS_SUCCESS);
    ok_eq_hex_(IoStatusBlock.Status, STATUS_SUCCESS);
    ok_eq_ulongptr_(IoStatusBlock.Information, RTL_SIZEOF_THROUGH_FIELD(FILE_PIPE_REMOTE_INFORMATION, CollectDataTime));
    ok_eq_ulonglong_(PipeRemoteInfo.CollectDataTime.QuadPart, 0ULL);
    ok_eq_ulong_(PipeRemoteInfo.MaximumCollectionCount, 0x55555555UL);
}

NpControlPipe()

NTSTATUS NpControlPipe	(	IN HANDLE	PipeHandle,
		IN ULONG	FsControlCode,
		IN PVOID	InputBuffer,
		IN ULONG	InputBufferLength
	)

Definition at line 208 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    Status = ZwFsControlFile(ServerHandle,
                             NULL,
                             NULL,
                             NULL,
                             &IoStatusBlock,
                             FsControlCode,
                             InputBuffer,
                             InputBufferLength,
                             NULL,
                             0);
    if (Status == STATUS_PENDING)
    {
        Status = ZwWaitForSingleObject(ServerHandle,
                                       FALSE,
                                       NULL);
        ok_eq_hex(Status, STATUS_SUCCESS);
        Status = IoStatusBlock.Status;
    }
    if (NT_SUCCESS(Status))
    {
        ok_eq_hex(IoStatusBlock.Status, Status);
        ok_eq_ulongptr(IoStatusBlock.Information, 0);
    }
    else
    {
        ok_eq_hex(IoStatusBlock.Status, 0x55555555UL);
        ok_eq_ulongptr(IoStatusBlock.Information, 0x5555555555555555ULL);
    }
    return Status;
}

Referenced by NpWaitPipe().

NpCreatePipe()

NTSTATUS NpCreatePipe	(	OUT PHANDLE	ServerHandle,
		IN PCWSTR	PipePath,
		IN ULONG	ReadMode,
		IN ULONG	CompletionMode,
		IN ULONG	NamedPipeType,
		IN ULONG	NamedPipeConfiguration,
		IN ULONG	MaximumInstances,
		IN ULONG	InboundQuota,
		IN ULONG	OutboundQuota
	)

Referenced by RunTest(), and TestCreateNamedPipe().

NpCreatePipeEx()

NTSTATUS NpCreatePipeEx	(	OUT PHANDLE	ServerHandle,
		IN PCWSTR	PipePath,
		IN ULONG	ReadMode,
		IN ULONG	CompletionMode,
		IN ULONG	NamedPipeType,
		IN ULONG	ShareAccess,
		IN ULONG	MaximumInstances,
		IN ULONG	InboundQuota,
		IN ULONG	OutboundQuota,
		IN ACCESS_MASK	DesiredAccess,
		IN ULONG	Disposition,
		IN ULONG	CreateOptions,
		IN PLARGE_INTEGER DefaultTimeout	OPTIONAL
	)

Definition at line 12 of file NpfsHelpers.c.

{
    UNICODE_STRING ObjectName;
    OBJECT_ATTRIBUTES ObjectAttributes;
    NAMED_PIPE_CREATE_PARAMETERS Params;
    IO_STATUS_BLOCK IoStatusBlock;
    NTSTATUS Status;
 
    RtlInitUnicodeString(&ObjectName, PipePath);
    InitializeObjectAttributes(&ObjectAttributes,
                               &ObjectName,
                               OBJ_CASE_INSENSITIVE | OBJ_KERNEL_HANDLE,
                               NULL,
                               NULL);
 
    Params.NamedPipeType = NamedPipeType;
    Params.ReadMode = ReadMode;
    Params.CompletionMode = CompletionMode;
    Params.MaximumInstances = MaximumInstances;
    Params.InboundQuota = InboundQuota;
    Params.OutboundQuota = OutboundQuota;
    if (DefaultTimeout)
    {
        Params.DefaultTimeout.QuadPart = DefaultTimeout->QuadPart;
        Params.TimeoutSpecified = TRUE;
    }
    else
    {
        Params.DefaultTimeout.QuadPart = 0;
        Params.TimeoutSpecified = FALSE;
    }
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    Status = IoCreateFile(ServerHandle,
                          DesiredAccess,
                          &ObjectAttributes,
                          &IoStatusBlock,
                          NULL, /* AllocationSize */
                          0, /* FileAttributes */
                          ShareAccess,
                          Disposition,
                          CreateOptions,
                          NULL, /* EaBuffer */
                          0, /* EaLength */
                          CreateFileTypeNamedPipe,
                          &Params,
                          0);
    if (NT_SUCCESS(Status))
    {
        ok_eq_hex(IoStatusBlock.Status, Status);
        ok_eq_ulongptr(IoStatusBlock.Information, FILE_CREATED);
    }
    else
    {
        ok_eq_hex(IoStatusBlock.Status, 0x55555555UL);
        ok_eq_ulongptr(IoStatusBlock.Information, 0x5555555555555555ULL);
    }
    return Status;
}

Referenced by NpCreatePipe().

NpOpenPipe()

NTSTATUS NpOpenPipe	(	OUT PHANDLE	ClientHandle,
		IN PCWSTR	PipePath,
		IN ULONG	NamedPipeConfiguration
	)

Definition at line 180 of file NpfsHelpers.c.

{
    ULONG ShareAccess;
 
    if (NamedPipeConfiguration == FILE_PIPE_INBOUND)
        ShareAccess = FILE_SHARE_WRITE;
    else if (NamedPipeConfiguration == FILE_PIPE_OUTBOUND)
        ShareAccess = FILE_SHARE_READ;
    else if (NamedPipeConfiguration == FILE_PIPE_FULL_DUPLEX)
        ShareAccess = FILE_SHARE_READ | FILE_SHARE_WRITE;
    else
    {
        ASSERTMSG("Invalid NamedPipeConfiguration parameter value!\n", FALSE);
        return STATUS_INVALID_PARAMETER_3;
    }
 
    return NpOpenPipeEx(ClientHandle,
                        PipePath,
                        SYNCHRONIZE | GENERIC_READ | GENERIC_WRITE,
                        ShareAccess,
                        FILE_OPEN,
                        FILE_SYNCHRONOUS_IO_NONALERT);
}

Referenced by ConnectPipe().

NpOpenPipeEx()

NTSTATUS NpOpenPipeEx	(	OUT PHANDLE	ClientHandle,
		IN PCWSTR	PipePath,
		IN ACCESS_MASK	DesiredAccess,
		IN ULONG	ShareAccess,
		IN ULONG	Disposition,
		IN ULONG	CreateOptions
	)

Definition at line 130 of file NpfsHelpers.c.

{
    UNICODE_STRING ObjectName;
    OBJECT_ATTRIBUTES ObjectAttributes;
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
 
    RtlInitUnicodeString(&ObjectName, PipePath);
    InitializeObjectAttributes(&ObjectAttributes,
                               &ObjectName,
                               OBJ_CASE_INSENSITIVE | OBJ_KERNEL_HANDLE,
                               NULL,
                               NULL);
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    Status = IoCreateFile(ClientHandle,
                          DesiredAccess,
                          &ObjectAttributes,
                          &IoStatusBlock,
                          NULL, /* AllocationSize */
                          0, /* FileAttributes */
                          ShareAccess,
                          Disposition,
                          CreateOptions,
                          NULL, /* EaBuffer */
                          0, /* EaLength */
                          CreateFileTypeNone,
                          NULL,
                          0);
    if (NT_SUCCESS(Status))
    {
        ok(Status != STATUS_PENDING, "IoCreateFile returned pending\n");
        ok_eq_hex(IoStatusBlock.Status, Status);
        ok_eq_ulongptr(IoStatusBlock.Information, FILE_OPENED);
    }
    else
    {
        ok_eq_hex(IoStatusBlock.Status, 0x55555555UL);
        ok_eq_ulongptr(IoStatusBlock.Information, 0x5555555555555555ULL);
    }
    return Status;
}

Referenced by ConnectPipe(), and NpOpenPipe().

NpQueryPipe_()

VOID NpQueryPipe_	(	IN HANDLE	Handle,
		IN NTSTATUS	ExpectedStatus,
		IN PCSTR	FileAndLine
	)

Definition at line 594 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
    FILE_PIPE_INFORMATION PipeInfo;
    FILE_PIPE_LOCAL_INFORMATION PipeLocalInfo;
    FILE_PIPE_REMOTE_INFORMATION PipeRemoteInfo;
 
    ASSERT(!NT_SUCCESS(ExpectedStatus));
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeInfo, sizeof(PipeInfo), 0x55);
    Status = ZwQueryInformationFile(PipeHandle,
                                    &IoStatusBlock,
                                    &PipeInfo,
                                    sizeof(PipeInfo),
                                    FilePipeInformation);
    ok_eq_hex_(Status, ExpectedStatus);
    ok_bool_true(CheckBuffer(&IoStatusBlock, sizeof(IoStatusBlock), 0x55), "CheckBuffer returned");
    ok_bool_true(CheckBuffer(&PipeInfo, sizeof(PipeInfo), 0x55), "CheckBuffer returned");
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeLocalInfo, sizeof(PipeLocalInfo), 0x55);
    Status = ZwQueryInformationFile(PipeHandle,
                                    &IoStatusBlock,
                                    &PipeLocalInfo,
                                    sizeof(PipeLocalInfo),
                                    FilePipeLocalInformation);
    ok_eq_hex_(Status, ExpectedStatus);
    ok_bool_true(CheckBuffer(&IoStatusBlock, sizeof(IoStatusBlock), 0x55), "CheckBuffer returned");
    ok_bool_true(CheckBuffer(&PipeLocalInfo, sizeof(PipeLocalInfo), 0x55), "CheckBuffer returned");
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    RtlFillMemory(&PipeRemoteInfo, sizeof(PipeRemoteInfo), 0x55);
    Status = ZwQueryInformationFile(PipeHandle,
                                    &IoStatusBlock,
                                    &PipeRemoteInfo,
                                    sizeof(PipeRemoteInfo),
                                    FilePipeInformation);
    ok_eq_hex_(Status, ExpectedStatus);
    ok_bool_true(CheckBuffer(&IoStatusBlock, sizeof(IoStatusBlock), 0x55), "CheckBuffer returned");
    ok_bool_true(CheckBuffer(&PipeRemoteInfo, sizeof(PipeRemoteInfo), 0x55), "CheckBuffer returned");
}

NpReadPipe()

NTSTATUS NpReadPipe	(	IN HANDLE	PipeHandle,
		OUT PVOID	Buffer,
		IN ULONG	BufferSize,
		OUT PULONG_PTR	BytesRead
	)

Definition at line 322 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
    BOOLEAN PendingReturned = FALSE;
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    Status = ZwReadFile(PipeHandle,
                        NULL,
                        NULL,
                        NULL,
                        &IoStatusBlock,
                        Buffer,
                        BufferSize,
                        NULL,
                        NULL);
    if (Status == STATUS_PENDING)
    {
        Status = ZwWaitForSingleObject(PipeHandle,
                                       FALSE,
                                       NULL);
        ok_eq_hex(Status, STATUS_SUCCESS);
        Status = IoStatusBlock.Status;
        PendingReturned = TRUE;
    }
    if (NT_SUCCESS(Status))
    {
        ok_eq_hex(IoStatusBlock.Status, Status);
        *BytesRead = IoStatusBlock.Information;
    }
    else
    {
        if (PendingReturned)
        {
            ok_eq_hex(IoStatusBlock.Status, Status);
            ok_eq_ulongptr(IoStatusBlock.Information, 0);
        }
        else
        {
            ok_eq_hex(IoStatusBlock.Status, 0x55555555UL);
            ok_eq_ulongptr(IoStatusBlock.Information, 0x5555555555555555ULL);
        }
        *BytesRead = 0;
    }
    return Status;
}

Referenced by ReadPipe().

NpWaitPipe()

NTSTATUS NpWaitPipe	(	IN PCWSTR	PipeName,
		IN PLARGE_INTEGER	Timeout
	)

Definition at line 250 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    HANDLE RootHandle;
    UNICODE_STRING RootDirectoryName = RTL_CONSTANT_STRING(DEVICE_NAMED_PIPE);
    OBJECT_ATTRIBUTES ObjectAttributes;
    IO_STATUS_BLOCK IoStatusBlock;
    PFILE_PIPE_WAIT_FOR_BUFFER WaitForBuffer;
    ULONG NameLength;
    ULONG BufferSize;
 
    InitializeObjectAttributes(&ObjectAttributes,
                               &RootDirectoryName,
                               OBJ_CASE_INSENSITIVE | OBJ_KERNEL_HANDLE,
                               NULL,
                               NULL);
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    Status = IoCreateFile(&RootHandle,
                          FILE_READ_ATTRIBUTES | SYNCHRONIZE,
                          &ObjectAttributes,
                          &IoStatusBlock,
                          NULL,
                          0,
                          FILE_SHARE_READ | FILE_SHARE_WRITE,
                          FILE_OPEN,
                          FILE_SYNCHRONOUS_IO_NONALERT,
                          NULL,
                          0,
                          CreateFileTypeNone,
                          NULL,
                          0);
    if (!NT_SUCCESS(Status))
    {
        ok_eq_hex(IoStatusBlock.Status, 0x55555555UL);
        ok_eq_ulongptr(IoStatusBlock.Information, 0x5555555555555555ULL);
        return Status;
    }
    ok(Status != STATUS_PENDING, "IoCreateFile returned pending\n");
    ok_eq_hex(IoStatusBlock.Status, Status);
    ok_eq_ulongptr(IoStatusBlock.Information, FILE_OPENED);
 
    NameLength = (ULONG)(wcslen(PipeName) * sizeof(WCHAR));
    BufferSize = FIELD_OFFSET(FILE_PIPE_WAIT_FOR_BUFFER,
                              Name[NameLength / sizeof(WCHAR)]);
    WaitForBuffer = ExAllocatePoolWithTag(NonPagedPool, BufferSize, 'WPmK');
    if (WaitForBuffer == NULL)
        return STATUS_INSUFFICIENT_RESOURCES;
 
    if (Timeout)
    {
        WaitForBuffer->Timeout.QuadPart = Timeout->QuadPart;
        WaitForBuffer->TimeoutSpecified = TRUE;
    }
    else
    {
        WaitForBuffer->Timeout.QuadPart = 0;
        WaitForBuffer->TimeoutSpecified = FALSE;
    }
    WaitForBuffer->NameLength = NameLength;
    RtlCopyMemory(WaitForBuffer->Name, PipeName, NameLength);
    Status = NpControlPipe(RootHandle,
                           FSCTL_PIPE_WAIT,
                           WaitForBuffer,
                           BufferSize);
    ExFreePoolWithTag(WaitForBuffer, 'WPmK');
    return Status;
}

NpWritePipe()

NTSTATUS NpWritePipe	(	IN HANDLE	PipeHandle,
		IN const VOID *	Buffer,
		IN ULONG	BufferSize,
		OUT PULONG_PTR	BytesWritten
	)

Definition at line 374 of file NpfsHelpers.c.

{
    NTSTATUS Status;
    IO_STATUS_BLOCK IoStatusBlock;
 
    RtlFillMemory(&IoStatusBlock, sizeof(IoStatusBlock), 0x55);
    Status = ZwWriteFile(PipeHandle,
                         NULL,
                         NULL,
                         NULL,
                         &IoStatusBlock,
                         (PVOID)Buffer,
                         BufferSize,
                         NULL,
                         NULL);
    if (Status == STATUS_PENDING)
    {
        Status = ZwWaitForSingleObject(PipeHandle,
                                       FALSE,
                                       NULL);
        ok_eq_hex(Status, STATUS_SUCCESS);
        Status = IoStatusBlock.Status;
    }
    if (NT_SUCCESS(Status))
    {
        ok_eq_hex(IoStatusBlock.Status, Status);
        *BytesWritten = IoStatusBlock.Information;
    }
    else
    {
        ok_eq_hex(IoStatusBlock.Status, 0x55555555UL);
        ok_eq_ulongptr(IoStatusBlock.Information, 0x5555555555555555ULL);
        *BytesWritten = 0;
    }
    return Status;
}

Referenced by WritePipe().

StartWorkerThread()

VOID StartWorkerThread

(

OUT PTHREAD_CONTEXT

Context

)

Definition at line 674 of file NpfsHelpers.c.

{
    KeInitializeEvent(&Context->ThreadDoneEvent, NotificationEvent, FALSE);
    KeInitializeEvent(&Context->StartWorkEvent, SynchronizationEvent, FALSE);
    KeInitializeEvent(&Context->WorkCompleteEvent, NotificationEvent, TRUE);
 
    Context->Thread = KmtStartThread(PipeWorkerThread, Context);
}

Referenced by TestConnect(), and TestReadWrite().

TriggerWork()

BOOLEAN TriggerWork	(	IN PTHREAD_CONTEXT	Context,
		IN ULONG	MilliSeconds
	)

Definition at line 710 of file NpfsHelpers.c.

{
    NTSTATUS Status;
 
    Status = KeWaitForSingleObject(&Context->WorkCompleteEvent,
                                   Executive,
                                   KernelMode,
                                   FALSE,
                                   NULL);
    ok_eq_hex(Status, STATUS_SUCCESS);
    KeClearEvent(&Context->WorkCompleteEvent);
    KeSetEvent(&Context->StartWorkEvent, IO_NO_INCREMENT, TRUE);
    return WaitForWork(Context, MilliSeconds);
}

Referenced by CheckConnectPipe(), CheckListenPipe(), CheckReadPipe(), and CheckWritePipe().

WaitForWork()

BOOLEAN WaitForWork	(	IN PTHREAD_CONTEXT	Context,
		IN ULONG	MilliSeconds
	)

Definition at line 692 of file NpfsHelpers.c.

{
    LARGE_INTEGER Timeout;
    NTSTATUS Status;
 
    Timeout.QuadPart = -10 * 1000 * (LONGLONG)MilliSeconds;
    Status = KeWaitForSingleObject(&Context->WorkCompleteEvent,
                                   Executive,
                                   KernelMode,
                                   FALSE,
                                   &Timeout);
    ok(Status == STATUS_SUCCESS || Status == STATUS_TIMEOUT, "Wait status %lx\n", Status);
    return Status != STATUS_TIMEOUT;
}

Referenced by TestConnect(), TestReadWrite(), and TriggerWork().