aboutsummaryrefslogtreecommitdiffstats
path: root/eth/downloader/downloader.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2015-04-19 23:14:15 +0800
committerobscuren <geffobscura@gmail.com>2015-04-19 23:14:15 +0800
commitdcf1a1988ab692664a21bafbd534eb30c9f5adf6 (patch)
tree63a96b3ef9867d727b46374cc962dce11c66f082 /eth/downloader/downloader.go
parent8eff550e8b9bf121c27a4c2469ec9878d803a60e (diff)
downloadgo-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.tar
go-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.tar.gz
go-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.tar.bz2
go-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.tar.lz
go-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.tar.xz
go-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.tar.zst
go-tangerine-dcf1a1988ab692664a21bafbd534eb30c9f5adf6.zip
moved
Diffstat (limited to 'eth/downloader/downloader.go')
-rw-r--r--eth/downloader/downloader.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/eth/downloader/downloader.go b/eth/downloader/downloader.go
index 2b9d1cbee..f8fc4fc30 100644
--- a/eth/downloader/downloader.go
+++ b/eth/downloader/downloader.go
@@ -359,6 +359,12 @@ out:
return nil
}
+// Deliver a chunk to the downloader. This is usually done through the BlocksMsg by
+// the protocol handler.
+func (d *Downloader) DeliverChunk(id string, blocks []*types.Block) {
+ d.blockCh <- blockPack{id, blocks}
+}
+
func (d *Downloader) AddHashes(id string, hashes []common.Hash) error {
// make sure that the hashes that are being added are actually from the peer
// that's the current active peer. hashes that have been received from other
@@ -422,12 +428,6 @@ func (d *Downloader) AddBlock(id string, block *types.Block, td *big.Int) error
return d.process()
}
-// Deliver a chunk to the downloader. This is usually done through the BlocksMsg by
-// the protocol handler.
-func (d *Downloader) DeliverChunk(id string, blocks []*types.Block) {
- d.blockCh <- blockPack{id, blocks}
-}
-
func (d *Downloader) process() error {
atomic.StoreInt32(&d.processingBlocks, 1)
defer atomic.StoreInt32(&d.processingBlocks, 0)