From 18a7fe228d2a873614d4d997b6ae1286d9e3583a Mon Sep 17 00:00:00 2001 From: chrislu Date: Mon, 27 Oct 2025 21:01:15 -0700 Subject: [PATCH] fmt --- weed/server/volume_grpc_erasure_coding.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/weed/server/volume_grpc_erasure_coding.go b/weed/server/volume_grpc_erasure_coding.go index bb871796b..5d100bdda 100644 --- a/weed/server/volume_grpc_erasure_coding.go +++ b/weed/server/volume_grpc_erasure_coding.go @@ -55,7 +55,7 @@ func (vs *VolumeServer) VolumeEcShardsGenerate(ctx context.Context, req *volume_ if volumeInfo, _, found, _ := volume_info.MaybeLoadVolumeInfo(baseFileName + ".vif"); found && volumeInfo.EcShardConfig != nil { ds := int(volumeInfo.EcShardConfig.DataShards) ps := int(volumeInfo.EcShardConfig.ParityShards) - + // Validate and use existing EC config if ds > 0 && ps > 0 && ds+ps <= erasure_coding.MaxShardCount { ecCtx.DataShards = ds @@ -489,12 +489,12 @@ func (vs *VolumeServer) VolumeEcShardsToVolume(ctx context.Context, req *volume_ // Use EC context (already loaded from .vif) to determine data shard count dataShards := v.ECContext.DataShards - + // Defensive validation to prevent panics from corrupted ECContext if dataShards <= 0 || dataShards > erasure_coding.MaxShardCount { return nil, fmt.Errorf("invalid data shard count %d for volume %d (must be 1..%d)", dataShards, req.VolumeId, erasure_coding.MaxShardCount) } - + shardFileNames := tempShards[:dataShards] glog.V(1).Infof("Using EC config from volume %d: %d data shards", req.VolumeId, dataShards) @@ -504,7 +504,7 @@ func (vs *VolumeServer) VolumeEcShardsToVolume(ctx context.Context, req *volume_ return nil, fmt.Errorf("ec volume %d missing shard %d", req.VolumeId, shardId) } } - + dataBaseFileName, indexBaseFileName := v.DataBaseFileName(), v.IndexBaseFileName() // calculate .dat file size datFileSize, err := erasure_coding.FindDatFileSize(dataBaseFileName, indexBaseFileName)