GameCult/CultLib
Watch
9
0
Fork
You've already forked CultLib
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

GameCult.Networking: the listener refusal local no longer shadows the datagram length

Browse source 
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-09-29 19:42:45 +02:00
commit 9dba01082c
1 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/GameCult.Networking/CultNetTransport.cs
View file

@ -2637,23 +2637,23 @@ namespace GameCult.Networking
return true;
}
CultNetRudpReceiveResult? received;
CultNetRudpReceiveResult? outcome;
CultNetRudpPacket? acknowledgement = null;
lock (existingPeer.SessionGate)
{
try
{
received = existingPeer.Session.Receive(packet, NowMs());
outcome = existingPeer.Session.Receive(packet, NowMs());
}
catch (InvalidOperationException)
{
// Receive has already recorded the packet's reliable sequence, so the session
// cannot be kept: a retransmit would be acknowledged and the frame silently lost.
_stats.PacketsDropped++;
received = null;
outcome = null;
}
if (received == null)
if (outcome == null)
{
try
{
@ -2666,14 +2666,14 @@ namespace GameCult.Networking
}
else
{
if (received.Reply != null)
SendPacket(existingPeer.RemoteEndPoint, received.Reply);
SendPackets(existingPeer, received.ReadyToSend);
if (outcome.Reply != null)
SendPacket(existingPeer.RemoteEndPoint, outcome.Reply);
SendPackets(existingPeer, outcome.ReadyToSend);
if (packet.PacketType == CultNetRudpPacketType.Data)
acknowledgement = existingPeer.Session.CreateAckForReceived(packet.Sequence);
}
}
if (received == null)
if (outcome == null)
{
existingPeer.DisconnectReason = CultNetRudpSession.RefusedPacketReason;
_peers.Remove(peerKey);
@ -2681,7 +2681,7 @@ namespace GameCult.Networking
return true;
}
var result = received;
var result = outcome;
if (result.Disconnected)
{
existingPeer.DisconnectReason = result.DisconnectReason;