|
//
// PipeClient.cpp : Defines the entry point for the console application.
//
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <tchar.h>
#include "stdafx.h"
#define BUFSIZE 512
int _tmain(int argc, TCHAR *argv[])
{
HANDLE hPipe;
LPTSTR lpvMessage=TEXT("Default message from client");
TCHAR chBuf[BUFSIZE];
BOOL fSuccess;
DWORD cbRead, cbWritten, dwMode;
LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\mynamedpipe");
if( argc > 1 )
lpvMessage = argv[1];
while (1)
{
// Try to open a named pipe; wait for it, if necessary.
BOOL bRetried = FALSE;
while (1)
{
hPipe = CreateFile(
lpszPipename, // pipe name
GENERIC_READ | // read and write access
GENERIC_WRITE,
0, // no sharing
NULL, // default security attributes
OPEN_EXISTING, // opens existing pipe
0, // default attributes
NULL); // no template file
// Break if the pipe handle is valid.
if (hPipe != INVALID_HANDLE_VALUE)
break;
// Exit if an error other than ERROR_PIPE_BUSY occurs.
if (GetLastError() != ERROR_PIPE_BUSY)
{
printf("Could not open pipe");
return 0;
}
if (bRetried)
{
printf("Could not open pipe");
return 0;
}
// Retry for 1000ms
bRetried = TRUE;
BOOL bSuccess = FALSE;
for (INT i = 0 ; i < 10 ; ++i)
{
_tprintf( TEXT("W") );
bSuccess = WaitNamedPipe(lpszPipename, 0);
if (!bSuccess)
{
Sleep(100);
}
else
break;
}
if (!bSuccess)
{
printf("Fail WaitNamedPipe");
return 0;
}
else
_tprintf( TEXT("R") );
}
// The pipe connected; change to message-read mode.
dwMode = PIPE_READMODE_MESSAGE;
fSuccess = SetNamedPipeHandleState(
hPipe, // pipe handle
&dwMode, // new pipe mode
NULL, // don't set maximum bytes
NULL); // don't set maximum time
if (!fSuccess)
{
printf("SetNamedPipeHandleState failed");
return 0;
}
// Send a message to the pipe server.
fSuccess = WriteFile(
hPipe, // pipe handle
lpvMessage, // message
(lstrlen(lpvMessage)+1)*sizeof(TCHAR), // message length
&cbWritten, // bytes written
NULL); // not overlapped
if (!fSuccess)
{
printf("WriteFile failed");
return 0;
}
do
{
// Read from the pipe.
fSuccess = ReadFile(
hPipe, // pipe handle
chBuf, // buffer to receive reply
BUFSIZE*sizeof(TCHAR), // size of buffer
&cbRead, // number of bytes read
NULL); // not overlapped
if (! fSuccess && GetLastError() != ERROR_MORE_DATA)
break;
//_tprintf( TEXT("%s\n"), chBuf );
_tprintf( TEXT(".") );
} while (!fSuccess); // repeat loop if ERROR_MORE_DATA
//getch();
CloseHandle(hPipe);
}
return 0;
}
| 