diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-08-18 17:39:29 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-08-18 17:39:29 -0700 |
| commit | c026eb05921b180cad0b529634ff4c891cb5b61f (patch) | |
| tree | d43528feaae85f8e709afaac924ccf4ff43c021e /weed/server/volume_grpc_erasure_coding.go | |
| parent | 7e91ae592c2e34506b040c08d3aecbbdbe3781d1 (diff) | |
| download | seaweedfs-c026eb05921b180cad0b529634ff4c891cb5b61f.tar.xz seaweedfs-c026eb05921b180cad0b529634ff4c891cb5b61f.zip | |
refactoring
Diffstat (limited to 'weed/server/volume_grpc_erasure_coding.go')
| -rw-r--r-- | weed/server/volume_grpc_erasure_coding.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/volume_grpc_erasure_coding.go b/weed/server/volume_grpc_erasure_coding.go index 79348c9d7..55e0261c8 100644 --- a/weed/server/volume_grpc_erasure_coding.go +++ b/weed/server/volume_grpc_erasure_coding.go @@ -272,7 +272,7 @@ func (vs *VolumeServer) VolumeEcShardRead(req *volume_server_pb.VolumeEcShardRea if req.FileKey != 0 { _, size, _ := ecVolume.FindNeedleFromEcx(types.Uint64ToNeedleId(req.FileKey)) - if size == types.TombstoneFileSize { + if size.IsDeleted() { return stream.Send(&volume_server_pb.VolumeEcShardReadResponse{ IsDeleted: true, }) @@ -340,7 +340,7 @@ func (vs *VolumeServer) VolumeEcBlobDelete(ctx context.Context, req *volume_serv if err != nil { return nil, fmt.Errorf("locate in local ec volume: %v", err) } - if size == types.TombstoneFileSize { + if size.IsDeleted() { return resp, nil } |