MB-50006 Acquire muSnap lock before processing flushDone

Change-Id: I6951f53a2c4eb7b68753634f27551e4472a65bd9
couchbase · Feb 11, 2022 · b247c98 · b247c98
1 parent 7f0af20
commit b247c98
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/secondary/indexer/storage_manager.go b/secondary/indexer/storage_manager.go
@@ -279,6 +279,9 @@ func (s *storageMgr) handleCreateSnapshot(cmd Message) {
 		}()
 	}
 
+	s.muSnap.Lock()
+	defer s.muSnap.Unlock()
+
 	if snapType == common.NO_SNAP || snapType == common.NO_SNAP_OSO {
 		logging.Debugf("StorageMgr::handleCreateSnapshot Skip Snapshot For %v "+
 			"%v SnapType %v", streamId, keyspaceId, snapType)
@@ -292,9 +295,6 @@ func (s *storageMgr) handleCreateSnapshot(cmd Message) {
 		return
 	}
 
-	s.muSnap.Lock()
-	defer s.muSnap.Unlock()
-
 	//pass copy of maps to worker
 	indexInstMap := s.indexInstMap.Get()
 	indexPartnMap := s.indexPartnMap.Get()