diff -r 4ebc2e2fb97c -r 71c04702a3d5 test/jdk/sun/management/jdp/JdpOnTestCase.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/test/jdk/sun/management/jdp/JdpOnTestCase.java Tue Sep 12 19:03:39 2017 +0200 @@ -0,0 +1,108 @@ +/* + * Copyright (c) 2013, 2017, 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 + * under the terms of the GNU General Public License version 2 only, as + * published by the Free Software Foundation. + * + * This code is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * version 2 for more details (a copy is included in the LICENSE file that + * accompanied this code). + * + * You should have received a copy of the GNU General Public License version + * 2 along with this work; if not, write to the Free Software Foundation, + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. + * + * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA + * or visit www.oracle.com if you need additional information or have any + * questions. + */ + +/** + * A JVM with JDP on should send multicast JDP packets regularly. + * + * See main for more information on running this test manually. + * See Launcher classes for automated runs. + * + */ + +import java.net.SocketTimeoutException; +import java.util.Map; +import static jdk.testlibrary.Asserts.assertNotEquals; + +public class JdpOnTestCase extends JdpTestCase { + + private int receivedJDPpackets = 0; + + public JdpOnTestCase(ClientConnection connection) { + super(connection); + } + + /** + * Subclasses: JdpOnTestCase and JdpOffTestCase have different messages. + */ + @Override + protected String initialLogMessage() { + return "Waiting for 3 packets with jdp.name=" + connection.instanceName; + } + + /** + * This method is executed after a correct Jdp packet (coming from this VM) has been received. + * + * @param payload A dictionary containing the data if the received Jdp packet. + */ + protected void packetFromThisVMReceived(Map payload) { + receivedJDPpackets++; + final String jdpName = payload.get("INSTANCE_NAME"); + log.fine("Received correct JDP packet #" + String.valueOf(receivedJDPpackets) + + ", jdp.name=" + jdpName); + assertNotEquals(null, payload.get("PROCESS_ID"), "Expected payload.get(\"PROCESS_ID\") to be not null."); + } + + /** + * The socket should not timeout. + * It is set to wait for 10 times the defined pause between Jdp packet. See JdpOnTestCase.TIME_OUT_FACTOR. + */ + @Override + protected void onSocketTimeOut(SocketTimeoutException e) throws Exception { + String message = "Timed out waiting for JDP packet. Should arrive within " + + connection.pauseInSeconds + " seconds, but waited for " + + timeOut + " seconds."; + log.severe(message); + throw new Exception(message, e); + } + + /** + * After receiving three Jdp packets the test should end. + */ + @Override + protected boolean shouldContinue() { + return receivedJDPpackets < 3; + } + + /** + * To run this test manually you might need the following VM options: + *

+ * -Dcom.sun.management.jmxremote.authenticate=false + * -Dcom.sun.management.jmxremote.ssl=false + * -Dcom.sun.management.jmxremote.port=4711 (or some other port number) + * -Dcom.sun.management.jmxremote=true + * -Dcom.sun.management.jmxremote.autodiscovery=true + * -Dcom.sun.management.jdp.pause=1 + * -Dcom.sun.management.jdp.name=alex (or some other string to identify this VM) + *

+ * Recommended for nice output: + * -Djava.util.logging.SimpleFormatter.format="%1$tF %1$tT %4$-7s %5$s %n" + * + * @param args + * @throws Exception + */ + public static void main(String[] args) throws Exception { + JdpTestCase client = new JdpOnTestCase(new ClientConnection()); + client.run(); + } + +}