(msg ConsensusMsg)
| 1185 | } |
| 1186 | |
| 1187 | func (self *Server) processConsensusMsg(msg ConsensusMsg) { |
| 1188 | if isReady(self.getState()) { |
| 1189 | self.msgC <- msg |
| 1190 | } |
| 1191 | } |
| 1192 | |
| 1193 | func (self *Server) processMsgEvent() error { |
| 1194 | select { |
no test coverage detected