Skip to content

Commit

Permalink
Update pmax_replication_integration_test.go
Browse files Browse the repository at this point in the history
Added the delay in the CleanRDFPair
  • Loading branch information
tssushma authored Nov 24, 2023
1 parent ff1318c commit b80e9b4
Showing 1 changed file with 9 additions and 2 deletions.
11 changes: 9 additions & 2 deletions inttest/pmax_replication_integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down Expand Up @@ -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

Expand Down

0 comments on commit b80e9b4

Please sign in to comment.