mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-27 05:27:21 +00:00
fix flexvol stuck issue due to corrupted mnt point
fix comments about PathExists fix comments revert change in PathExists func
This commit is contained in:
parent
c48ed1c5ac
commit
fb81a28a47
@ -42,15 +42,15 @@ func (f *flexVolumeUnmounter) TearDown() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (f *flexVolumeUnmounter) TearDownAt(dir string) error {
|
func (f *flexVolumeUnmounter) TearDownAt(dir string) error {
|
||||||
|
|
||||||
pathExists, pathErr := mount.PathExists(dir)
|
pathExists, pathErr := mount.PathExists(dir)
|
||||||
|
if pathErr != nil {
|
||||||
|
// only log warning here since plugins should anyways have to deal with errors
|
||||||
|
klog.Warningf("Error checking path: %v", pathErr)
|
||||||
|
} else {
|
||||||
if !pathExists {
|
if !pathExists {
|
||||||
klog.Warningf("Warning: Unmount skipped because path does not exist: %v", dir)
|
klog.Warningf("Warning: Unmount skipped because path does not exist: %v", dir)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if pathErr != nil && !mount.IsCorruptedMnt(pathErr) {
|
|
||||||
return fmt.Errorf("Error checking path: %v", pathErr)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
call := f.plugin.NewDriverCall(unmountCmd)
|
call := f.plugin.NewDriverCall(unmountCmd)
|
||||||
|
Loading…
Reference in New Issue
Block a user