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

fix: 119921

Browse Source
This commit is contained in:
cvvz 2023-08-13 15:52:25 +08:00
parent 6e0cb243d5
commit e40d00cf53
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/kubelet/volumemanager/reconciler/reconstruct.go
View File

@ -83,7 +83,6 @@ func (rc *reconciler) syncStates(kubeletPodDir string) {
if cachedInfo, ok := volumesNeedUpdate[reconstructedVolume.volumeName]; ok { if cachedInfo, ok := volumesNeedUpdate[reconstructedVolume.volumeName]; ok {
gvl = cachedInfo gvl = cachedInfo
} }
gvl.addPodVolume(reconstructedVolume)
if volumeInDSW { if volumeInDSW {
// Some pod needs the volume. And it exists on disk. Some previous // Some pod needs the volume. And it exists on disk. Some previous
// kubelet must have created the directory, therefore it must have // kubelet must have created the directory, therefore it must have
@ -95,6 +94,7 @@ func (rc *reconciler) syncStates(kubeletPodDir string) {
klog.V(4).InfoS("Volume exists in desired state, marking as InUse", "podName", volume.podName, "volumeSpecName", volume.volumeSpecName) klog.V(4).InfoS("Volume exists in desired state, marking as InUse", "podName", volume.podName, "volumeSpecName", volume.volumeSpecName)
continue continue
} }
gvl.addPodVolume(reconstructedVolume)
// There is no pod that uses the volume. // There is no pod that uses the volume.
if rc.operationExecutor.IsOperationPending(reconstructedVolume.volumeName, nestedpendingoperations.EmptyUniquePodName, nestedpendingoperations.EmptyNodeName) { if rc.operationExecutor.IsOperationPending(reconstructedVolume.volumeName, nestedpendingoperations.EmptyUniquePodName, nestedpendingoperations.EmptyNodeName) {
klog.InfoS("Volume is in pending operation, skip cleaning up mounts") klog.InfoS("Volume is in pending operation, skip cleaning up mounts")