Skip to content

K
k3s
Commit fb32e1de authored by andyzhangx's avatar andyzhangx
Browse files
Options

fix flexvol stuck issue due to corrupted mnt point

fix comments about PathExists fix comments revert change in PathExists func
parent 5b2266b9
Hide whitespace changes
Inline Side-by-side
Showing with 8 additions and 8 deletions
pkg/volume/flexvolume/unmounter.go
View file @ fb32e1de
...@@ -42,15 +42,15 @@ func (f *flexVolumeUnmounter) TearDown() error { ...@@ -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 !pathExists { if pathErr != nil {
klog.Warningf("Warning: Unmount skipped because path does not exist: %v", dir) // only log warning here since plugins should anyways have to deal with errors
return nil klog.Warningf("Error checking path: %v", pathErr)
} } else {
if !pathExists {
if pathErr != nil && !mount.IsCorruptedMnt(pathErr) { klog.Warningf("Warning: Unmount skipped because path does not exist: %v", dir)
return fmt.Errorf("Error checking path: %v", pathErr) return nil
}
} }
call := f.plugin.NewDriverCall(unmountCmd) call := f.plugin.NewDriverCall(unmountCmd)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment