gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rename

Browse Source
This commit is contained in:
chrislu
2024-08-13 13:59:24 -07:00
parent 07f4998188
commit fdf7193ae7
4 changed files with 500 additions and 500 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
weed/pb/volume_server.proto
View File

@@ -478,7 +478,7 @@ message VolumeInfo {
uint32 version = 2; uint32 version = 2;
string replication = 3; string replication = 3;
uint32 BytesOffset = 4; uint32 BytesOffset = 4;
int64 file_size = 5; // used for EC encoded volumes to store the original file size int64 dat_file_size = 5; // used for EC encoded volumes to store the original file size
} }
// tiered storage // tiered storage

992
weed/pb/volume_server_pb/volume_server.pb.go
View File

File diff suppressed because it is too large Load Diff

4
weed/server/volume_grpc_erasure_coding.go
View File

@@ -73,8 +73,8 @@ func (vs *VolumeServer) VolumeEcShardsGenerate(ctx context.Context, req *volume_
// write .vif files // write .vif files
datSize, _, _ := v.FileStat() datSize, _, _ := v.FileStat()
if err := volume_info.SaveVolumeInfo(baseFileName+".vif", &volume_server_pb.VolumeInfo{ if err := volume_info.SaveVolumeInfo(baseFileName+".vif", &volume_server_pb.VolumeInfo{
Version: uint32(v.Version()), Version: uint32(v.Version()),
FileSize: int64(datSize), DatFileSize: int64(datSize),
}); err != nil { }); err != nil {
return nil, fmt.Errorf("SaveVolumeInfo %s: %v", baseFileName, err) return nil, fmt.Errorf("SaveVolumeInfo %s: %v", baseFileName, err)
} }

2
weed/storage/erasure_coding/ec_volume.go
View File

@@ -69,7 +69,7 @@ func NewEcVolume(diskType types.DiskType, dir string, dirIdx string, collection
ev.Version = needle.Version3 ev.Version = needle.Version3
if volumeInfo, _, found, _ := volume_info.MaybeLoadVolumeInfo(dataBaseFileName + ".vif"); found { if volumeInfo, _, found, _ := volume_info.MaybeLoadVolumeInfo(dataBaseFileName + ".vif"); found {
ev.Version = needle.Version(volumeInfo.Version) ev.Version = needle.Version(volumeInfo.Version)
ev.datFileSize = volumeInfo.FileSize ev.datFileSize = volumeInfo.DatFileSize
} else { } else {
volume_info.SaveVolumeInfo(dataBaseFileName+".vif", &volume_server_pb.VolumeInfo{Version: uint32(ev.Version)}) volume_info.SaveVolumeInfo(dataBaseFileName+".vif", &volume_server_pb.VolumeInfo{Version: uint32(ev.Version)})
} }