()
| 286 | } |
| 287 | |
| 288 | func (s *Server) updateZeroLeader() { |
| 289 | s.Lock() |
| 290 | defer s.Unlock() |
| 291 | leader := s.Node.Raft().Status().Lead |
| 292 | for _, m := range s.state.Zeros { |
| 293 | m.Leader = m.Id == leader |
| 294 | } |
| 295 | } |
| 296 | |
| 297 | func (s *Server) removeZero(nodeId uint64) { |
| 298 | s.Lock() |
no test coverage detected