c++ - GetQueuedCompletionStatus 过早退出(或者我认为)

Question

让我先概括一下。我通过三个端口接收数据。我有一个套接字、一个完成端口和一个工作线程。我调用 WSARecv，工作线程进程调用 GetQueuedCompletionStatus，然后是我的解析例程 ReadMsgs。有时会发生调用 ReadMsgs 时缓冲区未更改的情况，并且在 ReadMsgs 处理缓冲区时更新缓冲区。 GetQueuedCompletionStatus 返回的已处理字节数对于发生更新时是​​正确的。

有谁知道为什么会发生这种情况以及我做错了什么。让我向您展示看起来最相关的代码。如果您需要查看更多代码，请具体说明。我的基本套接字类如下所示(我省略了在我看来无关紧要的细节。我还省略了所有错误检查。)

class Socket_Base : public OVERLAPPED
{
public:
Socket_Base()
{
    // Initialize base OVERLAPPED object
    Internal = 0;
    InternalHigh = 0;
    Offset = 0;
    OffsetHigh = 0;
    hEvent = WSACreateEvent();

    // Initialize addr structure
    ZeroMemory( &addr, sizeof(struct sockaddr_in));

    // Create the completion port
    hCP = CreateIoCompletionPort( INVALID_HANDLE_VALUE, NULL, 0, 1);

    // Create the worker thread and bind it to the callback function and the completion port
    hThread = (HANDLE)_beginthreadex( NULL, 0, Callback_Socket, hCP, 0, NULL);

    // Create the socket
    Sock = WSASocket( AF_INET, SOCK_STREAM, IPPROTO_TCP, NULL, 0, WSA_FLAG_OVERLAPPED);

    // Bind the socket to the completion port
    CreateIoCompletionPort( (HANDLE)Sock, hCP, 0, 0);
}
void Connect() { WSAConnect( Sock, (SOCKADDR*)(&addr), sizeof(addr), NULL, NULL, NULL, NULL);}
void StartRecv()
{
    DWORD Flags = 0;
    DWORD numBytes = 0;
    if (WSARecv( Sock, &wsaBuf, 1, &numBytes, &Flags, (OVERLAPPED*)this, NULL) == 0) ReadMsgs( numBytes);
}
int ReadMsgs( int NumBytes);

protected:
    virtual ~Socket_Base() {}
    virtual void ProcessMsg() = 0;
    struct sockaddr_in addr;
    SOCKET Sock;
    HANDLE hCP;
    WSABUF wsaBuf;
    HANDLE hThread;
    char *readBuf;
    int bufsize;
};

每个端口都有自己的派生套接字类，通过端口号和虚拟 ProcessMsg 函数(在解析每条消息时由 ReadMsgs 调用)来区分。这是一个这样的类:

class Socket_Admin : public Socket_Base
{
public:
static const int bufcap = 1024;
Socket_Admin::Socket_Admin() : Socket_Base()
{
    // Buffer
    readBuf = new char[ bufcap];

    // The socket
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    addr.sin_port = htons(9300);
    wsaBuf.buf = readBuf;
    wsaBuf.len = bufcap;
}
~Socket_Admin();
void ProcessMsg();
};

工作线程进程为

unsigned int Callback_Socket( void *lpParameter)
{
    HANDLE hCP = (HANDLE)lpParameter;
    DWORD NumBytes = 0;
    ULONGLONG CompletionKey;
    WSAOVERLAPPED *pOverlapped;
    while (GetQueuedCompletionStatus( hCP, &NumBytes, &CompletionKey, &pOverlapped, INFINITE) && CompletionKey == 0)
    {
        Socket_Base *pTCP = (Socket_Base*)pOverlapped;
        if (NumBytes > 0) pTCP->ReadMsgs( NumBytes);
        NumBytes = 0;
    }
    return 0;
}

还有一件事我应该解释一下。 ReadMsgs 就地进行解析。服务器使用最后的换行符分隔消息，并使用逗号分隔消息中的字段。 ReadMsgs 在找到它们时用空字符替换逗号和换行符，并在指向缓冲区中位置的单独指针数组中记录每个字段的开始位置。现在，当 ReadMsgs 到达最后填充的缓冲区区域的末尾时，它有时会发现一条不完整的消息。这被复制到缓冲区的开头，期望下一次读取完成消息，并相应地修改 wsaBuf。因此 ReadMsgs 的结尾看起来像这样:

wsaBuf.buf = pchar;
wsaBuf.len = remsize;
StartRecv();

其中 pchar 指向部分消息之外的字符，remsize 是剩余缓冲区的大小。

我从详细的服务器日志中知道哪些消息已发送到我的应用程序。将定界符替换为空字符还可以轻松查看缓冲区的哪一部分已被处理。通过将缓冲区保存到文件并检查它，我可以知道它是在调用 ReadMsgs 之后更新的。此外，通过上面代码中未显示的日志消息，我知道在这些情况下 ReadMsgs 是由工作线程调用的。它不会每次都发生，但确实会发生。

如果有人能告诉我我的错误是什么，我将不胜感激。

Answer 1

我可能有一个答案。我在 StartRecv 和 Callback_Socket 中都调用了 ReadMsgs。在StartRecv中，当WSARecv返回0时，我调用了ReadMsgs，表示WSARecv完成了传输。我在想，如果传输在 WSARecv 中完成，GetQueuedCompletion 状态就不会涉及。但是，如果 GetQueuedCompletionStatus 确实返回以响应已完成的读取，那么我将重复调用 ReadMsgs 来解释我收集的记录数据，就像我之前的假设一样。

我已经删除了 StartRecv 中对 ReadMsgs 的调用。代码现在可以正常工作了。

感谢给我投反对票的先生。这向我表明，我所描述的行为以前没有被观察到，因此极不可能发生。这让我想到了一个新的方向。有时，更有经验的货车司机的一声咕哝就能说明一切。