(blockNum uint32)
| 213 | } |
| 214 | |
| 215 | func (pool *MsgPool) onBlockSealed(blockNum uint32) { |
| 216 | if blockNum <= pool.historyLen { |
| 217 | return |
| 218 | } |
| 219 | pool.lock.Lock() |
| 220 | defer pool.lock.Unlock() |
| 221 | |
| 222 | toFreeRound := make([]uint32, 0) |
| 223 | for n := range pool.rounds { |
| 224 | if n < blockNum-pool.historyLen { |
| 225 | toFreeRound = append(toFreeRound, n) |
| 226 | } |
| 227 | } |
| 228 | for _, n := range toFreeRound { |
| 229 | delete(pool.rounds, n) |
| 230 | } |
| 231 | } |
no outgoing calls