(payload *p2pmsg.ConsensusPayload, message *ChangeView)
| 242 | } |
| 243 | |
| 244 | func (ds *DbftService) ChangeViewReceived(payload *p2pmsg.ConsensusPayload, message *ChangeView) { |
| 245 | log.Debug() |
| 246 | log.Info(fmt.Sprintf("Change View Received: height=%d View=%d index=%d nv=%d", payload.Height, message.ViewNumber(), payload.BookkeeperIndex, message.NewViewNumber)) |
| 247 | |
| 248 | if message.NewViewNumber <= ds.context.ExpectedView[payload.BookkeeperIndex] { |
| 249 | return |
| 250 | } |
| 251 | |
| 252 | ds.context.ExpectedView[payload.BookkeeperIndex] = message.NewViewNumber |
| 253 | |
| 254 | ds.CheckExpectedView(message.NewViewNumber) |
| 255 | } |
| 256 | |
| 257 | func (ds *DbftService) halt() error { |
| 258 | log.Info("DBFT Stop") |
no test coverage detected