diff --git a/Lidgren.Network/NetReliableSenderChannel.cs b/Lidgren.Network/NetReliableSenderChannel.cs index 375f1d2..ade2e9d 100644 --- a/Lidgren.Network/NetReliableSenderChannel.cs +++ b/Lidgren.Network/NetReliableSenderChannel.cs @@ -52,10 +52,7 @@ namespace Lidgren.Network internal override NetSendResult Enqueue(NetOutgoingMessage message) { m_queuedSends.Enqueue(message); - - int queueLen = m_queuedSends.Count; - int left = m_windowSize - ((m_sendStart + NetConstants.NumSequenceNumbers) - m_windowStart) % NetConstants.NumSequenceNumbers; - if (queueLen <= left) + if (m_queuedSends.Count <= GetAllowedSends()) return NetSendResult.Sent; return NetSendResult.Queued; } diff --git a/Lidgren.Network/NetUnreliableSenderChannel.cs b/Lidgren.Network/NetUnreliableSenderChannel.cs index 29a88ab..f1553af 100644 --- a/Lidgren.Network/NetUnreliableSenderChannel.cs +++ b/Lidgren.Network/NetUnreliableSenderChannel.cs @@ -45,7 +45,7 @@ namespace Lidgren.Network internal override NetSendResult Enqueue(NetOutgoingMessage message) { int queueLen = m_queuedSends.Count + 1; - int left = m_windowSize - ((m_sendStart + NetConstants.NumSequenceNumbers) - m_windowStart) % NetConstants.NumSequenceNumbers; + int left = GetAllowedSends(); if (queueLen > left) return NetSendResult.Dropped;