(pred string)
| 319 | } |
| 320 | |
| 321 | func (s *Server) blockTablet(pred string) func() { |
| 322 | s.blockCommitsOn.Store(pred, struct{}{}) |
| 323 | return func() { |
| 324 | s.blockCommitsOn.Delete(pred) |
| 325 | } |
| 326 | } |
| 327 | |
| 328 | func (s *Server) isBlocked(pred string) bool { |
| 329 | _, blocked := s.blockCommitsOn.Load(pred) |
no test coverage detected