ec deletion works

2019-06-21 01:14:10 -07:00
parent 613a2e8060
commit f88a8bda7b
8 changed files with 189 additions and 147 deletions
--- a/weed/server/volume_grpc_erasure_coding.go
+++ b/weed/server/volume_grpc_erasure_coding.go
@@ -234,6 +234,15 @@ func (vs *VolumeServer) VolumeEcShardRead(req *volume_server_pb.VolumeEcShardRea
 		return fmt.Errorf("not found ec shard %d.%d", req.VolumeId, req.ShardId)
 	}

+	if req.FileKey != 0 {
+		_, size, _ := ecVolume.FindNeedleFromEcx(types.Uint64ToNeedleId(req.FileKey))
+		if size == types.TombstoneFileSize {
+			return stream.Send(&volume_server_pb.VolumeEcShardReadResponse{
+				IsDeleted: true,
+			})
+		}
+	}
+
 	bufSize := req.Size
 	if bufSize > BufferSizeLimit {
 		bufSize = BufferSizeLimit