OSDN Git Service
(root)
/
bytom
/
vapor.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Mov (#518)
[bytom/vapor.git]
/
netsync
/
chainmgr
/
msg_fetcher.go
diff --git
a/netsync/chainmgr/msg_fetcher.go
b/netsync/chainmgr/msg_fetcher.go
index
457574b
..
aa8d657
100644
(file)
--- a/
netsync/chainmgr/msg_fetcher.go
+++ b/
netsync/chainmgr/msg_fetcher.go
@@
-24,7
+24,7
@@
const (
var (
requireBlockTimeout = 20 * time.Second
requireHeadersTimeout = 30 * time.Second
var (
requireBlockTimeout = 20 * time.Second
requireHeadersTimeout = 30 * time.Second
- requireBlocksTimeout =
5
0 * time.Second
+ requireBlocksTimeout =
9
0 * time.Second
checkSyncPeerNumInterval = 5 * time.Second
errRequestBlocksTimeout = errors.New("request blocks timeout")
checkSyncPeerNumInterval = 5 * time.Second
errRequestBlocksTimeout = errors.New("request blocks timeout")
@@
-33,6
+33,7
@@
var (
errSendMsg = errors.New("send message error")
)
errSendMsg = errors.New("send message error")
)
+// MsgFetcher is the interface for msg fetch struct
type MsgFetcher interface {
resetParameter()
addSyncPeer(peerID string)
type MsgFetcher interface {
resetParameter()
addSyncPeer(peerID string)
@@
-51,7
+52,7
@@
type fetchBlocksResult struct {
}
type msgFetcher struct {
}
type msgFetcher struct {
- storage
S
torage
+ storage
*s
torage
syncPeers *fastSyncPeers
peers *peers.PeerSet
blockProcessCh chan *blockMsg
syncPeers *fastSyncPeers
peers *peers.PeerSet
blockProcessCh chan *blockMsg
@@
-61,7
+62,7
@@
type msgFetcher struct {
mux sync.RWMutex
}
mux sync.RWMutex
}
-func newMsgFetcher(storage
S
torage, peers *peers.PeerSet) *msgFetcher {
+func newMsgFetcher(storage
*s
torage, peers *peers.PeerSet) *msgFetcher {
return &msgFetcher{
storage: storage,
syncPeers: newFastSyncPeers(),
return &msgFetcher{
storage: storage,
syncPeers: newFastSyncPeers(),