修复csi map 并发panic问题 (PaddlePaddle#1346)

D0m021ng · May 11, 2024 · 62d3a3c · 62d3a3c
1 parent 485782b
commit 62d3a3c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/fs/csiplugin/controller/mount_point_controller.go b/pkg/fs/csiplugin/controller/mount_point_controller.go
@@ -248,7 +248,9 @@ func (m *MountPointController) handleRunningPod(pod v1.Pod, updateMounts bool) {
 
 func (m *MountPointController) CheckAndRemountVolumeMount(volumeMount volumeMountInfo) error {
 	// TODO(dongzezhao) get mountParameters from volumeMountInfo
+	m.pvMapLock.Lock()
 	pvParams_, ok := m.pvParamsMap[volumeMount.VolumeName]
+	m.pvMapLock.Unlock()
 	if !ok {
 		log.Errorf("get pfs parameters [%s] not exist", volumeMount.VolumeName)
 		return fmt.Errorf("get pfs parameters [%s] not exist", volumeMount.VolumeName)