From dbd2535f42301ce630a90631b47aa656d9a83d32 Mon Sep 17 00:00:00 2001
From: hashmap <hashmap@gmail.com>
Date: Sun, 30 Jun 2019 22:26:17 +0200
Subject: [PATCH] Increase peer's send buffer (#2931) (#2934)
When we send a txhashet archive a peer's thread is busy with sending it
and can't send other messages, eg pings. If the network connection is
slow buffer capacity 10 may be not enough, hence the peer's drop.
Safer attempt to address #2929 in 2.0.0
---
p2p/src/conn.rs | 2 +-
servers/src/grin/sync/body_sync.rs | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/p2p/src/conn.rs b/p2p/src/conn.rs
index 394902fd3..92db4317f 100644
--- a/p2p/src/conn.rs
+++ b/p2p/src/conn.rs
@@ -163,7 +163,7 @@ impl<'a> Response<'a> {
}
}
-pub const SEND_CHANNEL_CAP: usize = 10;
+pub const SEND_CHANNEL_CAP: usize = 100;
pub struct StopHandle {
/// Channel to close the connection
diff --git a/servers/src/grin/sync/body_sync.rs b/servers/src/grin/sync/body_sync.rs
index 687258642..a4e88946d 100644
--- a/servers/src/grin/sync/body_sync.rs
+++ b/servers/src/grin/sync/body_sync.rs
@@ -106,7 +106,7 @@ impl BodySync {
// 10) max will be 80 if all 8 peers are advertising more work
// also if the chain is already saturated with orphans, throttle
let block_count = cmp::min(
- cmp::min(100, peers.len() * p2p::SEND_CHANNEL_CAP),
+ cmp::min(100, peers.len() * 10),
chain::MAX_ORPHAN_SIZE.saturating_sub(self.chain.orphans_len()) + 1,
);