aboutsummaryrefslogtreecommitdiffstats
path: root/eth/backend.go
diff options
context:
space:
mode:
authorFelix Lange <fjl@twurst.com>2015-03-19 22:18:31 +0800
committerFelix Lange <fjl@twurst.com>2015-03-19 22:18:31 +0800
commite80dda605130479086bed363e395a102a89a574a (patch)
treef5ddd0887d1366794d10ee43b656a7d15fefc945 /eth/backend.go
parentb9e0b11e7da387bbb426d25c36d495c4f099722f (diff)
downloadgo-tangerine-e80dda605130479086bed363e395a102a89a574a.tar.gz
go-tangerine-e80dda605130479086bed363e395a102a89a574a.tar.zst
go-tangerine-e80dda605130479086bed363e395a102a89a574a.zip
eth, whisper: adapt for RLP encoder switch in package p2p
I have rewritten the protocol test to use p2p.MsgPipe because p2p.NewMsg is gone.
Diffstat (limited to 'eth/backend.go')
-rw-r--r--eth/backend.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/eth/backend.go b/eth/backend.go
index 9e5324688..afe314d74 100644
--- a/eth/backend.go
+++ b/eth/backend.go
@@ -405,7 +405,7 @@ func (self *Ethereum) txBroadcastLoop() {
// automatically stops if unsubscribe
for obj := range self.txSub.Chan() {
event := obj.(core.TxPreEvent)
- self.net.Broadcast("eth", TxMsg, event.Tx.RlpData())
+ self.net.Broadcast("eth", TxMsg, []*types.Transaction{event.Tx})
}
}
@@ -414,7 +414,7 @@ func (self *Ethereum) blockBroadcastLoop() {
for obj := range self.blockSub.Chan() {
switch ev := obj.(type) {
case core.NewMinedBlockEvent:
- self.net.Broadcast("eth", NewBlockMsg, ev.Block.RlpData(), ev.Block.Td)
+ self.net.Broadcast("eth", NewBlockMsg, []interface{}{ev.Block, ev.Block.Td})
}
}
}