chore: increase timeout to 5

limebell · Nov 29, 2024 · 0c7db11 · 0c7db11
1 parent 2d3e294
commit 0c7db11
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/Libplanet.Net/Consensus/Gossip.cs b/src/Libplanet.Net/Consensus/Gossip.cs
@@ -451,7 +451,7 @@ await optimized.ParallelForEachAsync(
                     Message[] replies = (await _transport.SendMessageAsync(
                         pair.Key,
                         want,
-                        TimeSpan.FromSeconds(1),
+                        TimeSpan.FromSeconds(5),
                         idsToGet.Length,
                         true,
                         ctx)).ToArray();

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(3), ct),
+                        peer => SendMessageAsync(peer, content, TimeSpan.FromSeconds(5), 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(3), message))
+            if (_router!.TrySendMultipartMessage(TimeSpan.FromSeconds(5), message))
             {
                 _logger.Debug(
                     "{Message} as a reply to {Identity} sent", messageType, reqId);