(blocknum uint32)
| 198 | } |
| 199 | |
| 200 | func (pool *MsgPool) GetBlockSubmitMsgNums(blocknum uint32) []ConsensusMsg { |
| 201 | pool.lock.RLock() |
| 202 | defer pool.lock.RUnlock() |
| 203 | |
| 204 | roundMsgs, ok := pool.rounds[blocknum] |
| 205 | if !ok { |
| 206 | return nil |
| 207 | } |
| 208 | msg, ok := roundMsgs.msgs[BlockSubmitMessage] |
| 209 | if !ok { |
| 210 | return nil |
| 211 | } |
| 212 | return msg |
| 213 | } |
| 214 | |
| 215 | func (pool *MsgPool) onBlockSealed(blockNum uint32) { |
| 216 | if blockNum <= pool.historyLen { |