Use golang cleanup and fix TestVolumeUnmount (#1026)

Author: RamSubbarao

test/container/devconfig_test.go

@@ -46,7 +46,7 @@ func TestDevGoldenPath(t *testing.T) {
 		},
 	}
 	id := runContainer(t, cli, &containerConfig, withPorts(9443, 1414))
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	waitForReady(t, cli, id)
 	waitForWebReady(t, cli, id, insecureTLSConfig)
 	t.Run("JMS", func(t *testing.T) {
@@ -111,7 +111,7 @@ func TestDevSecure(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 	cert := filepath.Join(tlsDir(t, true), "server.crt")
@@ -146,7 +146,7 @@ func TestDevWebDisabled(t *testing.T) {
 		},
 	}
 	id := runContainer(t, cli, &containerConfig, withPorts(1414))
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	waitForReady(t, cli, id)
 	t.Run("Web", func(t *testing.T) {
 		_, dspmqweb := cli.ExecContainer(id, "", []string{"dspmqweb"})
@@ -176,7 +176,7 @@ func TestDevConfigDisabled(t *testing.T) {
 		},
 	}
 	id := runContainer(t, cli, &containerConfig, withPorts(9443))
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	waitForReady(t, cli, id)
 	rc, _ := execContainer(t, cli, id, "", []string{"bash", "-c", "echo 'display qlocal(DEV*)' | runmqsc"})
 	if rc == 0 {
@@ -200,7 +200,7 @@ func TestSSLKEYRBlank(t *testing.T) {
 		},
 	}
 	id := runContainer(t, cli, &containerConfig, withPorts(9443))
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	waitForReady(t, cli, id)
 
 	// execute runmqsc to display qmgr SSLKEYR and CERTLABL attibutes.
@@ -256,7 +256,7 @@ func TestSSLKEYRWithSuppliedKeyAndCert(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -323,7 +323,7 @@ func TestSSLKEYRWithCACert(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -386,7 +386,7 @@ func TestSSLFIPSNO(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -447,7 +447,7 @@ func TestSSLFIPSYES(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -527,7 +527,7 @@ func TestDevSecureFIPSTrueWeb(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
@@ -598,7 +598,7 @@ func TestDevSecureFalseFIPSWeb(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -649,7 +649,7 @@ func TestSSLFIPSTrueNoCerts(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -697,7 +697,7 @@ func TestSSLFIPSInvalidValue(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 	waitForReady(t, cli, ID)
 
@@ -746,7 +746,7 @@ func TestSSLFIPSBadCerts(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, ID, false)
+	cleanupAfterTest(t, cli, ID, false)
 	startContainer(t, cli, ID)
 
 	rc := waitForContainer(t, cli, ID, 20*time.Second)
@@ -784,7 +784,7 @@ func TestDevNoDefCreds(t *testing.T) {
 		},
 	}
 	id := runContainer(t, cli, &containerConfig, withPorts(9443, 1414))
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	waitForReady(t, cli, id)
 	waitForWebReady(t, cli, id, insecureTLSConfig)
 	// Expect a 401 Unauthorized HTTP Response
@@ -829,7 +829,7 @@ func testDevNoDefaultCredsUtil(t *testing.T, mqsimpleauthEnvs []string, htpwdInL
 	containerConfig.Env = append(containerConfig.Env, mqsimpleauthEnvs...)
 
 	id := runContainer(t, cli, &containerConfig, withPorts(1414))
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	waitForReady(t, cli, id)
 	defer stopContainer(t, cli, id)
 
@@ -868,11 +868,11 @@ func TestRORFSDevNoAppPassword(t *testing.T) {
 
 	// Create volumes for mounting into container
 	ephData := createVolume(t, cli, "ephData"+t.Name())
-	defer removeVolume(t, cli, ephData)
+	cleanupVolume(t, cli, ephData)
 	ephRun := createVolume(t, cli, "ephRun"+t.Name())
-	defer removeVolume(t, cli, ephRun)
+	cleanupVolume(t, cli, ephRun)
 	ephTmp := createVolume(t, cli, "ephTmp"+t.Name())
-	defer removeVolume(t, cli, ephTmp)
+	cleanupVolume(t, cli, ephTmp)
 
 	hostConfig := ce.ContainerHostConfig{
 		Binds: []string{
@@ -899,7 +899,7 @@ func TestRORFSDevNoAppPassword(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	defer cleanContainer(t, cli, id, false)
+	cleanupAfterTest(t, cli, id, false)
 	startContainer(t, cli, id)
 
 	waitForReady(t, cli, id)

test/container/devconfig_test_util.go

@@ -62,7 +62,7 @@ func waitForWebReady(t *testing.T, cli ce.ContainerInterface, ID string, tlsConf
 		t.Fatal(err)
 	}
 	url := fmt.Sprintf("https://localhost:%s/ibmmq/rest/v1/admin/installation", port)
-	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Minute)
+	ctx, cancel := context.WithTimeout(context.Background(), 4*time.Minute)
 	defer cancel()
 
 	for {
@@ -152,7 +152,7 @@ func runJMSTests(t *testing.T, cli ce.ContainerInterface, ID string, tls bool, u
 		}
 	}
 
-	defer cleanContainer(t, cli, jmsID, false)
+	cleanupAfterTest(t, cli, jmsID, false)
 }
 
 // Parse JUnit log line and return true if line contains failed or aborted tests