aboutsummaryrefslogtreecommitdiffstats
path: root/lds/fetcher.go
diff options
context:
space:
mode:
authorSonic <sonic@dexon.org>2019-05-08 17:05:04 +0800
committerSonic <sonic@dexon.org>2019-05-08 17:05:04 +0800
commit53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583 (patch)
tree3b347dcddd84f986398458d9ddea6f8b77523290 /lds/fetcher.go
parentb6c2c72d553e4680259fc8d05b0bcf9f4d0d4b58 (diff)
downloaddexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.tar
dexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.tar.gz
dexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.tar.bz2
dexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.tar.lz
dexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.tar.xz
dexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.tar.zst
dexon-53db7e5a2ae7eb85fa5a2fc412d5746ef6f0f583.zip
lds: replace eth/downloader with dex/downloader
Diffstat (limited to 'lds/fetcher.go')
-rw-r--r--lds/fetcher.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/lds/fetcher.go b/lds/fetcher.go
index 8db34398c..b58918a08 100644
--- a/lds/fetcher.go
+++ b/lds/fetcher.go
@@ -101,7 +101,7 @@ type fetchRequest struct {
// fetchResponse represents a header download response
type fetchResponse struct {
reqID uint64
- headers []*types.Header
+ headers []*types.HeaderWithGovState
peer *peer
}
@@ -506,7 +506,7 @@ func (f *lightFetcher) nextRequest() (*distReq, uint64, bool) {
}
// deliverHeaders delivers header download request responses for processing
-func (f *lightFetcher) deliverHeaders(peer *peer, reqID uint64, headers []*types.Header) {
+func (f *lightFetcher) deliverHeaders(peer *peer, reqID uint64, headers []*types.HeaderWithGovState) {
f.deliverChn <- fetchResponse{reqID: reqID, headers: headers, peer: peer}
}
@@ -518,7 +518,7 @@ func (f *lightFetcher) processResponse(req fetchRequest, resp fetchResponse) boo
}
headers := make([]*types.Header, req.amount)
for i, header := range resp.headers {
- headers[int(req.amount)-1-i] = header
+ headers[int(req.amount)-1-i] = header.Header
}
if _, err := f.chain.InsertHeaderChain(headers, 1); err != nil {
if err == consensus.ErrFutureBlock {