我正在创建一个命名管道并使用一个函数来执行此操作。这是代码:
HANDLE tProviderPipe(INVALID_HANDLE_VALUE);
SECURITY_ATTRIBUTES tSecurityAttributes;
tSecurityAttributes.nLength = sizeof(tSecurityAttributes);
tSecurityAttributes.bInheritHandle = FALSE;
tSecurityAttributes.lpSecurityDescriptor = NULL;
while (1)
{
tProviderPipe = ::CreateNamedPipe(L"\\\\.\\pipe\\MyPipe",
PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT,
1,
128,
128,
5000,
&tSecurityAttributes);
if (INVALID_HANDLE_VALUE != tProviderPipe)
{
DWORD lLastStatus(GetLastError());
OHTRACE(Trace::eTAlways, L"Pipe Status: " << (unsigned int)lLastStatus);
break;
}
if (ERROR_PIPE_BUSY != GetLastError())
{
DWORD lLastStatus(GetLastError());
OHTRACE(Trace::eTAlways, L"Pipe Status: " << (unsigned int)lLastStatus);
break;
}
if (!WaitNamedPipe(L"MyPipe", 20000))
{
DWORD lLastStatus(GetLastError());
OHTRACE(Trace::eTAlways, L"WPipe Status: " << (unsigned int)lLastStatus);
}
当调用此函数时,管道创建失败,错误代码为231(即管道忙)。我不明白为什么管道繁忙以及创建管道的正确方法是什么?在开始创建管道之前,应该检查和预检查的内容是什么?
你展示的代码都是错的。
这个检查:
if (INVALID_HANDLE_VALUE != tProviderPipe)
需要使用==
而不是!=
。如果CreateNamedPipe()
成功,你的代码就会失败。
这个检查:
if (ERROR_PIPE_BUSY != GetLastError())
需要删除。首先,它在错误的地方。 GetLastError()
仅在CreateNamedPipe()
失败时有效。在使==
修正之后,GetLastError()
在ERROR_PIPE_BUSY
成功之后永远不会是CreateNamedPipe()
(或任何其他有意义的值)。其次,如果你将它移动到正在检查if
的tProviderPipe
,那么它就变得多余,因为它记录了已经记录在那里的相同信息。
这个检查:
if (!WaitNamedPipe(L"MyPipe", 20000))
还需要删除。首先,您传递的是错误的管道名称格式。其次,它用于命名管道客户端在调用CreateFile()
之前调用(或者如果CreateFile()
使用ERROR_PIPE_BUSY
失败)。不要在命名管道服务器中调用它。你的意思是调用ConnectNamedPipe()
,它等待客户端连接到你正在创建的服务器管道。
请查看MSDN上的named pipe server examples。
尝试更像这样的东西:
HANDLE tProviderPipe = INVALID_HANDLE_VALUE;
SECURITY_ATTRIBUTES tSecurityAttributes;
OVERLAPPED ov = {};
DWORD lLastStatus;
ov.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
if (!ov.hEvent) {
lLastStatus = GetLastError();
OHTRACE(Trace::eTAlways, L"Pipe Event Create Error: " << (UINT)lLastStatus);
return;
}
tSecurityAttributes.nLength = sizeof(tSecurityAttributes);
tSecurityAttributes.bInheritHandle = FALSE;
tSecurityAttributes.lpSecurityDescriptor = NULL;
while (1) {
if (INVALID_HANDLE_VALUE == tProviderPipe) {
tProviderPipe = ::CreateNamedPipe(L"\\\\.\\pipe\\MyPipe", PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED, PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT, 1, 128, 128, 5000, &tSecurityAttributes);
if (INVALID_HANDLE_VALUE == tProviderPipe) {
lLastStatus = GetLastError();
OHTRACE(Trace::eTAlways, L"Pipe Create Error: " << (UINT)lLastStatus);
break;
}
}
if (!ConnectNamedPipe(tProviderPipe, &ov)) {
lLastStatus = GetLastError();
if (ERROR_IO_PENDING == lLastStatus) {
if (WaitForSingleObject(ov.hEvent, 20000) != WAIT_OBJECT_0) {
OHTRACE(Trace::eTAlways, L"Pipe not connected in 20 seconds");
break;
}
}
else if (ERROR_PIPE_CONNECTED != lLastStatus) {
OHTRACE(Trace::eTAlways, L"Pipe Connect Error: " << (UINT)lLastStatus);
continue;
}
}
// use tProviderPipe as needed ...
DisconnectNamedPipe(tProviderPipe);
}
if (INVALID_HANDLE_VALUE != tProviderPipe) {
CloseHandle(tProviderPipe);
}
CloseHandle(ov.hEvent);