From cf3f452e2e43d20ab8400c10ce9e93534a8e371c Mon Sep 17 00:00:00 2001 From: Paladz Date: Wed, 27 Jan 2021 17:17:49 +0800 Subject: [PATCH] edit the sync config (#563) Co-authored-by: paladz --- netsync/chainmgr/block_keeper.go | 2 +- netsync/chainmgr/handle.go | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/netsync/chainmgr/block_keeper.go b/netsync/chainmgr/block_keeper.go index 7707cffc..b7b394cc 100644 --- a/netsync/chainmgr/block_keeper.go +++ b/netsync/chainmgr/block_keeper.go @@ -24,7 +24,7 @@ const ( ) var ( - maxNumOfBlocksPerMsg = uint64(1000) + maxNumOfBlocksPerMsg = uint64(64) maxNumOfHeadersPerMsg = uint64(1000) maxNumOfBlocksRegularSync = uint64(128) ) diff --git a/netsync/chainmgr/handle.go b/netsync/chainmgr/handle.go index c1538b51..152367d2 100644 --- a/netsync/chainmgr/handle.go +++ b/netsync/chainmgr/handle.go @@ -157,13 +157,18 @@ func (m *Manager) handleGetBlockMsg(peer *peers.Peer, msg *msgs.GetBlockMessage) } func (m *Manager) handleGetBlocksMsg(peer *peers.Peer, msg *msgs.GetBlocksMessage) { - endTime := time.Now().Add(requireBlocksTimeout / 2) + endTime := time.Now().Add(requireBlocksTimeout / 10) isTimeout := func() bool { return time.Now().After(endTime) } blocks, err := m.blockKeeper.locateBlocks(msg.GetBlockLocator(), msg.GetStopHash(), isTimeout) if err != nil || len(blocks) == 0 { + log.WithFields(log.Fields{ + "module": logModule, + "err": err, + "size": len(blocks), + }).Error("fail on handleGetBlocksMsg locateBlocks") return } -- 2.11.0