diff options
Diffstat (limited to 'pkg/mountmanager')
| -rw-r--r-- | pkg/mountmanager/manager.go | 9 |
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 } |
