test/1913-get-set-local-objects/src/art/Test1913.java - platform/art - Git at Google

 /*
  * Copyright (C) 2017 The Android Open Source Project
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

 package art;

 import java.lang.reflect.Constructor;
 import java.lang.reflect.Executable;
 import java.lang.reflect.Method;
 import java.nio.ByteBuffer;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.Semaphore;
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.function.Predicate;
 import java.util.function.Supplier;

 public class Test1913 {
   public static final String TARGET_VAR = "TARGET";

   public static interface TestInterface {
     public default void doNothing() {}
   }
   public static class TestClass1 implements TestInterface {
     public String id;
     public TestClass1(String id) {
       this.id = id;
     }
     public String toString() {
       return String.format("TestClass1(\"%s\")", id);
     }
   }

   public static class TestClass1ext extends TestClass1 {
     public TestClass1ext(String id) {
       super(id);
     }
     public String toString() {
       return String.format("TestClass1ext(\"%s\")", super.toString());
     }
   }
   public static class TestClass2 {
     public String id;
     public TestClass2(String id) {
       this.id = id;
     }
     public String toString() {
       return String.format("TestClass2(\"%s\")", id);
     }
   }
   public static class TestClass2impl extends TestClass2 implements TestInterface {
     public TestClass2impl(String id) {
       super(id);
     }
     public String toString() {
       return String.format("TestClass2impl(\"%s\")", super.toString());
     }
   }

   public static void reportValue(Object val) {
     System.out.println("\tValue is '" + val +
                        "' (class: " + (val != null ? val.getClass() : "NULL") + ")");
   }

   public static void PrimitiveMethod(Runnable safepoint) {
     int TARGET = 42;
     safepoint.run();
     reportValue(TARGET);
   }

   // b/64115302: Needed to make sure that DX doesn't change the type of TARGET to TestClass1.
   private static Object AsObject(Object o) {
     return o;
   }

   public static void NullObjectMethod(Runnable safepoint) {
     Object TARGET = null;
     safepoint.run();
     reportValue(TARGET);
   }

   public static void NullInterfaceMethod(Runnable safepoint) {
     TestInterface TARGET = null;
     safepoint.run();
     reportValue(TARGET);
   }

   public static void NullSpecificClassMethod(Runnable safepoint) {
     TestClass1 TARGET = null;
     safepoint.run();
     reportValue(TARGET);
   }

   public static void ObjectMethod(Runnable safepoint) {
     Object TARGET = AsObject(new TestClass1("ObjectMethod"));
     safepoint.run();
     reportValue(TARGET);
   }

   public static void InterfaceMethod(Runnable safepoint) {
     TestInterface TARGET = new TestClass1("InterfaceMethod");
     safepoint.run();
     reportValue(TARGET);
   }

   public static void SpecificClassMethod(Runnable safepoint) {
     TestClass1 TARGET = new TestClass1("SpecificClassMethod");
     safepoint.run();
     reportValue(TARGET);
   }

   public static interface SafepointFunction {
     public void
     invoke(Thread thread, Method target, Locals.VariableDescription TARGET_desc, int depth)
         throws Exception;
   }

   public static interface SetterFunction {
     public void SetVar(Thread t, int depth, int slot, Object v);
   }

   public static interface GetterFunction { public Object GetVar(Thread t, int depth, int slot); }

   public static SafepointFunction
   NamedSet(final String type, final SetterFunction get, final Object v) {
     return new SafepointFunction() {
       public void invoke(Thread t, Method method, Locals.VariableDescription desc, int depth) {
         try {
           get.SetVar(t, depth, desc.slot, v);
           System.out.println(this + " on " + method + " set value: " + v);
         } catch (Exception e) {
           System.out.println(this + " on " + method + " failed to set value " + v + " due to " +
                              e.getMessage());
         }
       }
       public String toString() {
         return "\"Set" + type + "\"";
       }
     };
   }

   public static SafepointFunction NamedGet(final String type, final GetterFunction get) {
     return new SafepointFunction() {
       public void invoke(Thread t, Method method, Locals.VariableDescription desc, int depth) {
         try {
           Object res = get.GetVar(t, depth, desc.slot);
           System.out.println(this + " on " + method + " got value: " + res);
         } catch (Exception e) {
           System.out.println(this + " on " + method + " failed due to " + e.getMessage());
         }
       }
       public String toString() {
         return "\"Get" + type + "\"";
       }
     };
   }

   public static class TestCase {
     public final Method target;

     public TestCase(Method target) {
       this.target = target;
     }

     public static class ThreadPauser implements Runnable {
       public final Semaphore sem_wakeup_main;
       public final Semaphore sem_wait;

       public ThreadPauser() {
         sem_wakeup_main = new Semaphore(0);
         sem_wait = new Semaphore(0);
       }

       public void run() {
         try {
           sem_wakeup_main.release();
           sem_wait.acquire();
         } catch (Exception e) {
           throw new Error("Error with semaphores!", e);
         }
       }

       public void waitForOtherThreadToPause() throws Exception {
         sem_wakeup_main.acquire();
       }

       public void wakeupOtherThread() throws Exception {
         sem_wait.release();
       }
     }

     public void exec(final SafepointFunction safepoint) throws Exception {
       System.out.println("Running " + target + " with " + safepoint + " on remote thread.");
       final ThreadPauser pause = new ThreadPauser();
       Thread remote = new Thread(() -> {
         try {
           target.invoke(null, pause);
         } catch (Exception e) {
           throw new Error("Error invoking remote thread " + Thread.currentThread(), e);
         }
       }, "remote thread for " + target + " with " + safepoint);
       remote.start();
       pause.waitForOtherThreadToPause();
       try {
         Suspension.suspend(remote);
         StackTrace.StackFrameData frame = findStackFrame(remote);
         Locals.VariableDescription desc = findTargetVar(frame.current_location);
         safepoint.invoke(remote, target, desc, frame.depth);
       } finally {
         Suspension.resume(remote);
         pause.wakeupOtherThread();
         remote.join();
       }
     }

     private Locals.VariableDescription findTargetVar(long loc) {
       for (Locals.VariableDescription var : Locals.GetLocalVariableTable(target)) {
         if (var.start_location <= loc && var.length + var.start_location > loc &&
             var.name.equals(TARGET_VAR)) {
           return var;
         }
       }
       throw new Error("Unable to find variable " + TARGET_VAR + " in " + target + " at loc " + loc);
     }

     private StackTrace.StackFrameData findStackFrame(Thread thr) {
       for (StackTrace.StackFrameData frame : StackTrace.GetStackTrace(thr)) {
         if (frame.method.equals(target)) {
           return frame;
         }
       }
       throw new Error("Unable to find stack frame in method " + target + " on thread " + thr);
     }
   }
   public static Method getMethod(String name) throws Exception {
     return Test1913.class.getDeclaredMethod(name, Runnable.class);
   }

   public static void run() throws Exception {
     Locals.EnableLocalVariableAccess();
     final TestCase[] MAIN_TEST_CASES = new TestCase[] {
       new TestCase(getMethod("ObjectMethod")),        new TestCase(getMethod("InterfaceMethod")),
       new TestCase(getMethod("SpecificClassMethod")), new TestCase(getMethod("PrimitiveMethod")),
       new TestCase(getMethod("NullObjectMethod")),
       new TestCase(getMethod("NullInterfaceMethod")),
       new TestCase(getMethod("NullSpecificClassMethod")),
     };

     final SetterFunction set_obj = Locals::SetLocalVariableObject;
     final SafepointFunction[] SAFEPOINTS = new SafepointFunction[] {
       NamedGet("GetObject", Locals::GetLocalVariableObject),
       NamedSet("Null", set_obj, null),
       NamedSet("TestClass1", set_obj, new TestClass1("Set TestClass1")),
       NamedSet("TestClass1ext", set_obj, new TestClass1ext("Set TestClass1ext")),
       NamedSet("TestClass2", set_obj, new TestClass2("Set TestClass2")),
       NamedSet("TestClass2impl", set_obj, new TestClass2impl("Set TestClass2impl")),
     };

     for (TestCase t : MAIN_TEST_CASES) {
       for (SafepointFunction s : SAFEPOINTS) {
         t.exec(s);
       }
     }
   }
 }
	/*
	* Copyright (C) 2017 The Android Open Source Project
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package art;

	import java.lang.reflect.Constructor;
	import java.lang.reflect.Executable;
	import java.lang.reflect.Method;
	import java.nio.ByteBuffer;
	import java.util.Arrays;
	import java.util.Collection;
	import java.util.List;
	import java.util.Set;
	import java.util.concurrent.Semaphore;
	import java.util.function.Consumer;
	import java.util.function.Function;
	import java.util.function.Predicate;
	import java.util.function.Supplier;

	public class Test1913 {
	public static final String TARGET_VAR = "TARGET";

	public static interface TestInterface {
	public default void doNothing() {}
	}
	public static class TestClass1 implements TestInterface {
	public String id;
	public TestClass1(String id) {
	this.id = id;
	}
	public String toString() {
	return String.format("TestClass1(\"%s\")", id);
	}
	}

	public static class TestClass1ext extends TestClass1 {
	public TestClass1ext(String id) {
	super(id);
	}
	public String toString() {
	return String.format("TestClass1ext(\"%s\")", super.toString());
	}
	}
	public static class TestClass2 {
	public String id;
	public TestClass2(String id) {
	this.id = id;
	}
	public String toString() {
	return String.format("TestClass2(\"%s\")", id);
	}
	}
	public static class TestClass2impl extends TestClass2 implements TestInterface {
	public TestClass2impl(String id) {
	super(id);
	}
	public String toString() {
	return String.format("TestClass2impl(\"%s\")", super.toString());
	}
	}

	public static void reportValue(Object val) {
	System.out.println("\tValue is '" + val +
	"' (class: " + (val != null ? val.getClass() : "NULL") + ")");
	}

	public static void PrimitiveMethod(Runnable safepoint) {
	int TARGET = 42;
	safepoint.run();
	reportValue(TARGET);
	}

	// b/64115302: Needed to make sure that DX doesn't change the type of TARGET to TestClass1.
	private static Object AsObject(Object o) {
	return o;
	}

	public static void NullObjectMethod(Runnable safepoint) {
	Object TARGET = null;
	safepoint.run();
	reportValue(TARGET);
	}

	public static void NullInterfaceMethod(Runnable safepoint) {
	TestInterface TARGET = null;
	safepoint.run();
	reportValue(TARGET);
	}

	public static void NullSpecificClassMethod(Runnable safepoint) {
	TestClass1 TARGET = null;
	safepoint.run();
	reportValue(TARGET);
	}

	public static void ObjectMethod(Runnable safepoint) {
	Object TARGET = AsObject(new TestClass1("ObjectMethod"));
	safepoint.run();
	reportValue(TARGET);
	}

	public static void InterfaceMethod(Runnable safepoint) {
	TestInterface TARGET = new TestClass1("InterfaceMethod");
	safepoint.run();
	reportValue(TARGET);
	}

	public static void SpecificClassMethod(Runnable safepoint) {
	TestClass1 TARGET = new TestClass1("SpecificClassMethod");
	safepoint.run();
	reportValue(TARGET);
	}

	public static interface SafepointFunction {
	public void
	invoke(Thread thread, Method target, Locals.VariableDescription TARGET_desc, int depth)
	throws Exception;
	}

	public static interface SetterFunction {
	public void SetVar(Thread t, int depth, int slot, Object v);
	}

	public static interface GetterFunction { public Object GetVar(Thread t, int depth, int slot); }

	public static SafepointFunction
	NamedSet(final String type, final SetterFunction get, final Object v) {
	return new SafepointFunction() {
	public void invoke(Thread t, Method method, Locals.VariableDescription desc, int depth) {
	try {
	get.SetVar(t, depth, desc.slot, v);
	System.out.println(this + " on " + method + " set value: " + v);
	} catch (Exception e) {
	System.out.println(this + " on " + method + " failed to set value " + v + " due to " +
	e.getMessage());
	}
	}
	public String toString() {
	return "\"Set" + type + "\"";
	}
	};
	}

	public static SafepointFunction NamedGet(final String type, final GetterFunction get) {
	return new SafepointFunction() {
	public void invoke(Thread t, Method method, Locals.VariableDescription desc, int depth) {
	try {
	Object res = get.GetVar(t, depth, desc.slot);
	System.out.println(this + " on " + method + " got value: " + res);
	} catch (Exception e) {
	System.out.println(this + " on " + method + " failed due to " + e.getMessage());
	}
	}
	public String toString() {
	return "\"Get" + type + "\"";
	}
	};
	}

	public static class TestCase {
	public final Method target;

	public TestCase(Method target) {
	this.target = target;
	}

	public static class ThreadPauser implements Runnable {
	public final Semaphore sem_wakeup_main;
	public final Semaphore sem_wait;

	public ThreadPauser() {
	sem_wakeup_main = new Semaphore(0);
	sem_wait = new Semaphore(0);
	}

	public void run() {
	try {
	sem_wakeup_main.release();
	sem_wait.acquire();
	} catch (Exception e) {
	throw new Error("Error with semaphores!", e);
	}
	}

	public void waitForOtherThreadToPause() throws Exception {
	sem_wakeup_main.acquire();
	}

	public void wakeupOtherThread() throws Exception {
	sem_wait.release();
	}
	}

	public void exec(final SafepointFunction safepoint) throws Exception {
	System.out.println("Running " + target + " with " + safepoint + " on remote thread.");
	final ThreadPauser pause = new ThreadPauser();
	Thread remote = new Thread(() -> {
	try {
	target.invoke(null, pause);
	} catch (Exception e) {
	throw new Error("Error invoking remote thread " + Thread.currentThread(), e);
	}
	}, "remote thread for " + target + " with " + safepoint);
	remote.start();
	pause.waitForOtherThreadToPause();
	try {
	Suspension.suspend(remote);
	StackTrace.StackFrameData frame = findStackFrame(remote);
	Locals.VariableDescription desc = findTargetVar(frame.current_location);
	safepoint.invoke(remote, target, desc, frame.depth);
	} finally {
	Suspension.resume(remote);
	pause.wakeupOtherThread();
	remote.join();
	}
	}

	private Locals.VariableDescription findTargetVar(long loc) {
	for (Locals.VariableDescription var : Locals.GetLocalVariableTable(target)) {
	if (var.start_location <= loc && var.length + var.start_location > loc &&
	var.name.equals(TARGET_VAR)) {
	return var;
	}
	}
	throw new Error("Unable to find variable " + TARGET_VAR + " in " + target + " at loc " + loc);
	}

	private StackTrace.StackFrameData findStackFrame(Thread thr) {
	for (StackTrace.StackFrameData frame : StackTrace.GetStackTrace(thr)) {
	if (frame.method.equals(target)) {
	return frame;
	}
	}
	throw new Error("Unable to find stack frame in method " + target + " on thread " + thr);
	}
	}
	public static Method getMethod(String name) throws Exception {
	return Test1913.class.getDeclaredMethod(name, Runnable.class);
	}

	public static void run() throws Exception {
	Locals.EnableLocalVariableAccess();
	final TestCase[] MAIN_TEST_CASES = new TestCase[] {
	new TestCase(getMethod("ObjectMethod")), new TestCase(getMethod("InterfaceMethod")),
	new TestCase(getMethod("SpecificClassMethod")), new TestCase(getMethod("PrimitiveMethod")),
	new TestCase(getMethod("NullObjectMethod")),
	new TestCase(getMethod("NullInterfaceMethod")),
	new TestCase(getMethod("NullSpecificClassMethod")),
	};

	final SetterFunction set_obj = Locals::SetLocalVariableObject;
	final SafepointFunction[] SAFEPOINTS = new SafepointFunction[] {
	NamedGet("GetObject", Locals::GetLocalVariableObject),
	NamedSet("Null", set_obj, null),
	NamedSet("TestClass1", set_obj, new TestClass1("Set TestClass1")),
	NamedSet("TestClass1ext", set_obj, new TestClass1ext("Set TestClass1ext")),
	NamedSet("TestClass2", set_obj, new TestClass2("Set TestClass2")),
	NamedSet("TestClass2impl", set_obj, new TestClass2impl("Set TestClass2impl")),
	};

	for (TestCase t : MAIN_TEST_CASES) {
	for (SafepointFunction s : SAFEPOINTS) {
	t.exec(s);
	}
	}
	}
	}