github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 18:00:08 +00:00
Code Issues Projects Releases Wiki Activity

Fix volume remount on reboot

Browse Source
This commit is contained in:
Chakravarthy Nelluri 2017-09-01 20:12:39 -04:00
parent 8b9e8cf80a
commit b8d1c3bcd8
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/kubelet/volumemanager/reconciler/reconciler.go
View File

@ -448,6 +448,19 @@ func (rc *reconciler) reconstructVolume(volume podVolume) (*reconstructedVolume,
uniqueVolumeName = volumehelper.GetUniqueVolumeNameForNonAttachableVolume(volume.podName, plugin, volumeSpec) uniqueVolumeName = volumehelper.GetUniqueVolumeNameForNonAttachableVolume(volume.podName, plugin, volumeSpec)
} }
if attachablePlugin != nil {
if isNotMount, mountCheckErr := rc.mounter.IsLikelyNotMountPoint(volume.mountPath); mountCheckErr != nil {
return nil, fmt.Errorf("Could not check whether the volume %q (spec.Name: %q) pod %q (UID: %q) is mounted with: %v",
uniqueVolumeName,
volumeSpec.Name(),
volume.podName,
pod.UID,
mountCheckErr)
} else if isNotMount {
return nil, fmt.Errorf("Volume: %q is not mounted", uniqueVolumeName)
}
}
volumeMounter, newMounterErr := plugin.NewMounter( volumeMounter, newMounterErr := plugin.NewMounter(
volumeSpec, volumeSpec,
pod, pod,
@ -531,7 +544,9 @@ func (rc *reconciler) updateStates(volumesNeedUpdate map[v1.UniqueVolumeName]*re
glog.Errorf("Could not mark device is mounted to actual state of world: %v", err) glog.Errorf("Could not mark device is mounted to actual state of world: %v", err)
continue continue
} }
glog.Infof("Volume: %v is mounted", volume.volumeName)
} }
_, err = rc.desiredStateOfWorld.AddPodToVolume(volume.podName, _, err = rc.desiredStateOfWorld.AddPodToVolume(volume.podName,
volume.pod, volume.pod,
volume.volumeSpec, volume.volumeSpec,