A301/a301_mmo_game_server
2
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

fix : writer 전역으로 변경, pendingPings 락 프리 Cuncurrent로 변경

Browse Source
This commit is contained in:
qornwh1
2026-03-02 17:17:17 +09:00
parent 8fcdd3494e
commit 961973ff8b
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
ClientTester/EchoClientTester/EchoDummyService/DummyClients.cs
View File

@@ -1,3 +1,4 @@
using System.Collections.Concurrent;
using System.Diagnostics; using System.Diagnostics;
using ClientTester.Packet; using ClientTester.Packet;
using LiteNetLib; using LiteNetLib;
@@ -8,13 +9,14 @@ namespace ClientTester.EchoDummyService;
public class DummyClients public class DummyClients
{ {
public NetManager manager; private NetManager manager;
public EventBasedNetListener listener; private EventBasedNetListener listener;
private NetDataWriter? writer;
public NetPeer? peer; public NetPeer? peer;
public int clientId; public int clientId;
// seq → 송신 타임스탬프 (Stopwatch tick) // seq → 송신 타임스탬프 (Stopwatch tick)
private readonly Dictionary<int, long> pendingPings = new(); private ConcurrentDictionary<int, long> pendingPings = new();
private int seqNumber; private int seqNumber;
// 통계 // 통계
@@ -53,6 +55,7 @@ public class DummyClients
this.clientId = clientId; this.clientId = clientId;
listener = new EventBasedNetListener(); listener = new EventBasedNetListener();
manager = new NetManager(listener); manager = new NetManager(listener);
writer = new NetDataWriter();
listener.PeerConnectedEvent += netPeer => listener.PeerConnectedEvent += netPeer =>
{ {
@@ -65,16 +68,16 @@ public class DummyClients
short code = reader.GetShort(); short code = reader.GetShort();
short bodyLength = reader.GetShort(); short bodyLength = reader.GetShort();
string? msg = reader.GetString(); string? msg = reader.GetString();
long sentTick;
if (msg != null && msg.StartsWith("Echo seq:") && if (msg != null && msg.StartsWith("Echo seq:") &&
int.TryParse(msg.Substring("Echo seq:".Length), out int seq) && int.TryParse(msg.Substring("Echo seq:".Length), out int seq) &&
pendingPings.TryGetValue(seq, out long sentTick)) pendingPings.TryRemove(seq, out sentTick))
{ {
double rttMs = (Stopwatch.GetTimestamp() - sentTick) * 1000.0 / Stopwatch.Frequency; double rttMs = (Stopwatch.GetTimestamp() - sentTick) * 1000.0 / Stopwatch.Frequency;
LastRttMs = rttMs; LastRttMs = rttMs;
TotalRttMs += rttMs; TotalRttMs += rttMs;
RttCount++; RttCount++;
pendingPings.Remove(seq);
} }
ReceivedCount++; ReceivedCount++;
@@ -93,7 +96,7 @@ public class DummyClients
public void SendPing() public void SendPing()
{ {
if (peer == null) if (peer == null || writer == null)
{ {
return; return;
} }
@@ -101,15 +104,16 @@ public class DummyClients
int seq = seqNumber++; int seq = seqNumber++;
pendingPings[seq] = Stopwatch.GetTimestamp(); pendingPings[seq] = Stopwatch.GetTimestamp();
NetDataWriter writer = new NetDataWriter();
PacketHeader packetHeader = new PacketHeader(); PacketHeader packetHeader = new PacketHeader();
packetHeader.Code = 0; packetHeader.Code = 0;
packetHeader.BodyLength = $"seq:{seq}".Length; packetHeader.BodyLength = $"seq:{seq}".Length;
writer.Put((short)packetHeader.Code); writer.Put((short)packetHeader.Code);
writer.Put((short)packetHeader.BodyLength); writer.Put((short)packetHeader.BodyLength);
writer.Put($"Echo seq:{seq}"); writer.Put($"Echo seq:{seq}");
peer.Send(writer, DeliveryMethod.ReliableOrdered); // 순서보장 안함 HOL Blocking 제거
peer.Send(writer, DeliveryMethod.ReliableUnordered);
SentCount++; SentCount++;
writer.Reset();
} }
public double AvgRttMs => RttCount > 0 ? TotalRttMs / RttCount : 0.0; public double AvgRttMs => RttCount > 0 ? TotalRttMs / RttCount : 0.0;