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

Slight modifications to default resend values

Browse Source 
Don't respond to ExpandMTUSuccess if AutoExpandMTU is disabled
Locking handshakes collection in Deny() for consistency
This commit is contained in:
lidgren
2014-07-31 12:20:53 +00:00
parent 2e9cc2bff0
commit 85a3b28bbf
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Lidgren.Network/NetConnection.Handshake.cs
View File

@@ -263,7 +263,8 @@ namespace Lidgren.Network
SendDisconnect(reason, false); SendDisconnect(reason, false);
// remove from handshakes // remove from handshakes
m_peer.m_handshakes.Remove(m_remoteEndPoint); // TODO: make this more thread safe? we're on user thread lock (m_peer.m_handshakes)
m_peer.m_handshakes.Remove(m_remoteEndPoint);
} }
internal void ReceivedHandshake(double now, NetMessageType tp, int ptr, int payloadLength) internal void ReceivedHandshake(double now, NetMessageType tp, int ptr, int payloadLength)

7
Lidgren.Network/NetConnection.cs
View File

@@ -75,7 +75,7 @@ namespace Lidgren.Network
float avgRtt = m_averageRoundtripTime; float avgRtt = m_averageRoundtripTime;
if (avgRtt <= 0) if (avgRtt <= 0)
avgRtt = 0.1f; // "default" resend is based on 100 ms roundtrip time avgRtt = 0.1f; // "default" resend is based on 100 ms roundtrip time
return 0.02f + (avgRtt * 2.0f); // 20 ms + double rtt return 0.025f + (avgRtt * 2.1f); // 25 ms + double rtt
} }
internal NetConnection(NetPeer peer, IPEndPoint remoteEndPoint) internal NetConnection(NetPeer peer, IPEndPoint remoteEndPoint)
@@ -429,6 +429,11 @@ namespace Lidgren.Network
SendMTUSuccess(payloadLength); SendMTUSuccess(payloadLength);
break; break;
case NetMessageType.ExpandMTUSuccess: case NetMessageType.ExpandMTUSuccess:
if (m_peer.Configuration.AutoExpandMTU == false)
{
m_peer.LogDebug("Received ExpandMTURequest altho AutoExpandMTU is turned off!");
break;
}
NetIncomingMessage emsg = m_peer.SetupReadHelperMessage(ptr, payloadLength); NetIncomingMessage emsg = m_peer.SetupReadHelperMessage(ptr, payloadLength);
int size = emsg.ReadInt32(); int size = emsg.ReadInt32();
HandleExpandMTUSuccess(now, size); HandleExpandMTUSuccess(now, size);