Don't send on unbuffered channel while holding a lock

Longhorn 7919

Signed-off-by: Eric Weber <eric.weber@suse.com>
(cherry picked from commit ecd20d6)

pkg/process/process_manager.go

@@ -140,18 +140,19 @@ func (pm *Manager) checkMountPointStatusForEngine() {
 	if err != nil {
 		logrus.WithError(err).Warn("Failed to get all volume mount points")
 	}
-
-	pm.lock.RLock()
-	defer pm.lock.RUnlock()
-
-	processToUpdate := pm.getProcessToUpdateConditions(volumeMountPointMap)
-	for _, p := range processToUpdate {
+	// Locking is handled inside getProcessesToUpdateConditions.
+	processesToUpdate := pm.getProcessesToUpdateConditions(volumeMountPointMap)
+	for _, p := range processesToUpdate {
 		p.UpdateCh <- p
 	}
 }
 
-func (pm *Manager) getProcessToUpdateConditions(volumeMountPointMap map[string]mount.MountPoint) []*Process {
-	var processToUpdate []*Process
+func (pm *Manager) getProcessesToUpdateConditions(volumeMountPointMap map[string]mount.MountPoint) []*Process {
+	var processesToUpdate []*Process
+
+	pm.lock.RLock()
+	defer pm.lock.RUnlock()
+
 	for _, p := range pm.processes {
 		p.lock.Lock()
 		if isEngineProcess(p) && p.State == StateRunning {
@@ -161,12 +162,12 @@ func (pm *Manager) getProcessToUpdateConditions(volumeMountPointMap map[string]m
 
 			if mp, exists := volumeMountPointMap[volumeNameSHAStr]; exists {
 				p.Conditions[types.EngineConditionFilesystemReadOnly] = util.IsMountPointReadOnly(mp)
-				processToUpdate = append(processToUpdate, p)
+				processesToUpdate = append(processesToUpdate, p)
 			}
 		}
 		p.lock.Unlock()
 	}
-	return processToUpdate
+	return processesToUpdate
 }
 
 func isEngineProcess(p *Process) bool {