(msg ConsensusMsg)
| 131 | } |
| 132 | |
| 133 | func (pool *MsgPool) DropMsg(msg ConsensusMsg) { |
| 134 | pool.lock.Lock() |
| 135 | defer pool.lock.Unlock() |
| 136 | |
| 137 | if roundMsgs, present := pool.rounds[msg.GetBlockNum()]; present { |
| 138 | roundMsgs.dropMsg(msg) |
| 139 | } |
| 140 | } |
| 141 | |
| 142 | func (pool *MsgPool) HasMsg(msg ConsensusMsg, msgHash common.Uint256) bool { |
| 143 | pool.lock.RLock() |
no test coverage detected