diff options
author | Sonic <sonic@cobinhood.com> | 2018-09-19 19:07:10 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@byzantine-lab.io> | 2019-06-12 17:21:31 +0800 |
commit | bbd696f96d32b06b5bcffa1b97682d372b7eee31 (patch) | |
tree | 67e0a77155aa04c423a1c6999a5070c88bfa3ed8 /dex/handler.go | |
parent | d461a77d0c7c34c4d686c22f0c9d4bb77fd17569 (diff) | |
download | go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.tar go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.tar.gz go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.tar.bz2 go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.tar.lz go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.tar.xz go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.tar.zst go-tangerine-bbd696f96d32b06b5bcffa1b97682d372b7eee31.zip |
dex: introduce dex64 and remove eth62, eth63
Diffstat (limited to 'dex/handler.go')
-rw-r--r-- | dex/handler.go | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/dex/handler.go b/dex/handler.go index b9a354f42..21609a561 100644 --- a/dex/handler.go +++ b/dex/handler.go @@ -123,11 +123,6 @@ func NewProtocolManager(config *params.ChainConfig, mode downloader.SyncMode, ne // Initiate a sub-protocol for every implemented version we can handle manager.SubProtocols = make([]p2p.Protocol, 0, len(ProtocolVersions)) for i, version := range ProtocolVersions { - // Skip protocol version if incompatible with the mode of operation - if mode == downloader.FastSync && version < eth63 { - continue - } - // Compatible; initialise the sub-protocol version := version // Closure for the run manager.SubProtocols = append(manager.SubProtocols, p2p.Protocol{ Name: ProtocolName, @@ -526,7 +521,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { } } - case p.version >= eth63 && msg.Code == GetNodeDataMsg: + case msg.Code == GetNodeDataMsg: // Decode the retrieval message msgStream := rlp.NewStream(msg.Payload, uint64(msg.Size)) if _, err := msgStream.List(); err != nil { @@ -553,7 +548,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { } return p.SendNodeData(data) - case p.version >= eth63 && msg.Code == NodeDataMsg: + case msg.Code == NodeDataMsg: // A batch of node state data arrived to one of our previous requests var data [][]byte if err := msg.Decode(&data); err != nil { @@ -564,7 +559,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { log.Debug("Failed to deliver node state data", "err", err) } - case p.version >= eth63 && msg.Code == GetReceiptsMsg: + case msg.Code == GetReceiptsMsg: // Decode the retrieval message msgStream := rlp.NewStream(msg.Payload, uint64(msg.Size)) if _, err := msgStream.List(); err != nil { @@ -600,7 +595,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { } return p.SendReceiptsRLP(receipts) - case p.version >= eth63 && msg.Code == ReceiptsMsg: + case msg.Code == ReceiptsMsg: // A batch of receipts arrived to one of our previous requests var receipts [][]*types.Receipt if err := msg.Decode(&receipts); err != nil { |