infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-02-23 16:55:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

8212220: add code to verify results to metaspace/stressDictionary/StressDictionary.java

Browse Source 
Also change the test's default timeout to 5 minutes.

Reviewed-by: dholmes, stuefe
This commit is contained in:
Daniel D. Daugherty 2018-10-24 11:04:25 -04:00
parent 3a48e68b1a
commit daf4ad38ab
1 changed files with 45 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
test/hotspot/jtreg/vmTestbase/metaspace/stressDictionary/StressDictionary.java
View File

@ -29,7 +29,7 @@
*
* @library /vmTestbase /test/lib
* @run driver jdk.test.lib.FileInstaller . .
* @run main/othervm metaspace.stressDictionary.StressDictionary -stressTime 30
* @run main/othervm/timeout=300 metaspace.stressDictionary.StressDictionary -stressTime 30
*/
package metaspace.stressDictionary;
@ -123,11 +123,54 @@ public class StressDictionary extends GCTestBase {
tasks.add(this.new RegularWorker());
}
ExecutorService executorService = Executors.newCachedThreadPool();
List<Future<Object>> results = null;
try {
executorService.invokeAll(tasks);
results = executorService.invokeAll(tasks);
} catch (InterruptedException e) {
e.printStackTrace();
}
int act_results = results.size();
int exp_results = NUMBER_OF_CORRUPTING_THREADS +
NUMBER_OF_NOT_CORRUPTING_THREADS;
if (act_results == exp_results) {
System.err.println("INFO: There are " + act_results + " results.");
} else {
throw new RuntimeException("Wrong # of results from invokeAll(); "
+ "exp_results=" + exp_results + "; "
+ "act_results=" + act_results + ".");
}
int cancelled_cnt = 0;
int not_done_cnt = 0;
for (int i = 0; i < act_results; i++) {
if (!results.get(i).isDone()) {
not_done_cnt++;
System.err.println("ERROR: task #" + i + " is not done.");
}
if (results.get(i).isCancelled()) {
cancelled_cnt++;
System.err.println("ERROR: task #" + i + " was canceled.");
}
}
if (cancelled_cnt == 0) {
System.err.println("INFO: no tasks were cancelled.");
}
if (not_done_cnt == 0) {
System.err.println("INFO: all tasks are done.");
}
if (cancelled_cnt != 0 && not_done_cnt != 0) {
throw new RuntimeException(cancelled_cnt
+ " tasks were cancelled and "
+ not_done_cnt
+ " tasks are not done.");
} else if (cancelled_cnt != 0) {
throw new RuntimeException(cancelled_cnt
+ " tasks were cancelled.");
} else if (not_done_cnt != 0) {
throw new RuntimeException(not_done_cnt + " tasks are not done.");
}
}
private byte[] generateAndCompile() {