DWORD
WINAPI Pipe_Thread( LPVOID lpParam )
{
HANDLE hPipe;
LPTSTR lpvMessage=TEXT("Default message from client.");
TCHAR chBuf[512];
BOOL fSuccess = FALSE;
DWORD cbRead, cbToWrite, cbWritten, dwMode;
LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\testit");
TPipeMessage Packet;
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)
{
//_tprintf( TEXT("Could not open pipe. GLE=%d\n"), GetLastError() );
return -1;
}
// All pipe instances are busy, so wait for 20 seconds.
if ( ! WaitNamedPipe(lpszPipename, 20000))
{
MessageBox(HWND_DESKTOP,"Blabla2","Titel",MB_OK);
//printf("Could not open pipe: 20 second wait timed out.");
return -1;
}
}
// 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)
{
// _tprintf( TEXT("SetNamedPipeHandleState failed. GLE=%d\n"), GetLastError() );
return -1;
}
// Send a message to the pipe server.
cbToWrite = sizeof(Packet);
//Packet.size = sizeof(Packet);
Packet.data[0] = 0xAA;
Packet.data[511] = 0xBB;
Packet.dataSize = 512;
Packet.header = 0x01;
Packet.subheader = 0x02;
fSuccess = WriteFile(
hPipe, // pipe
handle
&Packet, // message
cbToWrite, // message length
&cbWritten, // bytes written
NULL); // not overlapped
sprintf(chBuf, "Bytes sent %i", cbWritten);
MessageBox(HWND_DESKTOP,chBuf,"SsS2",MB_OK);
if ( ! fSuccess)
{
//_tprintf( TEXT("WriteFile to pipe failed. GLE=%d\n"), GetLastError() );
return -1;
}
//printf("\nMessage sent to server, receiving reply as follows:\n");
/*
do
{
// Read from the pipe.
fSuccess = ReadFile(
hPipe, // pipe
handle
chBuf, // buffer to receive reply
512*sizeof(TCHAR), // size of buffer
&cbRead, // number of bytes read
NULL); // not overlapped
if ( ! fSuccess && GetLastError() != ERROR_MORE_DATA )
break;
} while ( ! fSuccess); // repeat loop if ERROR_MORE_DATA
if ( ! fSuccess)
{
//_tprintf( TEXT("ReadFile from pipe failed. GLE=%d\n"), GetLastError() );
return -1;
}
printf("\n<End of message, press ENTER to terminate connection and exit>");
_getch();
*/
while(hPipe);
CloseHandle(hPipe);
return 0;
}