test/hotspot/jtreg/vmTestbase/nsk/jdi/ModificationWatchpointEvent/valueToBe/valuetobe001.java - platform/libcore - Git at Google

 /*
  * Copyright (c) 2001, 2018, 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.
  */

 package nsk.jdi.ModificationWatchpointEvent.valueToBe;

 import com.sun.jdi.*;
 import com.sun.jdi.event.*;
 import com.sun.jdi.request.*;

 import java.io.*;
 import java.util.Iterator;
 import java.util.List;

 import nsk.share.*;
 import nsk.share.jpda.*;
 import nsk.share.jdi.*;


 // This class is the debugger in the test

 public class valuetobe001 {
     static final int PASSED = 0;
     static final int FAILED = 2;
     static final int JCK_STATUS_BASE = 95;

     static final int TIMEOUT_DELTA = 1000; // milliseconds

     static final String COMMAND_READY = "ready";
     static final String COMMAND_QUIT  = "quit";
     static final String COMMAND_GO    = "go";
     static final String COMMAND_DONE  = "done";

     static final String DEBUGEE_NAME  = "nsk.jdi.ModificationWatchpointEvent.valueToBe.valuetobe001a";
     static final String CHECKED_CLASS_NAME = "nsk.jdi.ModificationWatchpointEvent.valueToBe.valuetobe001aCheckedClass";

     static private Debugee debuggee;
     static private VirtualMachine vm;
     static private IOPipe pipe;
     static private Log log;
     static private ArgumentHandler argHandler;
     static private EventSet eventSet;

     static private ReferenceType rType;
     static private ModificationWatchpointRequest wpRequest;
     static private List fieldsList;

     static private volatile boolean testFailed;
     static private volatile boolean done;
     static private volatile int requestsCount, mwpEventsCount;

     public static void main (String args[]) {
         System.exit(run(args, System.out) + JCK_STATUS_BASE);
     }

     public static int run(final String args[], final PrintStream out) {

         testFailed = false;
         requestsCount = 0;
         mwpEventsCount = 0;

         argHandler = new ArgumentHandler(args);
         log = new Log(out, argHandler);

         // launch debuggee
         Binder binder = new Binder(argHandler, log);
         log.display("Connecting to debuggee");
         debuggee = binder.bindToDebugee(DEBUGEE_NAME);
         debuggee.redirectStderr(log, "valuetobe001a >");

         // resume debuggee
         log.display("Resuming debuggee");
         debuggee.resume();

         pipe = debuggee.createIOPipe();
         vm = debuggee.VM();

         // check for debuggee's capabilities
         if (!debuggee.VM().canWatchFieldModification()) {
               log.display("TEST WARNING: test passed because JDI implementation does not support " +
                  "watchpoints for field modification");
               pipe.println(COMMAND_QUIT);
               debuggee.waitFor();
               return PASSED;
         }

         try {

             // wait for debuggee started
             log.display("Waiting for command: " + COMMAND_READY);
             String command = pipe.readln();
             if (!command.equals(COMMAND_READY)) {
                 throw new Failure("TEST BUG: unexpected debuggee's command: " + command);
             }

             // get mirrors
             if ((rType = debuggee.classByName(CHECKED_CLASS_NAME)) == null) {
                 throw new Failure("TEST BUG: cannot find " + CHECKED_CLASS_NAME);
             }

             // create events requests
             log.display("Creating requests for WatchpointEvent");
             EventRequestManager erManager = debuggee.VM().eventRequestManager();
             Iterator fieldsIter;
             try {
                 fieldsList = rType.fields();
                 fieldsIter = fieldsList.iterator();
             } catch (ClassNotPreparedException e) {
                 throw new Failure( "TEST_BUG: " + rType.name() + " is not prepared");
             }
             while (fieldsIter.hasNext()) {
                 Field refField = (Field)fieldsIter.next();
                 if ((wpRequest = erManager.createModificationWatchpointRequest(refField)) == null) {
                     throw new Failure("TEST BUG: unable to create ModificationWatchpointRequest");
                 } else {
                     log.display("ModificationWatchpointRequest for field " +  refField.name() + " created");
                     wpRequest.enable();
                 }
                 requestsCount++;
             }
             log.display("Created total " + requestsCount + " ModificationWatchpointRequests");

             // define separate thread for handling events
             class EventHandler extends Thread {
                   public void run() {
                        eventSet = null;
                        try {
                             // handle events until all events generated and received
                             while ( mwpEventsCount != requestsCount ) {
                                  eventSet = null;
                                  eventSet = vm.eventQueue().remove(TIMEOUT_DELTA);

                                  if (eventSet == null)
                                      continue;

                                  EventIterator eventIterator = eventSet.eventIterator();
                                  while (eventIterator.hasNext()) {

                                      Event event = eventIterator.nextEvent();

                                      // handle ModificationWatchpointEvent
                                      if (event instanceof ModificationWatchpointEvent) {
                                          mwpEventsCount++;
                                          ModificationWatchpointEvent castedEvent = (ModificationWatchpointEvent)event;
                                          Value evValue = castedEvent.valueToBe();
                                          Field evField = castedEvent.field();
                                          log.display("ModificationWatchpointEvent received for " + evField.name());
                                          if (evValue == null) {
                                                log.complain("FAILURE 1: ModificationWatchpointEvent.valueToBe() returns null for " + evField.name());
                                                testFailed = true;
                                          } else {
                                                int ind = fieldsList.indexOf(evField);
                                                if (ind == -1) {
                                                     log.complain("FAILURE 2: ModificationWatchpoint.field() returns unknown field");
                                                     testFailed = true;
                                                } else {
                                                     Value valueNew = castedEvent.valueToBe();
                                                     Value valueNew1= castedEvent.valueToBe();

                                                     if (!valueNew.equals(valueNew1)) {
                                                         log.complain("FAILURE 3: method valueToBe() returns inconsistent results for " +
                                                             evField.name() + "\nvalueNew: " + valueNew + " ; valueNew1: " + valueNew1);
                                                         testFailed = true;
                                                     }

                                                     Value valueFld = castedEvent.valueCurrent();

                                                     if (valueFld.equals(valueNew)) {
                                                         log.complain("FAILURE 4: method valueToBe() returns incorrect equal value for " +
                                                             evField.name() + "\nvaluetoBe(): " + valueNew + " ; valueCurrent(): " + valueFld);
                                                         testFailed = true;
                                                     } else {
                                                         log.display(evField.name() + " is assigned to " + castedEvent.valueToBe().toString());
                                                     }
                                                }
                                           }
                                      }
                                 }
                                 // resume each handled event set
                                 eventSet.resume();
                             }
                        } catch (InterruptedException e) {
                              log.complain("TEST INCOMPLETE: caught InterruptedException while waiting for event");
                              testFailed = true;
                        } catch (VMDisconnectedException e) {
                              log.complain("TEST INCOMPLETE: caught VMDisconnectedException while waiting for event");
                              testFailed = true;
                        }
                        log.display("eventHandler completed");
                   }
             }

             // start event handling thread
             EventHandler eventHandler = new EventHandler();
             log.display("Starting eventHandler");
             eventHandler.start();

             // force debuggee to generate events
             log.display("Sending command: " + COMMAND_GO);
             pipe.println(COMMAND_GO);

             // wait for confirmation from debugee
             log.display("Waiting for command: " + COMMAND_DONE);
             command = pipe.readln();
             if (command == null || !command.equals(COMMAND_DONE)) {
                 throw new Failure("TEST BUG: unexpected debuggee's command: " + command);
             }

             // notify EventHandler that all events generated
             done = true;

             // wait for all expected events received
             log.display("Waiting for all expected events received");
             try {
                 eventHandler.join(argHandler.getWaitTime()*60000);
                 if (eventHandler.isAlive()) {
                     log.complain("FAILURE 20: Timeout for waiting of event was exceeded");
                     eventHandler.interrupt();
                     testFailed = true;
                 }
             } catch (InterruptedException e) {
                 log.complain("TEST INCOMPLETE: InterruptedException caught while waiting for eventHandler's death");
                 testFailed = true;
             }
         } catch (Failure e) {
             log.complain("TEST FAILURE: " + e.getMessage());
             testFailed = true;
         } catch (Exception e) {
             log.complain("Unexpected exception: " + e);
             e.printStackTrace(out);
             testFailed = true;
         } finally {

             log.display("");

             // force debugee to exit
             log.display("Sending command: " + COMMAND_QUIT);
             pipe.println(COMMAND_QUIT);

             // wait for debuggee exits and analize its exit code
             log.display("Waiting for debuggee terminating");
             int debuggeeStatus = debuggee.endDebugee();
             if (debuggeeStatus == PASSED + JCK_STATUS_BASE) {
                 log.display("Debuggee PASSED with exit code: " + debuggeeStatus);
             } else {
                 log.complain("Debuggee FAILED with exit code: " + debuggeeStatus);
                 testFailed = true;
             }
         }

         // check test results
         if (testFailed) {
             log.complain("TEST FAILED");
             return FAILED;
         }

         log.display("TEST PASSED");
         return PASSED;
     }
 }
	/*
	* Copyright (c) 2001, 2018, 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.
	*/

	package nsk.jdi.ModificationWatchpointEvent.valueToBe;

	import com.sun.jdi.*;
	import com.sun.jdi.event.*;
	import com.sun.jdi.request.*;

	import java.io.*;
	import java.util.Iterator;
	import java.util.List;

	import nsk.share.*;
	import nsk.share.jpda.*;
	import nsk.share.jdi.*;


	// This class is the debugger in the test

	public class valuetobe001 {
	static final int PASSED = 0;
	static final int FAILED = 2;
	static final int JCK_STATUS_BASE = 95;

	static final int TIMEOUT_DELTA = 1000; // milliseconds

	static final String COMMAND_READY = "ready";
	static final String COMMAND_QUIT = "quit";
	static final String COMMAND_GO = "go";
	static final String COMMAND_DONE = "done";

	static final String DEBUGEE_NAME = "nsk.jdi.ModificationWatchpointEvent.valueToBe.valuetobe001a";
	static final String CHECKED_CLASS_NAME = "nsk.jdi.ModificationWatchpointEvent.valueToBe.valuetobe001aCheckedClass";

	static private Debugee debuggee;
	static private VirtualMachine vm;
	static private IOPipe pipe;
	static private Log log;
	static private ArgumentHandler argHandler;
	static private EventSet eventSet;

	static private ReferenceType rType;
	static private ModificationWatchpointRequest wpRequest;
	static private List fieldsList;

	static private volatile boolean testFailed;
	static private volatile boolean done;
	static private volatile int requestsCount, mwpEventsCount;

	public static void main (String args[]) {
	System.exit(run(args, System.out) + JCK_STATUS_BASE);
	}

	public static int run(final String args[], final PrintStream out) {

	testFailed = false;
	requestsCount = 0;
	mwpEventsCount = 0;

	argHandler = new ArgumentHandler(args);
	log = new Log(out, argHandler);

	// launch debuggee
	Binder binder = new Binder(argHandler, log);
	log.display("Connecting to debuggee");
	debuggee = binder.bindToDebugee(DEBUGEE_NAME);
	debuggee.redirectStderr(log, "valuetobe001a >");

	// resume debuggee
	log.display("Resuming debuggee");
	debuggee.resume();

	pipe = debuggee.createIOPipe();
	vm = debuggee.VM();

	// check for debuggee's capabilities
	if (!debuggee.VM().canWatchFieldModification()) {
	log.display("TEST WARNING: test passed because JDI implementation does not support " +
	"watchpoints for field modification");
	pipe.println(COMMAND_QUIT);
	debuggee.waitFor();
	return PASSED;
	}

	try {

	// wait for debuggee started
	log.display("Waiting for command: " + COMMAND_READY);
	String command = pipe.readln();
	if (!command.equals(COMMAND_READY)) {
	throw new Failure("TEST BUG: unexpected debuggee's command: " + command);
	}

	// get mirrors
	if ((rType = debuggee.classByName(CHECKED_CLASS_NAME)) == null) {
	throw new Failure("TEST BUG: cannot find " + CHECKED_CLASS_NAME);
	}

	// create events requests
	log.display("Creating requests for WatchpointEvent");
	EventRequestManager erManager = debuggee.VM().eventRequestManager();
	Iterator fieldsIter;
	try {
	fieldsList = rType.fields();
	fieldsIter = fieldsList.iterator();
	} catch (ClassNotPreparedException e) {
	throw new Failure( "TEST_BUG: " + rType.name() + " is not prepared");
	}
	while (fieldsIter.hasNext()) {
	Field refField = (Field)fieldsIter.next();
	if ((wpRequest = erManager.createModificationWatchpointRequest(refField)) == null) {
	throw new Failure("TEST BUG: unable to create ModificationWatchpointRequest");
	} else {
	log.display("ModificationWatchpointRequest for field " + refField.name() + " created");
	wpRequest.enable();
	}
	requestsCount++;
	}
	log.display("Created total " + requestsCount + " ModificationWatchpointRequests");

	// define separate thread for handling events
	class EventHandler extends Thread {
	public void run() {
	eventSet = null;
	try {
	// handle events until all events generated and received
	while ( mwpEventsCount != requestsCount ) {
	eventSet = null;
	eventSet = vm.eventQueue().remove(TIMEOUT_DELTA);

	if (eventSet == null)
	continue;

	EventIterator eventIterator = eventSet.eventIterator();
	while (eventIterator.hasNext()) {

	Event event = eventIterator.nextEvent();

	// handle ModificationWatchpointEvent
	if (event instanceof ModificationWatchpointEvent) {
	mwpEventsCount++;
	ModificationWatchpointEvent castedEvent = (ModificationWatchpointEvent)event;
	Value evValue = castedEvent.valueToBe();
	Field evField = castedEvent.field();
	log.display("ModificationWatchpointEvent received for " + evField.name());
	if (evValue == null) {
	log.complain("FAILURE 1: ModificationWatchpointEvent.valueToBe() returns null for " + evField.name());
	testFailed = true;
	} else {
	int ind = fieldsList.indexOf(evField);
	if (ind == -1) {
	log.complain("FAILURE 2: ModificationWatchpoint.field() returns unknown field");
	testFailed = true;
	} else {
	Value valueNew = castedEvent.valueToBe();
	Value valueNew1= castedEvent.valueToBe();

	if (!valueNew.equals(valueNew1)) {
	log.complain("FAILURE 3: method valueToBe() returns inconsistent results for " +
	evField.name() + "\nvalueNew: " + valueNew + " ; valueNew1: " + valueNew1);
	testFailed = true;
	}

	Value valueFld = castedEvent.valueCurrent();

	if (valueFld.equals(valueNew)) {
	log.complain("FAILURE 4: method valueToBe() returns incorrect equal value for " +
	evField.name() + "\nvaluetoBe(): " + valueNew + " ; valueCurrent(): " + valueFld);
	testFailed = true;
	} else {
	log.display(evField.name() + " is assigned to " + castedEvent.valueToBe().toString());
	}
	}
	}
	}
	}
	// resume each handled event set
	eventSet.resume();
	}
	} catch (InterruptedException e) {
	log.complain("TEST INCOMPLETE: caught InterruptedException while waiting for event");
	testFailed = true;
	} catch (VMDisconnectedException e) {
	log.complain("TEST INCOMPLETE: caught VMDisconnectedException while waiting for event");
	testFailed = true;
	}
	log.display("eventHandler completed");
	}
	}

	// start event handling thread
	EventHandler eventHandler = new EventHandler();
	log.display("Starting eventHandler");
	eventHandler.start();

	// force debuggee to generate events
	log.display("Sending command: " + COMMAND_GO);
	pipe.println(COMMAND_GO);

	// wait for confirmation from debugee
	log.display("Waiting for command: " + COMMAND_DONE);
	command = pipe.readln();
	if (command == null \|\| !command.equals(COMMAND_DONE)) {
	throw new Failure("TEST BUG: unexpected debuggee's command: " + command);
	}

	// notify EventHandler that all events generated
	done = true;

	// wait for all expected events received
	log.display("Waiting for all expected events received");
	try {
	eventHandler.join(argHandler.getWaitTime()*60000);
	if (eventHandler.isAlive()) {
	log.complain("FAILURE 20: Timeout for waiting of event was exceeded");
	eventHandler.interrupt();
	testFailed = true;
	}
	} catch (InterruptedException e) {
	log.complain("TEST INCOMPLETE: InterruptedException caught while waiting for eventHandler's death");
	testFailed = true;
	}
	} catch (Failure e) {
	log.complain("TEST FAILURE: " + e.getMessage());
	testFailed = true;
	} catch (Exception e) {
	log.complain("Unexpected exception: " + e);
	e.printStackTrace(out);
	testFailed = true;
	} finally {

	log.display("");

	// force debugee to exit
	log.display("Sending command: " + COMMAND_QUIT);
	pipe.println(COMMAND_QUIT);

	// wait for debuggee exits and analize its exit code
	log.display("Waiting for debuggee terminating");
	int debuggeeStatus = debuggee.endDebugee();
	if (debuggeeStatus == PASSED + JCK_STATUS_BASE) {
	log.display("Debuggee PASSED with exit code: " + debuggeeStatus);
	} else {
	log.complain("Debuggee FAILED with exit code: " + debuggeeStatus);
	testFailed = true;
	}
	}

	// check test results
	if (testFailed) {
	log.complain("TEST FAILED");
	return FAILED;
	}

	log.display("TEST PASSED");
	return PASSED;
	}
	}