Golang implemented sidechain for Bytom
Révision | e6cea785d70f9750b1b23d444b488489d4c975d3 (tree) |
---|---|
l'heure | 2021-01-27 17:49:44 |
Auteur | paladz <colt@Colt...> |
Commiter | paladz |
edit the sync config
@@ -24,7 +24,7 @@ const ( | ||
24 | 24 | ) |
25 | 25 | |
26 | 26 | var ( |
27 | - maxNumOfBlocksPerMsg = uint64(1000) | |
27 | + maxNumOfBlocksPerMsg = uint64(64) | |
28 | 28 | maxNumOfHeadersPerMsg = uint64(1000) |
29 | 29 | maxNumOfBlocksRegularSync = uint64(128) |
30 | 30 | ) |
@@ -157,13 +157,18 @@ func (m *Manager) handleGetBlockMsg(peer *peers.Peer, msg *msgs.GetBlockMessage) | ||
157 | 157 | } |
158 | 158 | |
159 | 159 | func (m *Manager) handleGetBlocksMsg(peer *peers.Peer, msg *msgs.GetBlocksMessage) { |
160 | - endTime := time.Now().Add(requireBlocksTimeout / 2) | |
160 | + endTime := time.Now().Add(requireBlocksTimeout / 10) | |
161 | 161 | isTimeout := func() bool { |
162 | 162 | return time.Now().After(endTime) |
163 | 163 | } |
164 | 164 | |
165 | 165 | blocks, err := m.blockKeeper.locateBlocks(msg.GetBlockLocator(), msg.GetStopHash(), isTimeout) |
166 | 166 | if err != nil || len(blocks) == 0 { |
167 | + log.WithFields(log.Fields{ | |
168 | + "module": logModule, | |
169 | + "err": err, | |
170 | + "size": len(blocks), | |
171 | + }).Error("fail on handleGetBlocksMsg locateBlocks") | |
167 | 172 | return |
168 | 173 | } |
169 | 174 |