Winsock RIO:RIOSReceive立即返回，没有字节转移

我在使winsock RIO工作时遇到问题。似乎每次我发布RIOSReceive时，它都会立即返回，并传输0个字节，而我的对等方无法通过。

在发布RIOSReceive之后，我等待RIODequeCompletion，它会立即用numResults=1进行deques，但当我检查RIOSRESULT结构的bytesTransfer时，它是0。这告诉我没有正确设置这件事，但我找不到文档或示例来告诉我还应该做什么。

互联网上似乎很少有关于RIO的信息。我浏览了MSDN、Len Holgate with TheServerFramework、这个网站和两个GitHub RIO服务器。

RIOEcoServer和RIOServer_sm9在GitHub上，但我不能发布超过两个链接（这是我在这个网站上的第一个问题）。

这段代码只是为了让事情得到验证。它目前没有设置为使用sendCQ，不能很好地处理错误等。

以下是准备工作：

void serverRequestThread() {
//init buffers 
//register big buffers
recvBufferMain = rio.RIORegisterBuffer(pRecvBufferMain, bufferSize);
sendBufferMain = rio.RIORegisterBuffer(pSendBufferMain, bufferSize);
if (recvBufferMain == RIO_INVALID_BUFFERID) {
    cout << "RIO_INVALID_BUFFERID" << endl;
}
if (sendBufferMain == RIO_INVALID_BUFFERID) {
    cout << "RIO_INVALID_BUFFERID" << endl;
}
//create recv buffer slice
recvBuffer1.BufferId = recvBufferMain;
recvBuffer1.Offset = 0;
recvBuffer1.Length = 10000;
//create send buffer slice
sendBuffer1.BufferId = sendBufferMain;
sendBuffer1.Offset = 0;
sendBuffer1.Length = 10000;
//completion queue
recvCQ = rio.RIOCreateCompletionQueue(CQsize, NULL);
sendCQ = rio.RIOCreateCompletionQueue(CQsize, NULL);
if (recvCQ == RIO_INVALID_CQ) {
    cout << "RIO_INVALID_CQ" << endl;
}
if (sendCQ == RIO_INVALID_CQ) {
    cout << "RIO_INVALID_CQ" << endl;
}
//start a loop for newly accept'd socket
while (recvCQ != RIO_INVALID_CQ && sendCQ != RIO_INVALID_CQ) {
    //get accept'd socket
    struct sockaddr_in saClient;
    int iClientSize = sizeof(saClient);
    acceptSocket = accept(listenSocket, (SOCKADDR*)&saClient, &iClientSize);
    if (acceptSocket == INVALID_SOCKET) {
        cout << "Invalid socket" << endl;
        printError();
    }
    //register request queue
    requestQueue = rio.RIOCreateRequestQueue(
        acceptSocket,       //socket
        10,                 //max RECVs on queue
        1,                  //max recv buffers, set to 1
        10,                 //max outstanding sends
        1,                  //max send buffers, set to 1
        recvCQ,             //recv queue
        recvCQ,             //send queue
        pOperationContext   //socket context
        );
    if (requestQueue == RIO_INVALID_RQ) {
        cout << "RIO_INVALID_RQ" << endl;
        printError();
    }

我现在发布一个RIOEive:

    //start a loop to repin recv buffer for socket
    while (acceptSocket != INVALID_SOCKET) {
        //pin a recv buffer to wait on data
        recvSuccess = rio.RIOReceive(
            requestQueue,           //socketQueue
            &recvBuffer1,           //buffer slice
            1,                      //set to 1
            RIO_MSG_WAITALL,                        //flags
            0);                     //requestContext
        if (recvSuccess == false) {
            cout << "RECV ERROR!!!!!!!!n";
            printError();
        }
        //wait for recv to post in queue
        //std::this_thread::sleep_for(std::chrono::milliseconds(3000));

我一调用RIODequeCompletion，它就会返回1:

        numResults = 0;
        while (numResults == 0) numResults = rio.RIODequeueCompletion(recvCQ, recvArray, 10);
        if (numResults == RIO_CORRUPT_CQ) {
            cout << "RIO_CORRUPT_CQ" << endl;
        } else if (numResults == 0) {
            cout << "no messages on queuen";
        } else if (numResults > 0) {

但是当我检查RIORRESULT的字节传输时，它总是0:

            if (recvArray[0].BytesTransferred > 0) {
                //process results
                if (pRecvBufferMain[0] == 'G') {
                    //set respnose html
                    strcpy(pSendBufferMain, responseHTTP);
                    sendSuccess = rio.RIOSend(
                        requestQueue,   //socketQueue
                        &sendBuffer1,   //buffer slice
                        1,              //set to 1
                        0,              //flags
                        0);             //requestContext
                } else if (pRecvBufferMain[0] == 'P') {
                    //process post 

                } else {
                    //recv'd a bad message
                }
            } //end bytesTransferred if statement
            //reset everything and post another recv
        }//end response if statement
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }//end while loop for recv'ing
    std::this_thread::sleep_for(std::chrono::milliseconds(100));
}//end while loop for accept'ing
}// end function

正如我所说，我可能没有正确使用RIOReceive，和/或我没有设置所需的正确套接字选项（目前没有）。

我很感激你的帮助。