diff options
author | Sonic <sonic@dexon.org> | 2019-02-12 16:16:13 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@byzantine-lab.io> | 2019-06-12 17:27:22 +0800 |
commit | 5ea856585a994390c0f22f11868086a985c1f3f7 (patch) | |
tree | 46e344ef50c5f41ba82503894f5aeeda6f017c1d /dex/downloader/peer.go | |
parent | 003088b6787dae1b718785ddddfe361d2fe5c505 (diff) | |
download | go-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.go | 8 |
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 } |