diff options
| author | chrislu <chris.lu@gmail.com> | 2024-08-13 13:56:00 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-08-13 13:56:00 -0700 |
| commit | 07f4998188b2e62aec53c0e0f2f5597990d46e4c (patch) | |
| tree | 19ebf87eda86952452d5e1964bf88d183d0b0a9f /weed/server/volume_grpc_erasure_coding.go | |
| parent | 3a2e21fee78f932eba19a4d20d0914176cc9f5c8 (diff) | |
| download | seaweedfs-07f4998188b2e62aec53c0e0f2f5597990d46e4c.tar.xz seaweedfs-07f4998188b2e62aec53c0e0f2f5597990d46e4c.zip | |
add dat file size into vif for EC
Diffstat (limited to 'weed/server/volume_grpc_erasure_coding.go')
| -rw-r--r-- | weed/server/volume_grpc_erasure_coding.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/server/volume_grpc_erasure_coding.go b/weed/server/volume_grpc_erasure_coding.go index a84c163a6..032af7dfe 100644 --- a/weed/server/volume_grpc_erasure_coding.go +++ b/weed/server/volume_grpc_erasure_coding.go @@ -71,7 +71,11 @@ func (vs *VolumeServer) VolumeEcShardsGenerate(ctx context.Context, req *volume_ } // write .vif files - if err := volume_info.SaveVolumeInfo(baseFileName+".vif", &volume_server_pb.VolumeInfo{Version: uint32(v.Version())}); err != nil { + datSize, _, _ := v.FileStat() + if err := volume_info.SaveVolumeInfo(baseFileName+".vif", &volume_server_pb.VolumeInfo{ + Version: uint32(v.Version()), + FileSize: int64(datSize), + }); err != nil { return nil, fmt.Errorf("SaveVolumeInfo %s: %v", baseFileName, err) } |