(server *Server, historyLen uint32)
| 95 | } |
| 96 | |
| 97 | func newMsgPool(server *Server, historyLen uint32) *MsgPool { |
| 98 | // TODO |
| 99 | return &MsgPool{ |
| 100 | historyLen: historyLen, |
| 101 | server: server, |
| 102 | rounds: make(map[uint32]*ConsensusRound), |
| 103 | } |
| 104 | } |
| 105 | |
| 106 | func (pool *MsgPool) clean() { |
| 107 | pool.lock.Lock() |
no outgoing calls