Implement JVMTI can_signal_thread capability.
Implements the JVMTI can_signal_thread capability and all associated
methods and behaviors. This includes both the StopThread and
InterruptThread functions.
This CL contains the tests for the previous CL.
Test: ./test.py --host -j50
Test: stress --cpu 59 && while ./test/run-test --host 1934; do; done
Bug: 62821960
Bug: 34415266
Change-Id: I7b6fc37da0d2673caa993e486f078cf129d74c0f
diff --git a/test/1934-jvmti-signal-thread/signal_threads.cc b/test/1934-jvmti-signal-thread/signal_threads.cc
new file mode 100644
index 0000000..726a7a86
--- /dev/null
+++ b/test/1934-jvmti-signal-thread/signal_threads.cc
@@ -0,0 +1,157 @@
+/*
+ * 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.
+ */
+
+#include <pthread.h>
+
+#include <cstdio>
+#include <iostream>
+#include <vector>
+
+#include "android-base/logging.h"
+#include "jni.h"
+#include "jvmti.h"
+
+#include "scoped_local_ref.h"
+#include "scoped_primitive_array.h"
+
+// Test infrastructure
+#include "jvmti_helper.h"
+#include "test_env.h"
+
+namespace art {
+namespace Test1934SignalThreads {
+
+struct NativeMonitor {
+ jrawMonitorID continue_monitor;
+ bool should_continue;
+ jrawMonitorID start_monitor;
+ bool should_start;
+};
+
+extern "C" JNIEXPORT jlong JNICALL Java_art_Test1934_allocNativeMonitor(JNIEnv* env, jclass) {
+ NativeMonitor* mon;
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->Allocate(sizeof(NativeMonitor),
+ reinterpret_cast<unsigned char**>(&mon)))) {
+ return -1l;
+ }
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->CreateRawMonitor("test-1934 start",
+ &mon->start_monitor))) {
+ return -1l;
+ }
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->CreateRawMonitor("test-1934 continue",
+ &mon->continue_monitor))) {
+ return -1l;
+ }
+ mon->should_continue = false;
+ mon->should_start = false;
+ return static_cast<jlong>(reinterpret_cast<intptr_t>(mon));
+}
+
+extern "C" JNIEXPORT void Java_art_Test1934_nativeWaitForOtherThread(JNIEnv* env,
+ jclass,
+ jlong id) {
+ NativeMonitor* mon = reinterpret_cast<NativeMonitor*>(static_cast<intptr_t>(id));
+ // Start
+ if (JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorEnter(mon->start_monitor))) {
+ return;
+ }
+ mon->should_start = true;
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->RawMonitorNotifyAll(mon->start_monitor))) {
+ JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->start_monitor));
+ return;
+ }
+ if (JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->start_monitor))) {
+ return;
+ }
+
+ // Finish
+ if (JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorEnter(mon->continue_monitor))) {
+ return;
+ }
+ while (!mon->should_continue) {
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->RawMonitorWait(mon->continue_monitor, -1l))) {
+ JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->continue_monitor));
+ return;
+ }
+ }
+ JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->continue_monitor));
+}
+
+extern "C" JNIEXPORT void Java_art_Test1934_nativeDoInterleaved(JNIEnv* env,
+ jclass,
+ jlong id,
+ jobject closure) {
+ NativeMonitor* mon = reinterpret_cast<NativeMonitor*>(static_cast<intptr_t>(id));
+ // Wait for start.
+ if (JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorEnter(mon->start_monitor))) {
+ return;
+ }
+ while (!mon->should_start) {
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->RawMonitorWait(mon->start_monitor, -1l))) {
+ return;
+ }
+ }
+ if (JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->start_monitor))) {
+ return;
+ }
+
+ // Call closure.
+ ScopedLocalRef<jclass> runnable_klass(env, env->FindClass("java/lang/Runnable"));
+ if (env->ExceptionCheck()) {
+ return;
+ }
+ jmethodID doRun = env->GetMethodID(runnable_klass.get(), "run", "()V");
+ if (env->ExceptionCheck()) {
+ return;
+ }
+ env->CallVoidMethod(closure, doRun);
+
+ // Tell other thread to finish.
+ if (JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorEnter(mon->continue_monitor))) {
+ return;
+ }
+ mon->should_continue = true;
+ if (JvmtiErrorToException(env,
+ jvmti_env,
+ jvmti_env->RawMonitorNotifyAll(mon->continue_monitor))) {
+ JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->continue_monitor));
+ return;
+ }
+ JvmtiErrorToException(env, jvmti_env, jvmti_env->RawMonitorExit(mon->continue_monitor));
+}
+
+extern "C" JNIEXPORT void Java_art_Test1934_destroyNativeMonitor(JNIEnv*, jclass, jlong id) {
+ NativeMonitor* mon = reinterpret_cast<NativeMonitor*>(static_cast<intptr_t>(id));
+ jvmti_env->DestroyRawMonitor(mon->start_monitor);
+ jvmti_env->DestroyRawMonitor(mon->continue_monitor);
+ jvmti_env->Deallocate(reinterpret_cast<unsigned char*>(mon));
+}
+
+} // namespace Test1934SignalThreads
+} // namespace art
+