CCQ/Node: P2P message filter is wrong (#3547)
This commit is contained in:
parent
efdb10e39a
commit
c9a0b0a691
|
@ -137,10 +137,10 @@ func (ccq *ccqP2p) run(
|
||||||
if len(ccq.allowedPeers) == 0 {
|
if len(ccq.allowedPeers) == 0 {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
if _, found := ccq.allowedPeers[from.String()]; found {
|
if _, found := ccq.allowedPeers[msg.GetFrom().String()]; found {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
ccq.logger.Info("Dropping message from unknown peer", zap.String("fromPeerID", from.String()))
|
ccq.logger.Info("Dropping message from unknown peer", zap.String("fromPeerID", from.String()), zap.String("msgPeerID", msg.ReceivedFrom.String()), zap.String("msgFrom", msg.GetFrom().String()))
|
||||||
return false
|
return false
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Loading…
Reference in New Issue