diff options
| author | Viktor Kuzmin <kvaster@gmail.com> | 2022-09-03 23:52:30 +0300 |
|---|---|---|
| committer | Viktor Kuzmin <kvaster@gmail.com> | 2022-09-03 23:52:30 +0300 |
| commit | 825920dd8c0640f9ef5942d19fbab5a7e7945c4c (patch) | |
| tree | d8e95674b60c979727a06bd79a379e9eeec86bdf /pkg/driver/volume.go | |
| parent | bc49fc11ffe8c687c5d4ea46f25ead9191155ec0 (diff) | |
| download | seaweedfs-csi-driver-825920dd8c0640f9ef5942d19fbab5a7e7945c4c.tar.xz seaweedfs-csi-driver-825920dd8c0640f9ef5942d19fbab5a7e7945c4c.zip | |
Rename Mount interface to Unmounter
Diffstat (limited to 'pkg/driver/volume.go')
| -rw-r--r-- | pkg/driver/volume.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/pkg/driver/volume.go b/pkg/driver/volume.go index 29a2e8c..ff303ea 100644 --- a/pkg/driver/volume.go +++ b/pkg/driver/volume.go @@ -15,8 +15,8 @@ import ( type Volume struct { VolumeId string - mounter Mounter - mount Mount + mounter Mounter + unmounter Unmounter // unix socket used to manage volume localSocket string @@ -39,8 +39,8 @@ func (vol *Volume) Stage(stagingTargetPath string) error { _ = mount.New("").Unmount(stagingTargetPath) } - if m, err := vol.mounter.Mount(stagingTargetPath); err == nil { - vol.mount = m + if u, err := vol.mounter.Mount(stagingTargetPath); err == nil { + vol.unmounter = u return nil } else { return err @@ -100,12 +100,12 @@ func (vol *Volume) Unpublish(targetPath string) error { func (vol *Volume) Unstage(stagingTargetPath string) error { glog.V(0).Infof("unmounting volume %s from %s", vol.VolumeId, stagingTargetPath) - if vol.mount == nil { + if vol.unmounter == nil { glog.Errorf("volume is not mounted: %s, path", vol.VolumeId, stagingTargetPath) return nil } - if err := vol.mount.Unmount(); err != nil { + if err := vol.unmounter.Unmount(); err != nil { return err } |
