Graceful Peer Timeout for debugging purposes

mikhail-dcl · mikhail-dcl · commit f463fd54b000 · 2026-03-30T14:58:44.000+03:00
Signed-off-by: Mikhail Agapov &lt;mikhail.agapov@decentraland.org&gt;
diff --git a/src/DCLPulse/Transport/ENetHostedService.cs b/src/DCLPulse/Transport/ENetHostedService.cs
@@ -116,6 +116,7 @@ private void HandleEvent(ref Event netEvent)
         switch (netEvent.Type)
         {
             case EventType.Connect:
+                netEvent.Peer.Timeout(0, options.PeerTimeoutMs, options.PeerTimeoutMs);
                 connectedPeers[peerIndex] = netEvent.Peer;
 
                 messagePipe.OnPeerConnected(peerIndex);
diff --git a/src/DCLPulse/Transport/ENetTransportOptions.cs b/src/DCLPulse/Transport/ENetTransportOptions.cs
@@ -8,4 +8,6 @@ public sealed class ENetTransportOptions
     public int MaxPeers { get; set; } = 4095;
     public int ServiceTimeoutMs { get; set; } = 1000;
     public int BufferSize { get; set; } = 4096;
+
+    public uint PeerTimeoutMs { get; set; } = 30000;
 }
diff --git a/src/DCLPulse/appsettings.Development.json b/src/DCLPulse/appsettings.Development.json
@@ -5,6 +5,9 @@
       "Microsoft.Hosting.Lifetime": "Information"
     }
   },
+  "Transport": {
+    "PeerTimeoutMs": 300000
+  },
   "Peers": {
     "SelfMirrorEnabled": true,
     "SelfMirrorTier": 0

Original file line number	Diff line number	Diff line change
`@@ -116,6 +116,7 @@ private void HandleEvent(ref Event netEvent)`
`116`	`116`	`switch (netEvent.Type)`
`117`	`117`	`{`
`118`	`118`	`case EventType.Connect:`
	`119`	`+ netEvent.Peer.Timeout(0, options.PeerTimeoutMs, options.PeerTimeoutMs);`
`119`	`120`	`connectedPeers[peerIndex] = netEvent.Peer;`
`120`	`121`
`121`	`122`	`messagePipe.OnPeerConnected(peerIndex);`
Original file line number	Diff line number	Diff line change
`@@ -8,4 +8,6 @@ public sealed class ENetTransportOptions`
`8`	`8`	`public int MaxPeers { get; set; } = 4095;`
`9`	`9`	`public int ServiceTimeoutMs { get; set; } = 1000;`
`10`	`10`	`public int BufferSize { get; set; } = 4096;`
	`11`	`+`
	`12`	`+ public uint PeerTimeoutMs { get; set; } = 30000;`
`11`	`13`	`}`