edit the sync config (#563)

Co-authored-by: paladz <colt@ColtdeMacBook-Pro.local>

diff --git a/netsync/chainmgr/block_keeper.go b/netsync/chainmgr/block_keeper.go
index 7707cff..b7b394c 100644 (file)
--- 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 c1538b5..152367d 100644 (file)
--- 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
        }