diff options
| author | Péter Szilágyi <peterke@gmail.com> | 2015-06-29 17:44:00 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2015-07-01 00:00:01 +0800 |
| commit | 6fc85f1ec221f976399af071a75ad7264b0ee905 (patch) | |
| tree | 6ef805673f49ae9662f5c724f917f88bbba9a023 /eth/sync.go | |
| parent | 2c8ed76e01161d9fe4e69064404cd888b4e327f3 (diff) | |
| download | dexon-6fc85f1ec221f976399af071a75ad7264b0ee905.tar.gz dexon-6fc85f1ec221f976399af071a75ad7264b0ee905.tar.zst dexon-6fc85f1ec221f976399af071a75ad7264b0ee905.zip | |
eth: clean up peer struct a bit, fix double txn bcast
Diffstat (limited to 'eth/sync.go')
| -rw-r--r-- | eth/sync.go | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/eth/sync.go b/eth/sync.go index 82abb725f..47fd7363e 100644 --- a/eth/sync.go +++ b/eth/sync.go @@ -20,14 +20,6 @@ const ( txsyncPackSize = 100 * 1024 ) -// blockAnnounce is the hash notification of the availability of a new block in -// the network. -type blockAnnounce struct { - hash common.Hash - peer *peer - time time.Time -} - type txsync struct { p *peer txs []*types.Transaction @@ -75,7 +67,7 @@ func (pm *ProtocolManager) txsyncLoop() { // Send the pack in the background. glog.V(logger.Detail).Infof("%v: sending %d transactions (%v)", s.p.Peer, len(pack.txs), size) sending = true - go func() { done <- pack.p.sendTransactions(pack.txs) }() + go func() { done <- pack.p.SendTransactions(pack.txs) }() } // pick chooses the next pending sync. |