c# - 为什么 AutoResetEvent 不工作 BeginSend？

Question

我编写了一个服务器端应用程序，它使用BeginSend()和管理许多客户端EndSend()

在过去的几个小时里，我一直在努力确保不会BeginSend()为同一个客户拨打后续电话。

似乎以下代码片段没有达到我的目标，并且SendAsyncData在第一次完成之前不会阻止第二次调用。

我的错误是什么？

struct SendBuffer
{
    public const int BUFFER_SIZE = 1024 * 128;
    public byte[] BUFFER;
    public int sent;

    public SendBuffer(byte[] data)
    {
        BUFFER = new byte[data.Length];
        Buffer.BlockCopy(data, 0, BUFFER, 0, data.Length);
        sent = 0;
    }

    public void Dispose()
    {
        BUFFER = null;
        sent = 0;
    }
}

private void SendAsyncDataWithHeader(byte[] data
{
    int toSend;
    byte[] dataWithHeader = Combine(BitConverter.GetBytes(data.Length), data);

    SendAutoResetEvent.WaitOne();
    sendBuffer = new SendBuffer(dataWithHeader);

    if (sendBuffer.BUFFER.Length - sendBuffer.sent > SendBuffer.BUFFER_SIZE)
        toSend = SendBuffer.BUFFER_SIZE;
    else
        toSend = sendBuffer.BUFFER.Length - sendBuffer.sent;

    try
    {
        socket.BeginSend(sendBuffer.BUFFER, 0, toSend, SocketFlags.None, sendCallback, null);
    }
    catch (SocketException se)
    {
        switch (se.SocketErrorCode)
        {
            case SocketError.ConnectionAborted:
            case SocketError.ConnectionReset:
                if (Disconnected != null)
                {
                    Disconnected(this);
                }
                break;
        }
    }
    catch (ObjectDisposedException)
    {
    }
    catch (NullReferenceException ex)
    {
    }
    catch (Exception ex)
    {
        Server.logger.Error(ex);
        Disconnected(this);
    }
}

void sendCallback(IAsyncResult ar)
{
    int bytesSent;
    try
    {
        bytesSent = socket.EndSend(ar);
        if (bytesSent == 0)
        {
            if (Disconnected != null)
            {
                Disconnected(this);
                return;
            }
        }
        sendBuffer.sent += bytesSent;
        if (sendBuffer.sent == sendBuffer.BUFFER.Length)
        {
            sendBuffer.Dispose();

            SendAutoResetEvent.Set();
            Server.logger.Info("set {0}", userName);
        }
        else
        {
            int toSend;
            if (sendBuffer.BUFFER.Length - sendBuffer.sent > SendBuffer.BUFFER_SIZE)
                toSend = SendBuffer.BUFFER_SIZE;
            else
                toSend = sendBuffer.BUFFER.Length - sendBuffer.sent;

            socket.BeginSend(sendBuffer.BUFFER, sendBuffer.sent, toSend, SocketFlags.None, sendCallback, null);
        }
    }
    catch (SocketException se)
    {
        switch (se.SocketErrorCode)
        {
            case SocketError.ConnectionAborted:
            case SocketError.ConnectionReset:
                if (Disconnected != null)
                {
                    Disconnected(this);
                    return;
                }
                break;
        }
    }
    catch (ObjectDisposedException ex)
    {
    }
    catch (Exception ex)
    {
        Server.logger.Error(ex);
        Disconnected(this);
    }
}