Method handleTransmitConsensusMsgReq

p2pserver/actor/server/actor.go:225–232

(ctx actor.Context, req *TransmitConsensusMsgReq)

}

func (this *P2PActor) handleTransmitConsensusMsgReq(ctx actor.Context, req *TransmitConsensusMsgReq) {
	peer := this.server.GetNetWork().GetPeer(req.Target)
	if peer != nil {
		this.server.Send(peer, req.Msg, true)
	} else {
		log.Warnf("[p2p]can`t transmit consensus msg:no valid neighbor peer: %d\n", req.Target)
	}
}