0

我目前正在用托管 C++ 编写一个 winsock 服务器端套接字。创建 LPWSAOVERLAPPED 对象并将其传递给 WSASend 函数后，我看不到在操作完成非阻塞时将其删除的位置（WSASend 返回 SOCKET_ERROR 并且 WSAGetLastError() 返回 WSA_IO_PENDING）。我当前的解决方案是创建一个 System::Threading::WaitHandle，获取指向等待句柄的不安全指针并将其传递给 LPWSAOVERLAPPED 对象下的 hEvent。但是，这会导致不必要的对象创建，因为我并不真正关心发送操作何时完成。另一方面，我需要一个 LPWSAOVERLAPPED 对象以使操作完全无阻塞。有没有人有更好的解决方案来解决这个问题？这是我当前的代码：

void Connectivity::ConnectionInformation::SendData(unsigned char data[], const int length)
{
    if (isClosed || sendError)
        return;

    Monitor::Enter(this->sendSyncRoot);
    try
    {
        LPWSAOVERLAPPED overlapped = OverlappedObjectPool::GetOverlapped();
        WaitHandle ^ handle = gcnew ManualResetEvent(false);
        IntPtr handlePointer = handle->SafeWaitHandle->DangerousGetHandle();

        sendInfo->buf = (char*)data;
        sendInfo->len = length;

        overlapped->Internal = 0;
        overlapped->InternalHigh = 0;
        overlapped->Offset = 0;
        overlapped->OffsetHigh = 0;
        overlapped->Pointer = 0;
        overlapped->hEvent = (void*)handlePointer;                      //Set pointer

        if (WSASend(connection, sendInfo, 1, NULL, 0, overlapped, NULL) == SOCKET_ERROR)
        {
            if (WSAGetLastError() == WSA_IO_PENDING)
            {
                ThreadPool::UnsafeRegisterWaitForSingleObject(handle, sentCallback, (IntPtr)((void*)overlapped), -1, true);
            }
            else
            {
                this->sendError = true;
                //The send error bool makes sure that the close function doesn't get called
                //during packet processing which could lead to a lot of null reffernce exceptions.
                OverlappedObjectPool::GiveObject(overlapped);
            }
        }
        else
        {
            handle->Close();
            sentData((IntPtr)((void*)overlapped), false);
        }
    }
    finally
    {
        Monitor::Exit(this->sendSyncRoot);
    }
}
4

1 回答 1

1

对于异步 I/O，通过调用完成例程或将 IOCP 完成消息排队到 IOCP 完成队列来通知完成。在这两种情况下，应该注意 OVL 结构的生命周期至少应该是整个异步操作的生命周期，但如果方便的话可以更长:)

在完成例程的情况下，OVL 中未使用的 hEvent 参数可用于传输指向“IOrequest”类实例的指针，该类实例包含数据缓冲区、WSABUF 数组和 OVL 结构作为成员（当然是指向已为其发出 I/O 的套接字对象的指针）。OVL 指针作为参数提供给完成例程，因此可以检索 hEvent 并将其转换为类类型，因此检索完整的类实例 - OVL、数据缓冲区等。当数据已被处理时，（或立即在WSASend 的完成例程），并且这个 IOrequest 最终被销毁（或重新池化），OVL 将随之而来。这听起来有点乱伦，但效果很好，不需要任何讨厌的宏或其他技巧。

类似的方法可以用于完整的 IOCP，或者作为 lpCompletionKey 'spare' 参数传递的 OVL。

哦 - 你确实关心操作是否完成 - 你至少需要检查错误。

于 2012-12-28T00:46:35.123 回答