aboutsummaryrefslogtreecommitdiffstats
path: root/dex/downloader/peer.go
diff options
context:
space:
mode:
authorSonic <sonic@dexon.org>2019-02-12 16:16:13 +0800
committerWei-Ning Huang <w@byzantine-lab.io>2019-06-12 17:27:22 +0800
commit5ea856585a994390c0f22f11868086a985c1f3f7 (patch)
tree46e344ef50c5f41ba82503894f5aeeda6f017c1d /dex/downloader/peer.go
parent003088b6787dae1b718785ddddfe361d2fe5c505 (diff)
downloadgo-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.tar
go-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.tar.gz
go-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.tar.bz2
go-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.tar.lz
go-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.tar.xz
go-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.tar.zst
go-tangerine-5ea856585a994390c0f22f11868086a985c1f3f7.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/peer.go')
-rw-r--r--dex/downloader/peer.go8
1 files changed, 4 insertions, 4 deletions
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
}