aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/controllerserver.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-03-06 18:52:03 -0800
committerchrislu <chris.lu@gmail.com>2022-03-06 18:52:03 -0800
commit76c7b84418c4c99141c1ffbde2ac2060b2620e1d (patch)
treed6fbfd8b34d71ea072507b06043f55254d33c419 /pkg/driver/controllerserver.go
parentdac21204f38e4b177d0bfc11f7e5f17b3ea4355e (diff)
downloadseaweedfs-csi-driver-76c7b84418c4c99141c1ffbde2ac2060b2620e1d.tar.xz
seaweedfs-csi-driver-76c7b84418c4c99141c1ffbde2ac2060b2620e1d.zip
support quota
fix https://github.com/seaweedfs/seaweedfs-csi-driver/issues/48
Diffstat (limited to 'pkg/driver/controllerserver.go')
-rw-r--r--pkg/driver/controllerserver.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/pkg/driver/controllerserver.go b/pkg/driver/controllerserver.go
index c57a72a..88fcd80 100644
--- a/pkg/driver/controllerserver.go
+++ b/pkg/driver/controllerserver.go
@@ -41,6 +41,7 @@ func (cs *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
params := req.GetParameters()
glog.V(4).Infof("params:%v", params)
capacity := req.GetCapacityRange().GetRequiredBytes()
+ cs.Driver.Capacity = capacity
if err := filer_pb.Mkdir(cs.Driver, "/buckets", volumeId, nil); err != nil {
return nil, fmt.Errorf("Error setting bucket metadata: %v", err)