fix(enterprise/replicasync): Avoid deadlock during Close (#7220)

mafredri · web-flow · commit 8d27978760e1 · 2023-04-20T15:37:30.000+03:00
diff --git a/enterprise/replicasync/replicasync.go b/enterprise/replicasync/replicasync.go
@@ -216,6 +216,12 @@ func (m *Manager) subscribe(ctx context.Context) error {
 
 func (m *Manager) syncReplicas(ctx context.Context) error {
 	m.closeMutex.Lock()
+	select {
+	case <-m.closed:
+		m.closeMutex.Unlock()
+		return xerrors.New("manager is closed")
+	default:
+	}
 	m.closeWait.Add(1)
 	m.closeMutex.Unlock()
 	defer m.closeWait.Done()
