diff options
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/volume_grpc_erasure_coding.go | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/weed/server/volume_grpc_erasure_coding.go b/weed/server/volume_grpc_erasure_coding.go index 5d100bdda..ec59ffa39 100644 --- a/weed/server/volume_grpc_erasure_coding.go +++ b/weed/server/volume_grpc_erasure_coding.go @@ -20,6 +20,9 @@ import ( "github.com/seaweedfs/seaweedfs/weed/storage/types" "github.com/seaweedfs/seaweedfs/weed/storage/volume_info" "github.com/seaweedfs/seaweedfs/weed/util" + + "google.golang.org/grpc/codes" + "google.golang.org/grpc/status" ) /* @@ -506,6 +509,17 @@ func (vs *VolumeServer) VolumeEcShardsToVolume(ctx context.Context, req *volume_ } dataBaseFileName, indexBaseFileName := v.DataBaseFileName(), v.IndexBaseFileName() + + // If the EC index contains no live entries, decoding should be a no-op: + // just allow the caller to purge EC shards and do not generate an empty normal volume. + hasLive, err := erasure_coding.HasLiveNeedles(indexBaseFileName) + if err != nil { + return nil, fmt.Errorf("HasLiveNeedles %s: %w", indexBaseFileName, err) + } + if !hasLive { + return nil, status.Errorf(codes.FailedPrecondition, "ec volume %d %s", req.VolumeId, erasure_coding.EcNoLiveEntriesSubstring) + } + // calculate .dat file size datFileSize, err := erasure_coding.FindDatFileSize(dataBaseFileName, indexBaseFileName) if err != nil { |