()
| 79 | } |
| 80 | |
| 81 | func (s *Topom) ResyncGroupAll() error { |
| 82 | s.mu.Lock() |
| 83 | defer s.mu.Unlock() |
| 84 | ctx, err := s.newContext() |
| 85 | if err != nil { |
| 86 | return err |
| 87 | } |
| 88 | |
| 89 | for _, g := range ctx.group { |
| 90 | if err := s.resyncSlotMappingsByGroupId(ctx, g.Id); err != nil { |
| 91 | log.Warnf("group-[%d] resync-group failed", g.Id) |
| 92 | return err |
| 93 | } |
| 94 | defer s.dirtyGroupCache(g.Id) |
| 95 | |
| 96 | g.OutOfSync = false |
| 97 | if err := s.storeUpdateGroup(g); err != nil { |
| 98 | return err |
| 99 | } |
| 100 | } |
| 101 | return nil |
| 102 | } |
| 103 | |
| 104 | func (s *Topom) GroupAddServer(gid int, dc, addr string) error { |
| 105 | s.mu.Lock() |
nothing calls this directly
no test coverage detected