aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/driver')
-rw-r--r--pkg/driver/controllerserver.go2
-rw-r--r--pkg/driver/driver.go4
2 files changed, 3 insertions, 3 deletions
diff --git a/pkg/driver/controllerserver.go b/pkg/driver/controllerserver.go
index 102d1e2..3ca456c 100644
--- a/pkg/driver/controllerserver.go
+++ b/pkg/driver/controllerserver.go
@@ -80,7 +80,7 @@ func (cs *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVol
}
glog.V(4).Infof("Deleting volume %s", volumeId)
- if err := filer_pb.Remove(cs.Driver, "/buckets", volumeId, true, true, true, false); err != nil {
+ if err := filer_pb.Remove(cs.Driver, "/buckets", volumeId, true, true, true, false, nil); err != nil {
return nil, fmt.Errorf("Error setting bucket metadata: %v", err)
}
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go
index 920b47f..4e3b808 100644
--- a/pkg/driver/driver.go
+++ b/pkg/driver/driver.go
@@ -135,6 +135,6 @@ func (d *SeaweedFsDriver) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) e
}, filerGrpcAddress, d.grpcDialOption)
}
-func (d *SeaweedFsDriver) AdjustedUrl(hostAndPort string) string {
- return hostAndPort
+func (d *SeaweedFsDriver) AdjustedUrl(location *filer_pb.Location) string {
+ return location.Url
}