aoqi@0: /* aoqi@0: * Copyright 2012 SAP AG. All Rights Reserved. aoqi@0: * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. aoqi@0: * aoqi@0: * This code is free software; you can redistribute it and/or modify it aoqi@0: * under the terms of the GNU General Public License version 2 only, as aoqi@0: * published by the Free Software Foundation. aoqi@0: * aoqi@0: * This code is distributed in the hope that it will be useful, but WITHOUT aoqi@0: * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or aoqi@0: * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License aoqi@0: * version 2 for more details (a copy is included in the LICENSE file that aoqi@0: * accompanied this code). aoqi@0: * aoqi@0: * You should have received a copy of the GNU General Public License version aoqi@0: * 2 along with this work; if not, write to the Free Software Foundation, aoqi@0: * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. aoqi@0: * aoqi@0: * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA aoqi@0: * or visit www.oracle.com if you need additional information or have any aoqi@0: * questions. aoqi@0: */ aoqi@0: aoqi@0: /* aoqi@0: * @test FieldMonitor.java aoqi@0: * @bug 7158988 aoqi@0: * @key regression aoqi@0: * @summary verify jvm does not crash while debugging aoqi@0: * @run compile TestPostFieldModification.java aoqi@0: * @run main/othervm FieldMonitor aoqi@0: * @author axel.siebenborn@sap.com aoqi@0: */ aoqi@0: import java.io.BufferedReader; aoqi@0: import java.io.IOException; aoqi@0: import java.io.InputStream; aoqi@0: import java.io.InputStreamReader; aoqi@0: import java.util.Iterator; aoqi@0: import java.util.List; aoqi@0: import java.util.Map; aoqi@0: aoqi@0: import com.sun.jdi.Bootstrap; aoqi@0: import com.sun.jdi.Field; aoqi@0: import com.sun.jdi.ReferenceType; aoqi@0: import com.sun.jdi.VirtualMachine; aoqi@0: import com.sun.jdi.connect.Connector; aoqi@0: import com.sun.jdi.connect.IllegalConnectorArgumentsException; aoqi@0: import com.sun.jdi.connect.LaunchingConnector; aoqi@0: import com.sun.jdi.connect.VMStartException; aoqi@0: import com.sun.jdi.event.ClassPrepareEvent; aoqi@0: import com.sun.jdi.event.Event; aoqi@0: import com.sun.jdi.event.EventQueue; aoqi@0: import com.sun.jdi.event.EventSet; aoqi@0: import com.sun.jdi.event.ModificationWatchpointEvent; aoqi@0: import com.sun.jdi.event.VMDeathEvent; aoqi@0: import com.sun.jdi.event.VMStartEvent; aoqi@0: import com.sun.jdi.event.VMDisconnectEvent; aoqi@0: import com.sun.jdi.request.ClassPrepareRequest; aoqi@0: import com.sun.jdi.request.EventRequest; aoqi@0: import com.sun.jdi.request.EventRequestManager; aoqi@0: import com.sun.jdi.request.ModificationWatchpointRequest; aoqi@0: aoqi@0: public class FieldMonitor { aoqi@0: aoqi@0: public static final String CLASS_NAME = "TestPostFieldModification"; aoqi@0: public static final String FIELD_NAME = "value"; aoqi@0: public static final String ARGUMENTS = "-Xshare:off -XX:+PrintGC"; aoqi@0: aoqi@0: public static void main(String[] args) aoqi@0: throws IOException, InterruptedException { aoqi@0: aoqi@0: //VirtualMachine vm = launchTarget(sb.toString()); aoqi@0: VirtualMachine vm = launchTarget(CLASS_NAME); aoqi@0: aoqi@0: System.out.println("Vm launched"); aoqi@0: aoqi@0: // process events aoqi@0: EventQueue eventQueue = vm.eventQueue(); aoqi@0: // resume the vm aoqi@0: aoqi@0: Process process = vm.process(); aoqi@0: aoqi@0: aoqi@0: // Copy target's output and error to our output and error. aoqi@0: Thread outThread = new StreamRedirectThread("out reader", process.getInputStream()); aoqi@0: Thread errThread = new StreamRedirectThread("error reader", process.getErrorStream()); aoqi@0: aoqi@0: errThread.start(); aoqi@0: outThread.start(); aoqi@0: aoqi@0: boolean connected = true; aoqi@0: int watched = 0; aoqi@0: while (connected) { aoqi@0: EventSet eventSet = eventQueue.remove(); aoqi@0: for (Event event : eventSet) { aoqi@0: System.out.println("FieldMonitor-main receives: "+event); aoqi@0: if (event instanceof VMStartEvent) { aoqi@0: addClassWatch(vm); aoqi@0: } else if (event instanceof VMDeathEvent aoqi@0: || event instanceof VMDisconnectEvent) { aoqi@0: // exit aoqi@0: connected = false; aoqi@0: } else if (event instanceof ClassPrepareEvent) { aoqi@0: // watch field on loaded class aoqi@0: System.out.println("ClassPrepareEvent"); aoqi@0: ClassPrepareEvent classPrepEvent = (ClassPrepareEvent) event; aoqi@0: ReferenceType refType = classPrepEvent aoqi@0: .referenceType(); aoqi@0: addFieldWatch(vm, refType); aoqi@0: } else if (event instanceof ModificationWatchpointEvent) { aoqi@0: watched++; aoqi@0: System.out.println("sleep for 500 ms"); aoqi@0: Thread.sleep(500); aoqi@0: aoqi@0: ModificationWatchpointEvent modEvent = (ModificationWatchpointEvent) event; aoqi@0: System.out.println("old=" aoqi@0: + modEvent.valueCurrent()); aoqi@0: System.out.println("new=" + modEvent.valueToBe()); aoqi@0: } aoqi@0: } aoqi@0: System.out.println("resume..."); aoqi@0: eventSet.resume(); aoqi@0: } aoqi@0: // Shutdown begins when event thread terminates aoqi@0: try { aoqi@0: errThread.join(); // Make sure output is forwarded aoqi@0: outThread.join(); aoqi@0: } catch (InterruptedException exc) { aoqi@0: // we don't interrupt aoqi@0: } aoqi@0: aoqi@0: if (watched != 11) { // init + 10 modifications in TestPostFieldModification class aoqi@0: throw new Error("Expected to receive 11 times ModificationWatchpointEvent, but got "+watched); aoqi@0: } aoqi@0: } aoqi@0: aoqi@0: /** aoqi@0: * Find a com.sun.jdi.CommandLineLaunch connector aoqi@0: */ aoqi@0: static LaunchingConnector findLaunchingConnector() { aoqi@0: List connectors = Bootstrap.virtualMachineManager().allConnectors(); aoqi@0: Iterator iter = connectors.iterator(); aoqi@0: while (iter.hasNext()) { aoqi@0: Connector connector = iter.next(); aoqi@0: if (connector.name().equals("com.sun.jdi.CommandLineLaunch")) { aoqi@0: return (LaunchingConnector)connector; aoqi@0: } aoqi@0: } aoqi@0: throw new Error("No launching connector"); aoqi@0: } aoqi@0: /** aoqi@0: * Return the launching connector's arguments. aoqi@0: */ aoqi@0: static Map connectorArguments(LaunchingConnector connector, String mainArgs) { aoqi@0: Map arguments = connector.defaultArguments(); aoqi@0: for (String key : arguments.keySet()) { aoqi@0: System.out.println(key); aoqi@0: } aoqi@0: aoqi@0: Connector.Argument mainArg = (Connector.Argument)arguments.get("main"); aoqi@0: if (mainArg == null) { aoqi@0: throw new Error("Bad launching connector"); aoqi@0: } aoqi@0: mainArg.setValue(mainArgs); aoqi@0: aoqi@0: Connector.Argument optionsArg = (Connector.Argument)arguments.get("options"); aoqi@0: if (optionsArg == null) { aoqi@0: throw new Error("Bad launching connector"); aoqi@0: } aoqi@0: optionsArg.setValue(ARGUMENTS); aoqi@0: return arguments; aoqi@0: } aoqi@0: aoqi@0: static VirtualMachine launchTarget(String mainArgs) { aoqi@0: LaunchingConnector connector = findLaunchingConnector(); aoqi@0: Map arguments = connectorArguments(connector, mainArgs); aoqi@0: try { aoqi@0: return (VirtualMachine) connector.launch(arguments); aoqi@0: } catch (IOException exc) { aoqi@0: throw new Error("Unable to launch target VM: " + exc); aoqi@0: } catch (IllegalConnectorArgumentsException exc) { aoqi@0: throw new Error("Internal error: " + exc); aoqi@0: } catch (VMStartException exc) { aoqi@0: throw new Error("Target VM failed to initialize: " + aoqi@0: exc.getMessage()); aoqi@0: } aoqi@0: } aoqi@0: aoqi@0: aoqi@0: private static void addClassWatch(VirtualMachine vm) { aoqi@0: EventRequestManager erm = vm.eventRequestManager(); aoqi@0: ClassPrepareRequest classPrepareRequest = erm aoqi@0: .createClassPrepareRequest(); aoqi@0: classPrepareRequest.addClassFilter(CLASS_NAME); aoqi@0: classPrepareRequest.setEnabled(true); aoqi@0: } aoqi@0: aoqi@0: aoqi@0: private static void addFieldWatch(VirtualMachine vm, aoqi@0: ReferenceType refType) { aoqi@0: EventRequestManager erm = vm.eventRequestManager(); aoqi@0: Field field = refType.fieldByName(FIELD_NAME); aoqi@0: ModificationWatchpointRequest modificationWatchpointRequest = erm aoqi@0: .createModificationWatchpointRequest(field); aoqi@0: modificationWatchpointRequest.setSuspendPolicy(EventRequest.SUSPEND_EVENT_THREAD); aoqi@0: modificationWatchpointRequest.setEnabled(true); aoqi@0: } aoqi@0: } aoqi@0: aoqi@0: class StreamRedirectThread extends Thread { aoqi@0: aoqi@0: private final BufferedReader in; aoqi@0: aoqi@0: private static final int BUFFER_SIZE = 2048; aoqi@0: aoqi@0: /** aoqi@0: * Set up for copy. aoqi@0: * @param name Name of the thread aoqi@0: * @param in Stream to copy from aoqi@0: * @param out Stream to copy to aoqi@0: */ aoqi@0: StreamRedirectThread(String name, InputStream in) { aoqi@0: super(name); aoqi@0: this.in = new BufferedReader(new InputStreamReader(in)); aoqi@0: } aoqi@0: aoqi@0: /** aoqi@0: * Copy. aoqi@0: */ aoqi@0: public void run() { aoqi@0: try { aoqi@0: String line; aoqi@0: while ((line = in.readLine ()) != null) { aoqi@0: System.out.println ("testvm: " + line); aoqi@0: } aoqi@0: System.out.flush(); aoqi@0: } catch(IOException exc) { aoqi@0: System.err.println("Child I/O Transfer - " + exc); aoqi@0: } aoqi@0: } aoqi@0: }