(msg ConsensusMsg)
| 425 | } |
| 426 | |
| 427 | func (self *Server) broadcast(msg ConsensusMsg) { |
| 428 | self.msgSendC <- &SendMsgEvent{ |
| 429 | ToPeer: math.MaxUint32, |
| 430 | Msg: msg, |
| 431 | } |
| 432 | } |
| 433 | |
| 434 | func (self *Server) broadcastToAll(data []byte) error { |
| 435 | msg := &p2pmsg.ConsensusPayload{ |
no outgoing calls
no test coverage detected