Skip to content

Commit

Permalink
Merge pull request #56 from dell/lint-issue
Browse files Browse the repository at this point in the history
Corrects Lint issues
  • Loading branch information
gallacher authored Nov 28, 2023
2 parents 2728104 + b80e9b4 commit 839e45e
Show file tree
Hide file tree
Showing 2 changed files with 10 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
1 change: 1 addition & 0 deletions mock/mock.go
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down

0 comments on commit 839e45e

Please sign in to comment.