aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/volume.go
diff options
context:
space:
mode:
authorViktor Kuzmin <kvaster@gmail.com>2022-09-03 23:52:30 +0300
committerViktor Kuzmin <kvaster@gmail.com>2022-09-03 23:52:30 +0300
commit825920dd8c0640f9ef5942d19fbab5a7e7945c4c (patch)
treed8e95674b60c979727a06bd79a379e9eeec86bdf /pkg/driver/volume.go
parentbc49fc11ffe8c687c5d4ea46f25ead9191155ec0 (diff)
downloadseaweedfs-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.go12
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
}