aboutsummaryrefslogtreecommitdiff
path: root/pkg/mountmanager/manager.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/mountmanager/manager.go')
-rw-r--r--pkg/mountmanager/manager.go9
1 files changed, 3 insertions, 6 deletions
diff --git a/pkg/mountmanager/manager.go b/pkg/mountmanager/manager.go
index 493333a..7d6a908 100644
--- a/pkg/mountmanager/manager.go
+++ b/pkg/mountmanager/manager.go
@@ -99,12 +99,9 @@ func (m *Manager) Unmount(req *UnmountRequest) (*UnmountResponse, error) {
return &UnmountResponse{}, nil
}
- if ok, err := kubeMounter.IsMountPoint(entry.targetPath); ok || mount.IsCorruptedMnt(err) {
- if err = kubeMounter.Unmount(entry.targetPath); err != nil {
- return nil, err
- }
- }
-
+ // Note: We don't explicitly unmount here because weedMountProcess.wait()
+ // handles the unmount when the process terminates (either gracefully or forcefully).
+ // This centralizes unmount logic and avoids potential race conditions.
if err := entry.process.stop(); err != nil {
return nil, err
}