diff options
| author | Sonic <sonic@cobinhood.com> | 2018-10-20 10:10:47 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-03-12 12:19:09 +0800 |
| commit | 616516320bc5565c07364718266630a0ad7acd7a (patch) | |
| tree | 10846a7df9e0ffe2ee5a953714710c7b3206501c /dex/peer.go | |
| parent | 29e0161f790179e018acedf5521250d956098f91 (diff) | |
| download | dexon-616516320bc5565c07364718266630a0ad7acd7a.tar dexon-616516320bc5565c07364718266630a0ad7acd7a.tar.gz dexon-616516320bc5565c07364718266630a0ad7acd7a.tar.bz2 dexon-616516320bc5565c07364718266630a0ad7acd7a.tar.lz dexon-616516320bc5565c07364718266630a0ad7acd7a.tar.xz dexon-616516320bc5565c07364718266630a0ad7acd7a.tar.zst dexon-616516320bc5565c07364718266630a0ad7acd7a.zip | |
dex: no need to rlp encode/decode now, consensus supports it
Diffstat (limited to 'dex/peer.go')
| -rw-r--r-- | dex/peer.go | 16 |
1 files changed, 6 insertions, 10 deletions
diff --git a/dex/peer.go b/dex/peer.go index db68ea590..a5e0dd21a 100644 --- a/dex/peer.go +++ b/dex/peer.go @@ -388,16 +388,14 @@ func (p *peer) AsyncSendNewBlock(block *types.Block, td *big.Int) { } func (p *peer) SendLatticeBlock(block *coreTypes.Block) error { - r := toRLPLatticeBlock(block) - p.knownLatticeBlocks.Add(rlpHash(r)) - return p2p.Send(p.rw, LatticeBlockMsg, toRLPLatticeBlock(block)) + p.knownLatticeBlocks.Add(rlpHash(block)) + return p2p.Send(p.rw, LatticeBlockMsg, block) } func (p *peer) AsyncSendLatticeBlock(block *coreTypes.Block) { select { case p.queuedLatticeBlocks <- block: - r := toRLPLatticeBlock(block) - p.knownLatticeBlocks.Add(rlpHash(r)) + p.knownLatticeBlocks.Add(rlpHash(block)) default: p.Log().Debug("Dropping lattice block propagation") } @@ -446,16 +444,14 @@ func (p *peer) AsyncSendRandomness(randomness *coreTypes.BlockRandomnessResult) } func (p *peer) SendDKGPrivateShare(privateShare *coreTypes.DKGPrivateShare) error { - r := toRLPDKGPrivateShare(privateShare) - p.knownDKGPrivateShares.Add(rlpHash(r)) - return p2p.Send(p.rw, DKGPrivateShareMsg, toRLPDKGPrivateShare(privateShare)) + p.knownDKGPrivateShares.Add(rlpHash(privateShare)) + return p2p.Send(p.rw, DKGPrivateShareMsg, privateShare) } func (p *peer) AsyncSendDKGPrivateShare(privateShare *coreTypes.DKGPrivateShare) { select { case p.queuedDKGPrivateShares <- privateShare: - r := toRLPDKGPrivateShare(privateShare) - p.knownDKGPrivateShares.Add(rlpHash(r)) + p.knownDKGPrivateShares.Add(rlpHash(privateShare)) default: p.Log().Debug("Dropping DKG private share") } |