diff options
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{ |