GetQueuedCompletionStatus时不能从IOCP离队IO线程是否最初发布的IO在R

2019-07-31 02:49发布

我的应用程序停止切换到我花时间来进行调试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年,并发出一个异步Accpet头,然后读阻塞管道。 我已经测试这个程序在Windows 7,8,XP,2003,2008年, “远程登录127.0.0.1 1999” 后, “出队的IO \ n”,将印上除了Windows 8的控制台。

问题的关键是其最初发布的异步操作不得ReadFile的阻塞或GetQueuedCompletionStatus时绝不会出列IO直到ReadFile的在Windows 8返回线程。

我还用“scanf函数”测试,而不是阅读管,结果是因为“scanf函数”同样会调用ReadFile的最终读取控制台。 我不知道,如果ReadFile的是唯一受影响的功能或可能有其他的功能。

我能想到的使用专用线程发出异步操作的,并与专用线程所有的业务逻辑通信以执行接受/发送/ recv的。 但是,额外的层意味着额外的开销,有没有什么办法来达到同样的性能,在Windows 8早期版本的Windows?

Answer 1:

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

这是一个bug,官方MS的反应是:“我们已经通过这基本OS的球队,他们会认为这对于未来的更新。我解决这个推迟。”

注:我跑的Windows 8今日(2013年9月12日)在准备完全补丁版本的Windows测试8.1本测试,发现这个问题似乎被固定在Windows 8现在。 我不知道当它是固定的。



文章来源: GetQueuedCompletionStatus can't dequeue IO from IOCP if the thread which originally issued the IO is blocking in ReadFile under windows 8