test/hotspot/jtreg/serviceability/sa/TestClhsdbJstackLock.java
changeset 53635 247e5ca412f5
parent 50791 b1e90a8a876c
--- a/test/hotspot/jtreg/serviceability/sa/TestClhsdbJstackLock.java	Mon Feb 04 17:35:38 2019 -0800
+++ b/test/hotspot/jtreg/serviceability/sa/TestClhsdbJstackLock.java	Tue Feb 05 00:43:38 2019 +0530
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017, 2018, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2017, 2019, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
@@ -22,19 +22,12 @@
  */
 
 import java.util.ArrayList;
-import java.util.Scanner;
 import java.util.List;
-import java.io.File;
-import java.io.IOException;
-import java.util.stream.Collectors;
-import java.io.OutputStream;
 import jdk.test.lib.apps.LingeredApp;
-import jdk.test.lib.JDKToolLauncher;
-import jdk.test.lib.Platform;
-import jdk.test.lib.process.ProcessTools;
-import jdk.test.lib.process.OutputAnalyzer;
 import jdk.test.lib.Utils;
-import jdk.test.lib.Asserts;
+import java.util.Map;
+import java.util.HashMap;
+import jtreg.SkippedException;
 
 /**
  * @test
@@ -45,117 +38,39 @@
 
 public class TestClhsdbJstackLock {
 
-    private static final String JSTACK_OUT_FILE = "jstack_out.txt";
-
-    private static void verifyJStackOutput() throws Exception {
-
-        Exception unexpected = null;
-        File jstackFile = new File(JSTACK_OUT_FILE);
-        Asserts.assertTrue(jstackFile.exists() && jstackFile.isFile(),
-                           "File with jstack output not created: " +
-                           jstackFile.getAbsolutePath());
+    public static void main (String... args) throws Exception {
+        System.out.println("Starting TestClhsdbJstackLock test");
+        LingeredAppWithLock app = null;
         try {
-            Scanner scanner = new Scanner(jstackFile);
-
-            boolean classLockOwnerFound = false;
-            boolean classLockWaiterFound = false;
-            boolean objectLockOwnerFound = false;
-            boolean primitiveLockOwnerFound = false;
-
-            while (scanner.hasNextLine()) {
-                String line = scanner.nextLine();
-                System.out.println(line);
-
-                if (line.contains("missing reason for ")) {
-                    unexpected = new RuntimeException("Unexpected msg: missing reason for ");
-                    break;
-                }
-                if (line.matches("^\\s+- locked <0x[0-9a-f]+> \\(a java\\.lang\\.Class for LingeredAppWithLock\\)$")) {
-                    classLockOwnerFound = true;
-                }
-                if (line.matches("^\\s+- waiting to lock <0x[0-9a-f]+> \\(a java\\.lang\\.Class for LingeredAppWithLock\\)$")) {
-                    classLockWaiterFound = true;
-                }
-                if (line.matches("^\\s+- locked <0x[0-9a-f]+> \\(a java\\.lang\\.Thread\\)$")) {
-                    objectLockOwnerFound = true;
-                }
-                if (line.matches("^\\s+- locked <0x[0-9a-f]+> \\(a java\\.lang\\.Class for int\\)$")) {
-                    primitiveLockOwnerFound = true;
-                }
-            }
-
-            if (!classLockOwnerFound || !classLockWaiterFound ||
-                !objectLockOwnerFound || !primitiveLockOwnerFound) {
-                unexpected = new RuntimeException(
-                      "classLockOwnerFound = " + classLockOwnerFound +
-                      ", classLockWaiterFound = " + classLockWaiterFound +
-                      ", objectLockOwnerFound = " + objectLockOwnerFound +
-                      ", primitiveLockOwnerFound = " + primitiveLockOwnerFound);
-            }
-            if (unexpected != null) {
-                throw unexpected;
-            }
-        } catch (Exception ex) {
-            throw new RuntimeException("Test ERROR " + ex, ex);
-        } finally {
-            jstackFile.delete();
-        }
-    }
-
-    private static void startClhsdbForLock(long lingeredAppPid) throws Exception {
-
-        Process p;
-        JDKToolLauncher launcher = JDKToolLauncher.createUsingTestJDK("jhsdb");
-        launcher.addToolArg("clhsdb");
-        launcher.addToolArg("--pid");
-        launcher.addToolArg(Long.toString(lingeredAppPid));
-
-        ProcessBuilder pb = new ProcessBuilder();
-        pb.command(launcher.getCommand());
-        System.out.println(pb.command().stream().collect(Collectors.joining(" ")));
-
-        try {
-            p = pb.start();
-        } catch (Exception attachE) {
-            throw new Error("Couldn't start jhsdb or attach to LingeredApp : " + attachE);
-        }
-
-        // Issue the 'jstack' input at the clhsdb prompt.
-        OutputStream input = p.getOutputStream();
-        String str = "jstack > " + JSTACK_OUT_FILE + "\nquit\n";
-        try {
-            input.write(str.getBytes());
-            input.flush();
-        } catch (IOException ioe) {
-            throw new Error("Problem issuing the jstack command: " + str, ioe);
-        }
-
-        OutputAnalyzer output = new OutputAnalyzer(p);
-
-        try {
-            p.waitFor();
-        } catch (InterruptedException ie) {
-            p.destroyForcibly();
-            throw new Error("Problem awaiting the child process: " + ie, ie);
-        }
-
-        output.shouldHaveExitValue(0);
-    }
-
-    public static void main (String... args) throws Exception {
-
-        LingeredApp app = null;
-
-        try {
+            ClhsdbLauncher test = new ClhsdbLauncher();
             List<String> vmArgs = new ArrayList<String>(Utils.getVmOptions());
 
             app = new LingeredAppWithLock();
             LingeredApp.startApp(vmArgs, app);
-            System.out.println ("Started LingeredApp with pid " + app.getPid());
-            startClhsdbForLock(app.getPid());
-            verifyJStackOutput();
+
+            System.out.println ("Started LingeredAppWithLock with pid " + app.getPid());
+
+            List<String> cmds = List.of("jstack");
+
+            Map<String, List<String>> expStrMap = new HashMap<>();
+            Map<String, List<String>> unExpStrMap = new HashMap<>();
+            expStrMap.put("jstack", List.of(
+                "^\\s+- locked <0x[0-9a-f]+> \\(a java\\.lang\\.Class for LingeredAppWithLock\\)$",
+                "^\\s+- waiting to lock <0x[0-9a-f]+> \\(a java\\.lang\\.Class for LingeredAppWithLock\\)$",
+                "^\\s+- locked <0x[0-9a-f]+> \\(a java\\.lang\\.Thread\\)$",
+                "^\\s+- locked <0x[0-9a-f]+> \\(a java\\.lang\\.Class for int\\)$"));
+            unExpStrMap.put("jstack", List.of(
+                "missing reason for "));
+            test.run(app.getPid(), cmds, expStrMap, unExpStrMap);
+        } catch (SkippedException se) {
+            throw se;
+        } catch (Exception ex) {
+            throw new RuntimeException("Test ERROR " + ex, ex);
         } finally {
             LingeredApp.stopApp(app);
         }
+
+        System.out.println("Test PASSED");
     }
 }
+