...
This commit is contained in:
parent
e4435a8d1e
commit
43a0cac453
|
@ -132,6 +132,7 @@ func (conR *ConsensusReactor) RemovePeer(peer *p2p.Peer, reason interface{}) {
|
||||||
|
|
||||||
// Implements Reactor
|
// Implements Reactor
|
||||||
func (conR *ConsensusReactor) Receive(chId byte, peer *p2p.Peer, msgBytes []byte) {
|
func (conR *ConsensusReactor) Receive(chId byte, peer *p2p.Peer, msgBytes []byte) {
|
||||||
|
log.Debug("Receive", "channel", chId, "peer", peer, "bytes", msgBytes)
|
||||||
if conR.sync || !conR.IsRunning() {
|
if conR.sync || !conR.IsRunning() {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue