davejansen/lidgren-network-gen3
1
0
Fork 0
mirror of https://github.com/lidgren/lidgren-network-gen3.git synced 2026-05-17 07:36:32 +09:00
Code Issues Releases Activity

UseMessageCoalescing fixed :-)

Browse Source
This commit is contained in:
lidgren
2010-06-09 11:48:35 +00:00
parent 10ae62c4cd
commit ce57b96cf5
1 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
Lidgren.Network/NetConnection.cs
View File

@@ -205,23 +205,26 @@ namespace Lidgren.Network
int msgPayloadLength = msg.LengthBytes; int msgPayloadLength = msg.LengthBytes;
msg.m_lastSentTime = now; msg.m_lastSentTime = now;
if (!useCoalescing || (ptr > 0 && (ptr + NetPeer.kMaxPacketHeaderSize + msgPayloadLength) > mtu)) if (ptr > 0)
{ {
// send packet and start new packet if (!useCoalescing || ((ptr + NetPeer.kMaxPacketHeaderSize + msgPayloadLength) > mtu))
bool connectionReset;
m_owner.SendPacket(ptr, m_remoteEndpoint, numIncludedMessages, out connectionReset);
if (connectionReset)
{ {
// ouch! can't sent any more; lets disconnect // send packet and start new packet
Disconnect(NetConstants.ConnResetMessage); bool connectionReset;
ptr = 0; m_owner.SendPacket(ptr, m_remoteEndpoint, numIncludedMessages, out connectionReset);
if (connectionReset)
{
// ouch! can't sent any more; lets disconnect
Disconnect(NetConstants.ConnResetMessage);
ptr = 0;
numIncludedMessages = 0;
break;
}
m_statistics.PacketSent(ptr, numIncludedMessages);
numIncludedMessages = 0; numIncludedMessages = 0;
break; m_throttleDebt += ptr;
ptr = 0;
} }
m_statistics.PacketSent(ptr, numIncludedMessages);
numIncludedMessages = 0;
m_throttleDebt += ptr;
ptr = 0;
} }
// //