add grpc VolumeEcBlobDelete

1 files changed, 28 insertions, 0 deletions

diff --git a/weed/server/volume_grpc_erasure_coding.go b/weed/server/volume_grpc_erasure_coding.go
index e676337e6..58eefc6dc 100644
--- a/weed/server/volume_grpc_erasure_coding.go
+++ b/weed/server/volume_grpc_erasure_coding.go
@@ -16,6 +16,7 @@ import (
 	"github.com/chrislusf/seaweedfs/weed/storage"
 	"github.com/chrislusf/seaweedfs/weed/storage/erasure_coding"
 	"github.com/chrislusf/seaweedfs/weed/storage/needle"
+	"github.com/chrislusf/seaweedfs/weed/storage/types"
 	"github.com/chrislusf/seaweedfs/weed/util"
 )
 
@@ -274,3 +275,30 @@ func (vs *VolumeServer) VolumeEcShardRead(req *volume_server_pb.VolumeEcShardRea
 	return nil
 
 }
+
+func (vs *VolumeServer) VolumeEcBlobDelete(ctx context.Context, req *volume_server_pb.VolumeEcBlobDeleteRequest) (*volume_server_pb.VolumeEcBlobDeleteResponse, error) {
+
+	resp := &volume_server_pb.VolumeEcBlobDeleteResponse{}
+
+	for _, location := range vs.store.Locations {
+		if localEcVolume, found := location.FindEcVolume(needle.VolumeId(req.VolumeId)); found {
+
+			_, size, _, err := localEcVolume.LocateEcShardNeedle(types.NeedleId(req.FileKey), needle.Version(req.Version))
+			if err != nil {
+				return nil, fmt.Errorf("locate in local ec volume: %v", err)
+			}
+			if size == types.TombstoneFileSize {
+				return resp, nil
+			}
+
+			err = localEcVolume.DeleteNeedleFromEcx(types.NeedleId(req.FileKey))
+			if err != nil {
+				return nil, err
+			}
+
+			break
+		}
+	}
+
+	return resp, nil
+}