diff options
| author | chrislu <chris.lu@gmail.com> | 2022-04-03 01:07:08 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-04-03 01:07:08 -0700 |
| commit | e1dcd15f015e5dadd123982b8f6d51f1f3b99c26 (patch) | |
| tree | f11fd71129d6179c3eea81b3079eb5c09e0f47f1 /pkg/driver/driver.go | |
| parent | 498a0af0ee54b2c06dd0710cf6fd84722ea75912 (diff) | |
| download | seaweedfs-csi-driver-e1dcd15f015e5dadd123982b8f6d51f1f3b99c26.tar.xz seaweedfs-csi-driver-e1dcd15f015e5dadd123982b8f6d51f1f3b99c26.zip | |
support expand volume
Diffstat (limited to 'pkg/driver/driver.go')
| -rw-r--r-- | pkg/driver/driver.go | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go index 5e82a60..00e1f35 100644 --- a/pkg/driver/driver.go +++ b/pkg/driver/driver.go @@ -30,7 +30,8 @@ type SeaweedFsDriver struct { nodeID string version string - endpoint string + endpoint string + mountSocket string vcap []*csi.VolumeCapability_AccessMode cscap []*csi.ControllerServiceCapability @@ -53,6 +54,12 @@ func NewSeaweedFsDriver(filer, nodeID, endpoint string) *SeaweedFsDriver { util.LoadConfiguration("security", false) + montDirHash := util.HashToInt32([]byte(endpoint)) + if montDirHash < 0 { + montDirHash = -montDirHash + } + socket := fmt.Sprintf("/tmp/seaweedfs-mount-%d.sock", montDirHash) + n := &SeaweedFsDriver{ endpoint: endpoint, nodeID: nodeID, @@ -60,6 +67,7 @@ func NewSeaweedFsDriver(filer, nodeID, endpoint string) *SeaweedFsDriver { version: version, filers: pb.ServerAddresses(filer).ToAddresses(), grpcDialOption: security.LoadClientTLS(util.GetViper(), "grpc.client"), + mountSocket: socket, } n.AddVolumeCapabilityAccessModes([]csi.VolumeCapability_AccessMode_Mode{ |