|
|
@ -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 |
|
|
|
}) |
|
|
|