aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-03-13 16:17:44 -0700
committerChris Lu <chris.lu@gmail.com>2020-03-13 16:17:44 -0700
commit3cc9e858954c1c9d91af2054b60eb9c04f4a49c4 (patch)
tree7c2a2d85fe1492d56c945fcdfde0a34a36f94f25
parent4ce23e88099c5b5a89351d1d6757f587c7ad36fe (diff)
downloadseaweedfs-3cc9e858954c1c9d91af2054b60eb9c04f4a49c4.tar.xz
seaweedfs-3cc9e858954c1c9d91af2054b60eb9c04f4a49c4.zip
volume: vacuum pass preallocate variable
-rw-r--r--weed/topology/topology_vacuum.go3
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/topology/topology_vacuum.go b/weed/topology/topology_vacuum.go
index 9d964489d..532029ac3 100644
--- a/weed/topology/topology_vacuum.go
+++ b/weed/topology/topology_vacuum.go
@@ -66,7 +66,8 @@ func batchVacuumVolumeCompact(grpcDialOption grpc.DialOption, vl *VolumeLayout,
glog.V(0).Infoln(index, "Start vacuuming", vid, "on", url)
err := operation.WithVolumeServerClient(url, grpcDialOption, func(volumeServerClient volume_server_pb.VolumeServerClient) error {
_, err := volumeServerClient.VacuumVolumeCompact(context.Background(), &volume_server_pb.VacuumVolumeCompactRequest{
- VolumeId: uint32(vid),
+ VolumeId: uint32(vid),
+ Preallocate: preallocate,
})
return err
})