diff options
Diffstat (limited to 'dex/downloader')
-rw-r--r-- | dex/downloader/downloader_test.go | 8 | ||||
-rw-r--r-- | dex/downloader/fakepeer.go | 4 | ||||
-rw-r--r-- | dex/downloader/peer.go | 8 |
3 files changed, 10 insertions, 10 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) diff --git a/dex/downloader/fakepeer.go b/dex/downloader/fakepeer.go index f0d596a4b..f4ff9b517 100644 --- a/dex/downloader/fakepeer.go +++ b/dex/downloader/fakepeer.go @@ -132,9 +132,9 @@ func (p *FakePeer) RequestHeadersByNumber(number uint64, amount int, skip int, r return nil } -// RequestBodies implements downloader.Peer, returning a batch of block bodies +// DownloadBodies implements downloader.Peer, returning a batch of block bodies // corresponding to the specified block hashes. -func (p *FakePeer) RequestBodies(hashes []common.Hash) error { +func (p *FakePeer) DownloadBodies(hashes []common.Hash) error { var ( txs [][]*types.Transaction uncles [][]*types.Header diff --git a/dex/downloader/peer.go b/dex/downloader/peer.go index 25c355df1..e1c6960f1 100644 --- a/dex/downloader/peer.go +++ b/dex/downloader/peer.go @@ -85,7 +85,7 @@ type LightPeer interface { // Peer encapsulates the methods required to synchronise with a remote full peer. type Peer interface { LightPeer - RequestBodies([]common.Hash) error + DownloadBodies([]common.Hash) error RequestReceipts([]common.Hash) error RequestNodeData([]common.Hash) error } @@ -106,8 +106,8 @@ func (w *lightPeerWrapper) RequestGovStateByHash(common.Hash) error { // TODO(sonic): support this panic("RequestGovStateByHash not supported in light client mode sync") } -func (w *lightPeerWrapper) RequestBodies([]common.Hash) error { - panic("RequestBodies not supported in light client mode sync") +func (w *lightPeerWrapper) DownloadBodies([]common.Hash) error { + panic("DownloadBodies not supported in light client mode sync") } func (w *lightPeerWrapper) RequestReceipts([]common.Hash) error { panic("RequestReceipts not supported in light client mode sync") @@ -182,7 +182,7 @@ func (p *peerConnection) FetchBodies(request *fetchRequest) error { for _, header := range request.Headers { hashes = append(hashes, header.Hash()) } - go p.peer.RequestBodies(hashes) + go p.peer.DownloadBodies(hashes) return nil } |