diff options
author | obscuren <geffobscura@gmail.com> | 2014-09-27 02:19:01 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-09-27 02:19:01 +0800 |
commit | 0acdeca3d6df4716d8789444c7bb645c73a27324 (patch) | |
tree | af1f7e9c52e00fca4f4093f617f4d8f92a107735 /peer.go | |
parent | a45e293267bfa4147f291dc15625e089bdc41ab7 (diff) | |
download | dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.tar dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.tar.gz dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.tar.bz2 dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.tar.lz dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.tar.xz dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.tar.zst dexon-0acdeca3d6df4716d8789444c7bb645c73a27324.zip |
skip messages properly
Diffstat (limited to 'peer.go')
-rw-r--r-- | peer.go | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -314,14 +314,14 @@ func (p *Peer) HandleOutbound() { out: for { + skip: select { // Main message queue. All outbound messages are processed through here case msg := <-p.outputQueue: if !p.statusKnown { switch msg.Type { - case ethwire.MsgGetTxsTy, ethwire.MsgGetBlockHashesTy, ethwire.MsgGetBlocksTy, ethwire.MsgBlockHashesTy, ethwire.MsgBlockTy: - peerlogger.Debugln("Blocked outgoing [eth] message to peer without the [eth] cap.") - break + case ethwire.MsgStatusTy, ethwire.MsgGetTxsTy, ethwire.MsgTxTy, ethwire.MsgGetBlockHashesTy, ethwire.MsgBlockHashesTy, ethwire.MsgGetBlocksTy, ethwire.MsgBlockTy: + break skip } } |