diff options
| author | Péter Szilágyi <peterke@gmail.com> | 2015-07-03 00:55:18 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2015-08-24 22:57:28 +0800 |
| commit | 42f44dda5468000b3b2c005ec485529bc5da3674 (patch) | |
| tree | c93c9a2734adceac75e48f825076d48325826140 /eth/fetcher/fetcher.go | |
| parent | c51e153b5c5327f971e7b410e49e7babfc3f0b8e (diff) | |
| download | dexon-42f44dda5468000b3b2c005ec485529bc5da3674.tar.gz dexon-42f44dda5468000b3b2c005ec485529bc5da3674.tar.zst dexon-42f44dda5468000b3b2c005ec485529bc5da3674.zip | |
eth, eth/downloader: handle header requests, table driven proto tests
Diffstat (limited to 'eth/fetcher/fetcher.go')
| -rw-r--r-- | eth/fetcher/fetcher.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/eth/fetcher/fetcher.go b/eth/fetcher/fetcher.go index 55b6c5c1c..07eb165dc 100644 --- a/eth/fetcher/fetcher.go +++ b/eth/fetcher/fetcher.go @@ -69,8 +69,9 @@ type peerDropFn func(id string) // announce is the hash notification of the availability of a new block in the // network. type announce struct { - hash common.Hash // Hash of the block being announced - time time.Time // Timestamp of the announcement + hash common.Hash // Hash of the block being announced + number uint64 // Number of the block being announced (0 = unknown | old protocol) + time time.Time // Timestamp of the announcement origin string // Identifier of the peer originating the notification fetch blockRequesterFn // Fetcher function to retrieve @@ -152,9 +153,10 @@ func (f *Fetcher) Stop() { // Notify announces the fetcher of the potential availability of a new block in // the network. -func (f *Fetcher) Notify(peer string, hash common.Hash, time time.Time, fetcher blockRequesterFn) error { +func (f *Fetcher) Notify(peer string, hash common.Hash, number uint64, time time.Time, fetcher blockRequesterFn) error { block := &announce{ hash: hash, + number: number, time: time, origin: peer, fetch: fetcher, |