test/runtime/NMT/ThreadedVirtualAllocTestType.java

Wed, 27 Apr 2016 01:25:04 +0800

author
aoqi
date
Wed, 27 Apr 2016 01:25:04 +0800
changeset 0
f90c822e73f8
child 6876
710a3c8b516e
permissions
-rw-r--r--

Initial load
http://hg.openjdk.java.net/jdk8u/jdk8u/hotspot/
changeset: 6782:28b50d07f6f8
tag: jdk8u25-b17

     1 /*
     2  * Copyright (c) 2013, Oracle and/or its affiliates. All rights reserved.
     3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
     4  *
     5  * This code is free software; you can redistribute it and/or modify it
     6  * under the terms of the GNU General Public License version 2 only, as
     7  * published by the Free Software Foundation.
     8  *
     9  * This code is distributed in the hope that it will be useful, but WITHOUT
    10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
    11  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
    12  * version 2 for more details (a copy is included in the LICENSE file that
    13  * accompanied this code).
    14  *
    15  * You should have received a copy of the GNU General Public License version
    16  * 2 along with this work; if not, write to the Free Software Foundation,
    17  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
    18  *
    19  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
    20  * or visit www.oracle.com if you need additional information or have any
    21  * questions.
    22  */
    24 /*
    25  * @test
    26  * @key nmt jcmd
    27  * @library /testlibrary /testlibrary/whitebox
    28  * @build ThreadedVirtualAllocTestType
    29  * @run main ClassFileInstaller sun.hotspot.WhiteBox
    30  * @run main/othervm -Xbootclasspath/a:. -XX:+UnlockDiagnosticVMOptions -XX:+WhiteBoxAPI -XX:NativeMemoryTracking=detail ThreadedVirtualAllocTestType
    31  */
    33 import com.oracle.java.testlibrary.*;
    34 import sun.hotspot.WhiteBox;
    36 public class ThreadedVirtualAllocTestType {
    37   public static long addr;
    38   public static final WhiteBox wb = WhiteBox.getWhiteBox();
    39   public static final long commitSize = 128 * 1024;
    40   public static final long reserveSize = 512 * 1024;
    42   public static void main(String args[]) throws Exception {
    43     OutputAnalyzer output;
    45     String pid = Integer.toString(ProcessTools.getProcessId());
    46     ProcessBuilder pb = new ProcessBuilder();
    48     boolean has_nmt_detail = wb.NMTIsDetailSupported();
    49     if (has_nmt_detail) {
    50       System.out.println("NMT detail support detected.");
    51     } else {
    52       System.out.println("NMT detail support not detected.");
    53     }
    55     Thread reserveThread = new Thread() {
    56       public void run() {
    57         addr = wb.NMTReserveMemory(reserveSize);
    58       }
    59     };
    60     reserveThread.start();
    61     reserveThread.join();
    63     mergeData();
    65     pb.command(new String[] { JDKToolFinder.getJDKTool("jcmd"), pid, "VM.native_memory", "detail"});
    66     output = new OutputAnalyzer(pb.start());
    67     output.shouldContain("Test (reserved=512KB, committed=0KB)");
    68     if (has_nmt_detail) {
    69       output.shouldMatch("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + reserveSize) + "\\] reserved 512KB for Test");
    70     }
    72     Thread commitThread = new Thread() {
    73       public void run() {
    74         wb.NMTCommitMemory(addr, commitSize);
    75       }
    76     };
    77     commitThread.start();
    78     commitThread.join();
    80     mergeData();
    82     output = new OutputAnalyzer(pb.start());
    83     output.shouldContain("Test (reserved=512KB, committed=128KB)");
    84     if (has_nmt_detail) {
    85       output.shouldMatch("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + commitSize) + "\\] committed 128KB");
    86     }
    88     Thread uncommitThread = new Thread() {
    89       public void run() {
    90         wb.NMTUncommitMemory(addr, commitSize);
    91       }
    92     };
    93     uncommitThread.start();
    94     uncommitThread.join();
    96     mergeData();
    98     output = new OutputAnalyzer(pb.start());
    99     output.shouldContain("Test (reserved=512KB, committed=0KB)");
   100     output.shouldNotMatch("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + commitSize) + "\\] committed");
   102     Thread releaseThread = new Thread() {
   103       public void run() {
   104         wb.NMTReleaseMemory(addr, reserveSize);
   105       }
   106     };
   107     releaseThread.start();
   108     releaseThread.join();
   110     mergeData();
   112     output = new OutputAnalyzer(pb.start());
   113     output.shouldNotContain("Test (reserved=");
   114     output.shouldNotContain("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + reserveSize) + "\\] reserved");
   115   }
   117   public static void mergeData() throws Exception {
   118     // Use WB API to ensure that all data has been merged before we continue
   119     if (!wb.NMTWaitForDataMerge()) {
   120       throw new Exception("Call to WB API NMTWaitForDataMerge() failed");
   121     }
   122   }
   123 }

mercurial