mirror of https://github.com/lianthony/NT4.0
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
189 lines
5.1 KiB
189 lines
5.1 KiB
/*++
|
|
|
|
Copyright (c) 1990 Microsoft Corporation
|
|
|
|
Module Name:
|
|
|
|
tnpcli.c
|
|
|
|
Abstract:
|
|
|
|
This program makes simple client calls to tnpsrv.c
|
|
|
|
run tnpcli with no arguments and it will use the pipe name
|
|
\\.\Pipe\cw\testpipe
|
|
with - as the parameter it will use the pipe name
|
|
\\colinw1\Pipe\cw\testpipe
|
|
any other arguments and it will use the first parameter as the pipe name
|
|
|
|
Author:
|
|
|
|
Colin Watson (ColinW) 19-March-1991
|
|
|
|
Revision History:
|
|
|
|
--*/
|
|
#include <assert.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <windows.h>
|
|
|
|
#define PIPE_NAME "\\\\.\\Pipe\\cw\\testpipe"
|
|
#define PIPE_NAME2 "\\\\colinw1\\Pipe\\cw\\testpipe"
|
|
CHAR* WriteData1 = "Hello Mars\n";
|
|
CHAR* WriteData2 = "Hello Jupiter\n";
|
|
|
|
int
|
|
main(
|
|
int argc,
|
|
char *argv[],
|
|
char *envp[]
|
|
)
|
|
{
|
|
|
|
HANDLE C1;
|
|
DWORD Size;
|
|
DWORD Dummy;
|
|
DWORD Count;
|
|
CHAR Data[1024];
|
|
PCHAR pipename;
|
|
|
|
if ( argc == 2 ) {
|
|
if (strcmp(argv[1], "-") == 0) {
|
|
pipename = PIPE_NAME2;
|
|
} else {
|
|
pipename = argv[1];
|
|
}
|
|
} else {
|
|
pipename = PIPE_NAME;
|
|
};
|
|
printf("Create client %s...\n", pipename);
|
|
|
|
C1 = CreateFile(pipename,
|
|
GENERIC_READ | GENERIC_WRITE,
|
|
FILE_SHARE_READ | FILE_SHARE_WRITE,
|
|
NULL, // Security Attributes
|
|
OPEN_EXISTING,
|
|
FILE_ATTRIBUTE_NORMAL,
|
|
NULL
|
|
);
|
|
for ( Count = 1; Count < 10; Count++ ) {
|
|
|
|
printf("Client Writing...\n");
|
|
if ( FALSE == WriteFile(C1, WriteData1, strlen(WriteData1)+1, &Dummy, NULL) ) {
|
|
printf("Client WriteFile returned Error %lx\n", GetLastError() );
|
|
}
|
|
|
|
while (1) {
|
|
printf("Client now Peeking...\n");
|
|
if ( FALSE == PeekNamedPipe(C1,Data, sizeof(Data), &Size, NULL, NULL) ) {
|
|
printf("Client PeekNamedPipe returned Error %lx\n", GetLastError() );
|
|
break;
|
|
}
|
|
|
|
if ( Size ) {
|
|
printf("Client PeekNamedPipe Done Size: %lx Data: %s\n",
|
|
Size, Data);
|
|
break;
|
|
}
|
|
else {
|
|
printf("Client PeekNamedPipe Done, no data yet, sleep 1 sec\n");
|
|
Sleep(1000);
|
|
}
|
|
}
|
|
|
|
printf("Client now Reading...\n");
|
|
if ( FALSE == ReadFile(C1,Data, sizeof(Data), &Size, NULL) ) {
|
|
printf("Client ReadFile returned Error %lx\n", GetLastError() );
|
|
}
|
|
|
|
printf("Client Reading Done Size: %lx Data: %s\n", Size, Data);
|
|
}
|
|
|
|
printf("Client Writing zero length record...\n");
|
|
if ( FALSE == WriteFile(C1, WriteData1, 0, &Dummy, NULL) ) {
|
|
printf("Client WriteFile returned Error %lx\n", GetLastError() );
|
|
}
|
|
|
|
printf("Client now Reading...\n");
|
|
if ( FALSE == ReadFile(C1,Data, sizeof(Data), &Size, NULL) ) {
|
|
printf("Client ReadFile returned Error %lx\n", GetLastError() );
|
|
}
|
|
printf("Client Reading Done Size: %lx Data: %s\n", Size, Data);
|
|
|
|
|
|
{
|
|
DWORD Flags;
|
|
DWORD OutBufferSize;
|
|
DWORD InBufferSize;
|
|
DWORD MaxInstances;
|
|
|
|
printf("Client call GetNamedPipeInfo....\n");
|
|
|
|
if ( FALSE == GetNamedPipeInfo(C1, &Flags, &OutBufferSize, &InBufferSize, &MaxInstances) ){
|
|
printf("Client GetNamedPipeInfo returned Error %lx\n", GetLastError() );
|
|
}
|
|
else {
|
|
printf("Flags %lx, OutBufferSize %lx, InBufferSize %lx, MaxInstances %lx\n",
|
|
Flags, OutBufferSize, InBufferSize, MaxInstances);
|
|
}
|
|
}
|
|
|
|
{
|
|
DWORD State;
|
|
DWORD CurInstances;
|
|
|
|
printf("Client call GetNamedPipeHandleState....\n");
|
|
|
|
if ( FALSE == GetNamedPipeHandleState(C1, &State, &CurInstances, NULL, NULL, NULL, 0) ){
|
|
printf("Client GetNamedPipeHandleState returned Error %lx\n", GetLastError() );
|
|
}
|
|
else {
|
|
printf("State %lx, CurInstances %lx\n", State, CurInstances );
|
|
}
|
|
|
|
}
|
|
|
|
printf("Client attempting 10 second WaitNamedPipe- should timeout...\n");
|
|
|
|
if ( FALSE == WaitNamedPipe(pipename, 10000) ) {
|
|
printf("Client WaitNamedPipe returned Error %lx\n", GetLastError() );
|
|
}
|
|
|
|
printf("WaitNamedPipe complete\nClient closing...\n");
|
|
|
|
CloseHandle(C1);
|
|
printf("Client closed\n");
|
|
|
|
Sleep(1000);
|
|
|
|
printf("Client attempting 10 second WaitNamedPipe- should work...\n");
|
|
|
|
if ( FALSE == WaitNamedPipe(pipename, 10000) ) {
|
|
printf("Client WaitNamedPipe returned Error %lx\n", GetLastError() );
|
|
}
|
|
|
|
printf("WaitNamedPipeComplete\n");
|
|
|
|
for ( Count = 1; Count < 5; Count++ ) {
|
|
|
|
printf("Client CallNamedPipe...\n");
|
|
|
|
if ( FALSE == CallNamedPipe(
|
|
pipename,
|
|
WriteData2,
|
|
strlen(WriteData2)+1,
|
|
Data,
|
|
sizeof(Data),
|
|
&Size,
|
|
10000 // Ten second timeout
|
|
) ) {
|
|
printf("CallNamedPipe returned Error %lx\n", GetLastError() );
|
|
}
|
|
printf("Client CallNamedPipe Done %lx: %s\n", Size, Data);
|
|
}
|
|
|
|
printf("CallNamedPipe complete\n");
|
|
|
|
return 0;
|
|
}
|