From ff1318c0809c35e4de89573cb986f940fa51a219 Mon Sep 17 00:00:00 2001 From: Utkarsh Dubey Date: Fri, 24 Nov 2023 10:23:35 +0530 Subject: [PATCH 1/2] Corrects Lint issues --- mock/mock.go | 1 + 1 file changed, 1 insertion(+) diff --git a/mock/mock.go b/mock/mock.go index c7d5529..1dfc3a4 100644 --- a/mock/mock.go +++ b/mock/mock.go @@ -1229,6 +1229,7 @@ func handleSGRDFAction(w http.ResponseWriter, r *http.Request) { PerformActionOnRDFSG(w, rdfNo, action) } +// PerformActionOnRDFSG updates rdfNo with given action func PerformActionOnRDFSG(w http.ResponseWriter, rdfNo, action string) { mockCacheMutex.Lock() defer mockCacheMutex.Unlock() From b80e9b4064131b2ea5f8da809ed93b842a17dd1a Mon Sep 17 00:00:00 2001 From: tssushma <98810659+tssushma@users.noreply.github.com> Date: Fri, 24 Nov 2023 15:26:15 +0530 Subject: [PATCH 2/2] Update pmax_replication_integration_test.go Added the delay in the CleanRDFPair --- inttest/pmax_replication_integration_test.go | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/inttest/pmax_replication_integration_test.go b/inttest/pmax_replication_integration_test.go index 3e66446..146e63e 100644 --- a/inttest/pmax_replication_integration_test.go +++ b/inttest/pmax_replication_integration_test.go @@ -723,20 +723,24 @@ func TestExecuteReplicationActionOnSG(t *testing.T) { } fmt.Printf("Volume in Protected Storage Group created successfully: %v\n", vol) - fmt.Printf("Waiting for 10 minutes \n") - time.Sleep(600 * time.Second) + fmt.Printf("Waiting for 2 minutes \n") + time.Sleep(120 * time.Second) err = client.ExecuteReplicationActionOnSG(context.TODO(), symmetrixID, "Suspend", defaultProtectedStorageGroup, localRDFGrpNo, true, true, false) if err != nil { t.Errorf("Error in suspending the RDF relation in Protected Storage Group: %s", err.Error()) return } + fmt.Printf("Waiting for 2 minutes \n") + time.Sleep(120 * time.Second) err = client.ExecuteReplicationActionOnSG(context.TODO(), symmetrixID, "Resume", defaultProtectedStorageGroup, localRDFGrpNo, true, true, false) if err != nil { t.Errorf("Error in resuming the RDF relation in Protected Storage Group: %s", err.Error()) return } + fmt.Printf("Waiting for 2 minutes \n") + time.Sleep(120 * time.Second) cleanupRDFPair(vol.VolumeID, volumeName, defaultProtectedStorageGroup, t) } @@ -884,6 +888,9 @@ func cleanupRDFPair(volumeID string, _ string, _ string, t *testing.T) { t.Errorf("Error retrieving RDF device pair information: %s", err.Error()) return } + fmt.Printf("RDF INFO %v", rdfPair) + fmt.Printf("Waiting for 2 minutes \n") + time.Sleep(120 * time.Second) // Terminating the Pair and removing the volumes from local SG and remote SG