diff --git a/enterprise/replicasync/replicasync.go b/enterprise/replicasync/replicasync.go index 6f8c25a65cc49..4b31b912ea673 100644 --- a/enterprise/replicasync/replicasync.go +++ b/enterprise/replicasync/replicasync.go @@ -371,8 +371,8 @@ func (m *Manager) Close() error { } close(m.closed) m.closeCancel() - m.closeWait.Wait() m.closeMutex.Unlock() + m.closeWait.Wait() m.mutex.Lock() defer m.mutex.Unlock() ctx, cancelFunc := context.WithTimeout(context.Background(), 5*time.Second)