diff options
| author | Sonic <sonic@dexon.org> | 2019-02-12 16:16:13 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-04-09 21:32:57 +0800 |
| commit | b3622c655271c594d19c78eb92b26c1f539ea31b (patch) | |
| tree | a90ec42b2fdb9da67556b12e69e732d0c664a18f /dex/downloader/downloader_test.go | |
| parent | 4df167061e22b7e8e8e54eaf6e5d08fd30f884a2 (diff) | |
| download | dexon-b3622c655271c594d19c78eb92b26c1f539ea31b.tar.gz dexon-b3622c655271c594d19c78eb92b26c1f539ea31b.tar.zst dexon-b3622c655271c594d19c78eb92b26c1f539ea31b.zip | |
dex: Add a flag to GetBlockHeadersMsg and GetBlockBodiesMsg (#188)
* dex: Add a flag to GetBlockHeadersMsg and GetBlockBodiesMsg
So that we can dispatch the response msg to fetcher or downloader
easily.
* fixup! dex: Add a flag to GetBlockHeadersMsg and GetBlockBodiesMsg
Diffstat (limited to 'dex/downloader/downloader_test.go')
| -rw-r--r-- | dex/downloader/downloader_test.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/dex/downloader/downloader_test.go b/dex/downloader/downloader_test.go index 80993bd75..e8ec0056b 100644 --- a/dex/downloader/downloader_test.go +++ b/dex/downloader/downloader_test.go @@ -376,10 +376,10 @@ func (dlp *downloadTesterPeer) RequestGovStateByHash(hash common.Hash) error { return nil } -// RequestBodies constructs a getBlockBodies method associated with a particular +// DownloadBodies constructs a getBlockBodies method associated with a particular // peer in the download tester. The returned function can be used to retrieve // batches of block bodies from the particularly requested peer. -func (dlp *downloadTesterPeer) RequestBodies(hashes []common.Hash) error { +func (dlp *downloadTesterPeer) DownloadBodies(hashes []common.Hash) error { txs, uncles := dlp.chain.bodies(hashes) go dlp.dl.downloader.DeliverBodies(dlp.id, txs, uncles) return nil @@ -1322,8 +1322,8 @@ func (ftp *floodingTestPeer) RequestHeadersByHash(hash common.Hash, count int, s func (ftp *floodingTestPeer) RequestGovStateByHash(hash common.Hash) error { return ftp.peer.RequestGovStateByHash(hash) } -func (ftp *floodingTestPeer) RequestBodies(hashes []common.Hash) error { - return ftp.peer.RequestBodies(hashes) +func (ftp *floodingTestPeer) DownloadBodies(hashes []common.Hash) error { + return ftp.peer.DownloadBodies(hashes) } func (ftp *floodingTestPeer) RequestReceipts(hashes []common.Hash) error { return ftp.peer.RequestReceipts(hashes) |