aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/mounter.go
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2022-07-01 02:19:02 -0700
committerGitHub <noreply@github.com>2022-07-01 02:19:02 -0700
commit3a5a3406256bc10263f0815baef112a19b62556b (patch)
treeec08f9e968af823d73c16327b86f79707e198eab /pkg/driver/mounter.go
parent27586e9139d4bacf1d37525a2fb7726f472931f4 (diff)
parent96d415ad3e121518552629f31a7cbe6eee9c76e4 (diff)
downloadseaweedfs-csi-driver-3a5a3406256bc10263f0815baef112a19b62556b.tar.xz
seaweedfs-csi-driver-3a5a3406256bc10263f0815baef112a19b62556b.zip
Merge pull request #66 from garenchan/ck-dev1
Fix error when managing multiple volumes
Diffstat (limited to 'pkg/driver/mounter.go')
-rw-r--r--pkg/driver/mounter.go14
1 files changed, 12 insertions, 2 deletions
diff --git a/pkg/driver/mounter.go b/pkg/driver/mounter.go
index e0a6283..2c019ed 100644
--- a/pkg/driver/mounter.go
+++ b/pkg/driver/mounter.go
@@ -20,8 +20,18 @@ type Mounter interface {
Mount(target string) error
}
-func newMounter(path string, collection string, readOnly bool, driver *SeaweedFsDriver, volContext map[string]string) (Mounter, error) {
- return newSeaweedFsMounter(path, collection, readOnly, driver, volContext)
+func newMounter(volumeID string, readOnly bool, driver *SeaweedFsDriver, volContext map[string]string) (Mounter, error) {
+ path, ok := volContext["path"]
+ if !ok {
+ path = fmt.Sprintf("/buckets/%s", volumeID)
+ }
+
+ collection, ok := volContext["collection"]
+ if !ok {
+ collection = volumeID
+ }
+
+ return newSeaweedFsMounter(volumeID, path, collection, readOnly, driver, volContext)
}
func fuseMount(path string, command string, args []string) error {