test/runtime/NMT/ThreadedVirtualAllocTestType.java

Thu, 16 May 2013 12:14:19 -0700

author
katleman
date
Thu, 16 May 2013 12:14:19 -0700
changeset 5082
1cdbd42c3e49
parent 4885
3b890cd4da64
child 5586
5fd8e2fbafd4
permissions
-rw-r--r--

Added tag jdk8-b90 for changeset 1ae0472ff3a0

     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     Thread reserveThread = new Thread() {
    49       public void run() {
    50         addr = wb.NMTReserveMemory(reserveSize);
    51       }
    52     };
    53     reserveThread.start();
    54     reserveThread.join();
    56     mergeData();
    58     pb.command(new String[] { JDKToolFinder.getJDKTool("jcmd"), pid, "VM.native_memory", "detail"});
    59     output = new OutputAnalyzer(pb.start());
    60     output.shouldContain("Test (reserved=512KB, committed=0KB)");
    61     output.shouldMatch("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + reserveSize) + "\\] reserved 512KB for Test");
    63     Thread commitThread = new Thread() {
    64       public void run() {
    65         wb.NMTCommitMemory(addr, commitSize);
    66       }
    67     };
    68     commitThread.start();
    69     commitThread.join();
    71     mergeData();
    73     output = new OutputAnalyzer(pb.start());
    74     output.shouldContain("Test (reserved=512KB, committed=128KB)");
    75     output.shouldMatch("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + commitSize) + "\\] committed 128KB");
    77     Thread uncommitThread = new Thread() {
    78       public void run() {
    79         wb.NMTUncommitMemory(addr, commitSize);
    80       }
    81     };
    82     uncommitThread.start();
    83     uncommitThread.join();
    85     mergeData();
    87     output = new OutputAnalyzer(pb.start());
    88     output.shouldContain("Test (reserved=512KB, committed=0KB)");
    89     output.shouldNotMatch("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + commitSize) + "\\] committed");
    91     Thread releaseThread = new Thread() {
    92       public void run() {
    93         wb.NMTReleaseMemory(addr, reserveSize);
    94       }
    95     };
    96     releaseThread.start();
    97     releaseThread.join();
    99     mergeData();
   101     output = new OutputAnalyzer(pb.start());
   102     output.shouldNotContain("Test (reserved=");
   103     output.shouldNotContain("\\[0x[0]*" + Long.toHexString(addr) + " - 0x[0]*" + Long.toHexString(addr + reserveSize) + "\\] reserved");
   104   }
   106   public static void mergeData() throws Exception {
   107     // Use WB API to ensure that all data has been merged before we continue
   108     if (!wb.NMTWaitForDataMerge()) {
   109       throw new Exception("Call to WB API NMTWaitForDataMerge() failed");
   110     }
   111   }
   112 }

mercurial