diff options
| author | Sonic <sonic@cobinhood.com> | 2018-10-20 10:10:47 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@byzantine-lab.io> | 2019-06-12 17:23:39 +0800 |
| commit | 6f50d557abae1def74f0e4509711da3d33dba43c (patch) | |
| tree | 66f6a43f6da96a1e616005421225bb8f102238e6 /dex/peer.go | |
| parent | 45dee648b6f28f73e781f71a10561dc064327edf (diff) | |
| download | go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.tar go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.tar.gz go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.tar.bz2 go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.tar.lz go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.tar.xz go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.tar.zst go-tangerine-6f50d557abae1def74f0e4509711da3d33dba43c.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") } |