var (
requireBlockTimeout = 20 * time.Second
requireHeadersTimeout = 30 * time.Second
- requireBlocksTimeout = 50 * time.Second
+ requireBlocksTimeout = 90 * time.Second
checkSyncPeerNumInterval = 5 * time.Second
errRequestBlocksTimeout = errors.New("request blocks timeout")
errSendMsg = errors.New("send message error")
)
+// MsgFetcher is the interface for msg fetch struct
type MsgFetcher interface {
resetParameter()
addSyncPeer(peerID string)
}
type msgFetcher struct {
- storage Storage
+ storage *storage
syncPeers *fastSyncPeers
peers *peers.PeerSet
blockProcessCh chan *blockMsg
mux sync.RWMutex
}
-func newMsgFetcher(storage Storage, peers *peers.PeerSet) *msgFetcher {
+func newMsgFetcher(storage *storage, peers *peers.PeerSet) *msgFetcher {
return &msgFetcher{
storage: storage,
syncPeers: newFastSyncPeers(),