GetQueuedCompletionStatus не может деактивировать IO из IOCP, если поток, который первоначально выдал IO, блокирует ReadFile под окнами 8

Мое приложение перестает работать после переключения на окна 8. Я трачу часы на отладку проблемы, выяснил, что IOCP ведет себя по-разному между окнами 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, после "telnet 127.0.0.1 1999", "dequeued IO\n" будет напечатан на консоли, кроме Windows 8.

Точка - это поток, который изначально выдал операцию async, не должен блокироваться в ReadFile или GetQueuedCompletionStatus никогда не удалит этот IO, пока ReadFile не вернется в Windows 8.

Я также тестировал, используя "scanf" вместо чтения канала, результаты такие же, поскольку "scanf" в конечном итоге вызовет ReadFile для чтения консоли. Я не знаю, является ли функция ReadFile единственной функцией, или могут быть другие функции.

То, что я могу думать, это использовать выделенный поток для выдачи асинхронных операций, и вся бизнес-логика взаимодействует с этим выделенным потоком для выполнения accept/send/recv. Но дополнительный уровень означает дополнительные накладные расходы, есть ли способ достичь той же производительности, что и предыдущие версии окон в Windows 8?

Ответ 1