c++ - 如果最初发出 IO 的线程在 Windows 8 下的 ReadFile 中阻塞,则 GetQueuedCompletionStatus 无法从 IOCP 出列 IO

标签 c++ sockets windows-8 winsock iocp

切换到 Windows 8 后,我的应用程序停止工作。我花了几个小时调试问题,发现 IOCP 的行为在 Windows 8 和以前的版本之间有所不同。我提取了必要的代码来演示和重现问题。

SOCKET sListen;

DWORD WINAPI WorkerProc(LPVOID lpParam)
{
    ULONG_PTR dwKey;
    DWORD dwTrans;
    LPOVERLAPPED lpol;
    while(true)
    {
        GetQueuedCompletionStatus((HANDLE)lpParam, &dwTrans, &dwKey, (LPOVERLAPPED*)&lpol, WSA_INFINITE);
        printf("dequeued an IO\n");
    }
}
DWORD WINAPI StartProc(LPVOID lpParam)
{
    WSADATA WsaData;
    if (WSAStartup(0x202,&WsaData)!=0) return 1;
    sListen = WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);
    SOCKADDR_IN si;
    ZeroMemory(&si,sizeof(si));
    si.sin_family = AF_INET;
    si.sin_port = ntohs(1999);
    si.sin_addr.S_un.S_addr = INADDR_ANY;
    if(bind(sListen, (sockaddr*)&si, sizeof(si)) == SOCKET_ERROR) return 1;
    listen(sListen, SOMAXCONN);
    HANDLE hCompletion = CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0, 0);
    CreateIoCompletionPort((HANDLE)sListen, hCompletion, (DWORD)0, 0);
    CreateThread(NULL, 0, WorkerProc, hCompletion, 0, NULL);
    return 0;
}
DWORD WINAPI AcceptProc(LPVOID lpParam)
{
    DWORD dwBytes;
    LPOVERLAPPED pol=(LPOVERLAPPED)malloc(sizeof(OVERLAPPED));
    ZeroMemory(pol,sizeof(OVERLAPPED));
    SOCKET sClient = WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);
    BOOL b = AcceptEx(sListen, 
        sClient,
        malloc ((sizeof(sockaddr_in) + 16) * 2), 
        0,
        sizeof(sockaddr_in) + 16, 
        sizeof(sockaddr_in) + 16, 
        &dwBytes, 
        pol);
    if(!b && WSAGetLastError() != WSA_IO_PENDING)   return 1;
    HANDLE hPipe=CreateNamedPipeA("\\\\.\\pipe\\testpipe",PIPE_ACCESS_DUPLEX,PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT,PIPE_UNLIMITED_INSTANCES,4096,4096,999999999,NULL);
    BYTE chBuf[1024]; 
    DWORD  cbRead; 
    CreateFileA("\\\\.\\pipe\\testpipe", GENERIC_READ |GENERIC_WRITE,  0,NULL, OPEN_EXISTING, 0, NULL);
    ReadFile(hPipe,chBuf,1024, &cbRead,NULL);
    return 0;
}

int main()
{
    printf ("Starting server on port 1999...");
    WaitForSingleObject(CreateThread(NULL, 0, StartProc, NULL, 0, NULL),INFINITE);
    CreateThread(NULL, 0,AcceptProc, NULL, 0, NULL);
    printf ("done\n");
    Sleep(10000000);
    return 0;
}

这个程序在端口 1999 上监听并发出一个 async accpet 然后读取阻塞管道。我已经在 Windows 7、8、XP、2003、2008 上测试了这个程序,在“telnet 127.0.0.1 1999”之后,“dequeued an IO\n”将打印在除 Windows 8 之外的控制台上。

关键是最初发出异步操作的线程不能在 ReadFile 中阻塞,否则 GetQueuedCompletionStatus 永远不会使该 IO 出队,直到 ReadFile 在 Windows 8 上返回。

我还使用“scanf”而不是读取管道进行了测试,结果是相同的,因为“scanf”最终会调用 ReadFile 来读取控制台。我不知道 ReadFile 是唯一受影响的功能还是可能有其他功能。

我能想到的是使用专用线程来发出异步操作,所有业务逻辑都与该专用线程通信以执行接受/发送/接收。但是额外的层意味着额外的开销,有什么方法可以在 windows 8 上实现与以前版本的 windows 相同的性能?

最佳答案

https://connect.microsoft.com/WindowsServer/feedback/details/760161/breaking-change-to-acceptex-and-iocp-in-server-2012-and-windows-8

这是一个错误,MS 的官方回应是 “我们已将此信息传递给基础操作系统团队,他们将考虑在未来更新此问题。我正在解决这个推迟的问题。”

注意:我今天(2013 年 9 月 12 日)在完全修补的 Windows 8 版本上运行了此测试,以准备测试 Windows 8.1,发现问题现在似乎已在 Windows 8 上得到修复。我不知道它什么时候修复的。

关于c++ - 如果最初发出 IO 的线程在 Windows 8 下的 ReadFile 中阻塞,则 GetQueuedCompletionStatus 无法从 IOCP 出列 IO,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/12047960/

相关文章:

c++ - 从实际参数捕获函数参数类型

sockets - 为什么在 SSL 程序(客户端/服务器 openssl)之后 Wireshark 向我显示协议(protocol) X11 和 TCP 而不是 SSL 或 TLS?

xaml - 在 Metro 风格应用程序中以编程方式更改按钮的背景图像

c++ - C++中将数字转换为字母

c++ - 删除对模板函数的永不运行调用,在运行时获取分配错误

c++ - 将按钮界面添加到我的控制台应用程序

java - 保持 java 套接字打开 - 如何检查新数据是否可用?

java - 如何在不同端口上运行的特定 Netty 客户端实例上发送数据

c# - Windows 8 应用程序和访问文件系统

delphi - 使用 Windows Media Player ActiveX 在 delphi 中播放 DVD 视频