X-Git-Url: http://git.osdn.net/view?p=bytom%2Fvapor.git;a=blobdiff_plain;f=netsync%2Fconsensusmgr%2Fblock_fetcher.go;h=8c28ff90eaa04d0e266f007e6926db54223dcb03;hp=3c92b38b545f86783a2ca96c6567af15f8152686;hb=4adf3b94c3cf38f3ff3d77e95f6a4830f516d2d9;hpb=df9deca26ab5e99b48bae28fb8282ec3fa47d516 diff --git a/netsync/consensusmgr/block_fetcher.go b/netsync/consensusmgr/block_fetcher.go index 3c92b38b..8c28ff90 100644 --- a/netsync/consensusmgr/block_fetcher.go +++ b/netsync/consensusmgr/block_fetcher.go @@ -4,7 +4,6 @@ import ( "github.com/sirupsen/logrus" "gopkg.in/karalabe/cookiejar.v2/collections/prque" - "github.com/vapor/netsync/peers" "github.com/vapor/p2p/security" "github.com/vapor/protocol/bc" ) @@ -19,7 +18,7 @@ const ( // and scheduling them for retrieval. type blockFetcher struct { chain Chain - peers *peers.PeerSet + peers Peers newBlockCh chan *blockMsg queue *prque.Prque @@ -27,7 +26,7 @@ type blockFetcher struct { } //NewBlockFetcher creates a block fetcher to retrieve blocks of the new propose. -func newBlockFetcher(chain Chain, peers *peers.PeerSet) *blockFetcher { +func newBlockFetcher(chain Chain, peers Peers) *blockFetcher { f := &blockFetcher{ chain: chain, peers: peers,