From 68a45709313f4be54c578a5bee4a29c93d44b6c8 Mon Sep 17 00:00:00 2001 From: Rewant Soni Date: Thu, 21 Nov 2024 19:59:00 +0530 Subject: [PATCH] provider: update replicationID to be storageClass name Signed-off-by: Rewant Soni --- services/provider/server/server.go | 5 +---- services/provider/server/server_test.go | 4 ++-- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/services/provider/server/server.go b/services/provider/server/server.go index 62349d3b59..ffc0960779 100644 --- a/services/provider/server/server.go +++ b/services/provider/server/server.go @@ -681,10 +681,7 @@ func (s *OCSProviderServer) GetStorageClaimConfig(ctx context.Context, req *pb.S return nil, status.Errorf(codes.Internal, "failed to get StorageClusterPeerList. %v", err) } replicationEnabled := len(scp.Items) > 0 - var replicationID string - if replicationEnabled { - replicationID = util.CalculateMD5Hash(req.StorageClaimName) - } + replicationID := req.StorageClaimName var extR []*pb.ExternalResource diff --git a/services/provider/server/server_test.go b/services/provider/server/server_test.go index 80a3445953..acbe685709 100644 --- a/services/provider/server/server_test.go +++ b/services/provider/server/server_test.go @@ -665,7 +665,7 @@ func TestOCSProviderServerGetStorageClaimConfig(t *testing.T) { "mirroringMode": "snapshot", }, Labels: map[string]string{ - "ramendr.openshift.io/replicationid": "", + "ramendr.openshift.io/replicationid": "block-pool-claim", "ramendr.openshift.io/storageID": "8d40b6be71600457b5dec219d2ce2d4c", }, Annotations: map[string]string{ @@ -682,7 +682,7 @@ func TestOCSProviderServerGetStorageClaimConfig(t *testing.T) { }, Labels: map[string]string{ "replication.storage.openshift.io/flatten-mode": "force", - "ramendr.openshift.io/replicationid": "", + "ramendr.openshift.io/replicationid": "block-pool-claim", "ramendr.openshift.io/storageID": "8d40b6be71600457b5dec219d2ce2d4c", }, Annotations: map[string]string{},