space-wizards/RobustToolbox
1
0
Fork 0
mirror of https://github.com/space-wizards/RobustToolbox.git synced 2026-02-15 03:30:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix latency simulation.

Browse Source
This commit is contained in:
Pieter-Jan Briers
2020-06-25 02:16:43 +02:00
parent e693d3ded7
commit f71f2821d1
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Lidgren.Network/NetPeer.LatencySimulation.cs
View File

@@ -41,6 +41,7 @@ namespace Lidgren.Network
private class DelayedPacket
{
public byte[] Data;
public int Length;
public double DelayedUntil;
public NetEndPoint Target;
}
@@ -91,9 +92,10 @@ namespace Lidgren.Network
DelayedPacket p = new DelayedPacket();
p.Target = target;
p.Data = ArrayPool<byte>.Shared.Rent(numBytes);
//Buffer.BlockCopy(m_sendBuffer, 0, p.Data, 0, numBytes);
new Memory<byte>(m_sendBuffer, 0, numBytes)
.CopyTo(p.Data);
p.Length = numBytes;
Buffer.BlockCopy(m_sendBuffer, 0, p.Data, 0, numBytes);
//new Memory<byte>(m_sendBuffer, 0, numBytes)
// .CopyTo(p.Data);
p.DelayedUntil = NetTime.Now + delay;
m_delayedPackets.Add(p);
@@ -116,7 +118,7 @@ namespace Lidgren.Network
{
if (now > p.DelayedUntil)
{
ActuallySendPacket(new Span<byte>(p.Data), p.Data.Length, p.Target, out connectionReset);
ActuallySendPacket(p.Data, p.Length, p.Target, out connectionReset);
m_delayedPackets.Remove(p);
ArrayPool<byte>.Shared.Return(p.Data);
goto RestartDelaySending;
@@ -131,7 +133,7 @@ namespace Lidgren.Network
bool connectionReset;
foreach (DelayedPacket p in m_delayedPackets)
{
ActuallySendPacket(new Span<byte>(p.Data), p.Data.Length, p.Target, out connectionReset);
ActuallySendPacket(p.Data, p.Length, p.Target, out connectionReset);
ArrayPool<byte>.Shared.Return(p.Data);
}
m_delayedPackets.Clear();