我在让 winsock RIO 工作时遇到问题。
似乎每次我发布 RIOReceive 时它都会立即返回并传输 0 个字节，而我的对等方无法通过消息。
发布 RIOReceive 后，我等待 RIODequeCompletion，它立即以 numResults = 1 出队，但是当我检查 RIORESULT 结构的 bytesTransferred 时，它是 0。这告诉我我没有正确设置这个东西，但我可以找不到告诉我我还应该做什么的文档或示例。
互联网上对 RIO 的报道似乎很少。我浏览了 MSDN 、 Len Holgate with TheServerFramework 、这个站点和两个 GitHub RIO 服务器。
RIOEchoServer 和 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();
}
我现在发布一个 RIOReceive:
//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 queue\n";
} else if (numResults > 0) {
但是当我检查 RIORESULT 的 bytesTransferred 时，它始终为 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，和/或我没有设置我需要的正确套接字选项(现在没有)。
我感谢任何帮助。
最佳答案
尝试删除 RIO_MSG_WAITALL 。可能存在一个错误，您只能获得关闭通知(字节 == 0)，而不是获得其中的数据完成。无论哪种方式，看看代码是否在没有标志的情况下工作都会很有趣。
我的示例服务器和测试是否适用于您的硬件？
关于c++ - Winsock RIO : RIOReceive returns immediately with no bytesTransferred，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/28353305/