11 #define MAX_INSTANCES 5 13 #define OUT_QUOTA 4096 15 #define CheckServer(ServerHandle, State) \ 16 NpCheckServerPipe(ServerHandle, \ 17 BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX, \ 20 OUT_QUOTA, OUT_QUOTA, \ 23 #define CheckClient(ClientHandle, State) \ 24 NpCheckClientPipe(ClientHandle, \ 25 BYTE_STREAM, QUEUE, BYTE_STREAM, DUPLEX, \ 28 OUT_QUOTA, OUT_QUOTA, \ 42 Context->Connect.ClientHandle = ClientHandle;
61 Context->Connect.PipePath = PipePath;
73 Context->Listen.ServerHandle = ServerHandle;
102 ClientHandle = ConnectContext.
Connect.ClientHandle;
144 if (!
skip(Okay,
"Listen succeeded unexpectedly\n"))
178 ClientHandle = ConnectContext.
Connect.ClientHandle;
217 ClientHandle = ConnectContext.
Connect.ClientHandle;
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)
PKTHREAD KmtStartThread(IN PKSTART_ROUTINE StartRoutine, IN PVOID StartContext OPTIONAL)
#define CheckClient(ClientHandle, State)
#define STATUS_PIPE_DISCONNECTED
#define UNREFERENCED_PARAMETER(P)
BOOLEAN TriggerWork(IN PTHREAD_CONTEXT Context, IN ULONG MilliSeconds)
VOID StartWorkerThread(OUT PTHREAD_CONTEXT Context)
#define DEVICE_NAMED_PIPE
#define INVALID_HANDLE_VALUE
#define FILE_PIPE_CONNECTED_STATE
VOID FinishWorkerThread(IN PTHREAD_CONTEXT Context)
#define CheckServer(ServerHandle, State)
#define ok_bool_false(value, desc)
#define ok_bool_true(value, desc)
NTSTATUS(* NTAPI)(IN PFILE_FULL_EA_INFORMATION EaBuffer, IN ULONG EaLength, OUT PULONG ErrorOffset)
static BOOLEAN CheckListenPipe(IN PTHREAD_CONTEXT Context, IN HANDLE ServerHandle, IN ULONG MilliSeconds)
#define FILE_PIPE_LISTENING_STATE
struct _THREAD_CONTEXT::@1581::@1583 Connect
static VOID TestConnect(IN HANDLE ServerHandle, IN PCWSTR PipePath)
NTSTATUS NpOpenPipe(OUT PHANDLE ClientHandle, IN PCWSTR PipePath, IN ULONG NamedPipeConfiguration)
#define NT_SUCCESS(StatCode)
_In_opt_ PFILE_OBJECT _In_opt_ PETHREAD Thread
#define NpDisconnectPipe(ServerHandle)
NTSTATUS NTAPI ObCloseHandle(IN HANDLE Handle, IN KPROCESSOR_MODE AccessMode)
static VOID ListenPipe(IN OUT PTHREAD_CONTEXT Context)
#define STATUS_PIPE_CONNECTED
struct _THREAD_CONTEXT::@1581::@1584 Listen
static BOOLEAN CheckConnectPipe(IN PTHREAD_CONTEXT Context, IN PCWSTR PipePath, IN ULONG MilliSeconds)
VOID KmtFinishThread(IN PKTHREAD Thread OPTIONAL, IN PKEVENT Event OPTIONAL)
BOOLEAN WaitForWork(IN PTHREAD_CONTEXT Context, IN ULONG MilliSeconds)
#define FILE_PIPE_DISCONNECTED_STATE
#define NpQueryPipe(h, es)
static VOID ConnectPipe(IN OUT PTHREAD_CONTEXT Context)
static KSTART_ROUTINE RunTest
#define FILE_PIPE_CLOSING_STATE
#define FILE_PIPE_FULL_DUPLEX
#define ok_eq_hex(value, expected)
#define STATUS_ILLEGAL_FUNCTION
#define STATUS_PIPE_NOT_AVAILABLE
#define NpListenPipe(ServerHandle)