(blockNum uint32)
| 270 | } |
| 271 | |
| 272 | func (self *EventTimer) StartCommitTimer(blockNum uint32) error { |
| 273 | self.lock.Lock() |
| 274 | defer self.lock.Unlock() |
| 275 | |
| 276 | log.Infof("server %d started commit timer for blk %d", self.server.Index, blockNum) |
| 277 | return self.startEventTimer(EventCommitBlockTimeout, blockNum) |
| 278 | } |
| 279 | |
| 280 | func (self *EventTimer) CancelCommitMsgTimer(blockNum uint32) { |
| 281 | self.lock.Lock() |
no test coverage detected