namedpipe传输数据失败，麻烦各位看看是什么问题。
for(;;)//创建namedpipe的服务器端代码
{
//create namedpipe client
hPipe = CreateNamedPipe(
lpszPipename, // pipe name
PIPE_ACCESS_DUPLEX, // read/write access
PIPE_TYPE_MESSAGE | // message type pipe
PIPE_READMODE_MESSAGE | // message-read mode
PIPE_WAIT, // blocking mode
PIPE_UNLIMITED_INSTANCES, // max. instances
BUFSIZE, // output buffer size
BUFSIZE, // input buffer size
0, // client time-out
&sa); // default security attribute
if(hPipe != INVALID_HANDLE_VALUE)
{
return -1;
}
MessageBox(NULL,TEXT("create namepipe successful"),NULL,NULL);
fConnected = ConnectNamedPipe(hPipe, NULL) ? TRUE : (GetLastError() == ERROR_PIPE_CONNECTED);
if(fConnected==TRUE)
{
MessageBox(NULL,TEXT("connect the namedpipe client"),NULL,NULL);
else
{
CloseHandle(hPipe);
}
下面是传输 数据的线程，啊麻烦各位看看，哪里有错，谢谢～
DWORD WINAPI InstanceThread(LPVOID lpvParam)
// This routine is a thread processing function to read from and reply to a client
// via the open pipe connection passed from the main loop. Note this allows
// the main loop to continue executing, potentially creating more threads of
// of this procedure to run concurrently, depending on the number of incoming
// client connections.
{
#ifdef Debug_mode
MessageBox(NULL,_T("enter server thread"),NULL, NULL);
#endif
HANDLE hHeap = GetProcessHeap();
TCHAR* pchRequest = (TCHAR*)HeapAlloc(hHeap, HEAP_ZERO_MEMORY, BUFSIZE*sizeof(TCHAR));
TCHAR* pchReply = (TCHAR*)HeapAlloc(hHeap, HEAP_ZERO_MEMORY, BUFSIZE*sizeof(TCHAR));
DWORD cbBytesRead = 0, cbReplyBytes = 0, cbWritten = 0;
BOOL fSuccess = FALSE;
HANDLE hPipe = NULL;
// Do some extra error checking since the app will keep running even if this
// thread fails.
if (lpvParam == NULL)
{
// printf( "\nERROR - Pipe Server Failure:\n");
// printf( " InstanceThread got an unexpected NULL value in lpvParam.\n");
// printf( " InstanceThread exitting.\n");
if (pchReply != NULL) HeapFree(hHeap, HEAP_ZERO_MEMORY, pchReply);
if (pchRequest != NULL) HeapFree(hHeap,HEAP_ZERO_MEMORY, pchRequest);
return (DWORD)-1;
}
if (pchRequest == NULL)
{
//printf( "\nERROR - Pipe Server Failure:\n");
//printf( " InstanceThread got an unexpected NULL heap allocation.\n");
//printf( " InstanceThread exitting.\n");
if (pchReply != NULL) HeapFree(hHeap, 0, pchReply);
return (DWORD)-1;
}
if (pchReply == NULL)
{
//printf( "\nERROR - Pipe Server Failure:\n");
//printf( " InstanceThread got an unexpected NULL heap allocation.\n");
//printf( " InstanceThread exitting.\n");
if (pchRequest != NULL) HeapFree(hHeap, 0, pchRequest);
return (DWORD)-1;
}
// Print verbose messages. In production code, this should be for debugging only.
// printf("InstanceThread created, receiving and processing messages.\n");
hPipe = (HANDLE) lpvParam;
while (1)
{
// Read client requests from the pipe. This simplistic code only allows messages
// up to BUFSIZE characters in length.
fSuccess = ReadFile(
hPipe, // handle to pipe
pchRequest, // buffer to receive data
BUFSIZE*sizeof(TCHAR), // size of buffer
&cbBytesRead, // number of bytes read
NULL); // not overlapped I/O
if (!fSuccess || cbBytesRead == 0)
{
#ifdef Debug_mode
MessageBox(NULL,_T("readfile failed ，the client side might disconnected"),NULL, NULL);
#endif
if (GetLastError() == ERROR_BROKEN_PIPE)
{
_tprintf(TEXT("InstanceThread: client disconnected.\n"), GetLastError());
}
else
{
_tprintf(TEXT("InstanceThread ReadFile failed, GLE=%d.\n"), GetLastError());
}
break;
}
// GetAnswerToRequest(pchRequest, pchReply, &cbReplyBytes);
fSuccess = WriteFile(
hPipe, // handle to pipe
pchReply, // buffer to write from
cbReplyBytes, // number of bytes to write
&cbWritten, // number of bytes written
NULL); // not overlapped I/O
if (!fSuccess || cbReplyBytes != cbWritten)
{
#ifdef Debug_mode
MessageBox(NULL,_T("writefile failed "),NULL, NULL);
#endif
_tprintf(TEXT("InstanceThread WriteFile failed, GLE=%d.\n"), GetLastError());
break;
}
}
FlushFileBuffers(hPipe);
DisconnectNamedPipe(hPipe);
CloseHandle(hPipe);
HeapFree(hHeap, 0, pchRequest);
HeapFree(hHeap, 0, pchReply);
printf("InstanceThread exitting.\n");
return 1;
}
[解决办法]
你要自己调试代码，错误很明显，参数错了。
