timeout 3

planetarium · Nov 28, 2024 · 2d3e294 · 2d3e294
1 parent 368bb48
commit 2d3e294
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Libplanet.Net/Transports/NetMQTransport.cs b/src/Libplanet.Net/Transports/NetMQTransport.cs
@@ -513,7 +513,7 @@ public void BroadcastMessage(IEnumerable<BoundPeer> peers, MessageContent conten
                         .AddTag("Message", content.Type)
                         .AddTag("Peers", boundPeers.Select(x => x.PeerString));
                     await boundPeers.ParallelForEachAsync(
-                        peer => SendMessageAsync(peer, content, TimeSpan.FromSeconds(1), ct),
+                        peer => SendMessageAsync(peer, content, TimeSpan.FromSeconds(3), ct),
                         ct
                     );
 
@@ -734,7 +734,7 @@ private void DoReply(
 
             // FIXME The current timeout value(1 sec) is arbitrary.
             // We should make this configurable or fix it to an unneeded structure.
-            if (_router!.TrySendMultipartMessage(TimeSpan.FromSeconds(1), message))
+            if (_router!.TrySendMultipartMessage(TimeSpan.FromSeconds(3), message))
             {
                 _logger.Debug(
                     "{Message} as a reply to {Identity} sent", messageType, reqId);