MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-03-22 15:19:59 +07:00
Code Issues Packages Projects Releases Wiki Activity

[debugger] Refactoring: remove one time used constants

Browse Source 
GitOrigin-RevId: eb131b2b7ea468030dae5e4d44fce7c80e03419f
This commit is contained in:
Alexey Merkulov
2024-04-30 18:27:33 +02:00
committed by intellij-monorepo-bot
parent a6e921a6e7
commit 64f33d4c93
1 changed files with 6 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
java/java-runtime/src/com/intellij/rt/debugger/coroutines/CoroutinesDebugHelper.java
View File

@@ -8,20 +8,14 @@ import java.util.List;
public final class CoroutinesDebugHelper {
private static final String GET_CALLER_FRAME_METHOD = "getCallerFrame";
private static final String DUMP_COROUTINES_INFO_METHOD = "dumpCoroutinesInfo";
private static final String GET_LAST_OBSERVED_THREAD_METHOD = "getLastObservedThread";
private static final String GET_SEQUENCE_NUMBER_METHOD = "getSequenceNumber";
private static final String COROUTINE_OWNER_CLASS = "CoroutineOwner";
private static final String DEBUG_COROUTINE_INFO_FIELD = "info";
private static final String SEQUENCE_NUMBER_FIELD = "sequenceNumber";
public static long[] getCoroutinesRunningOnCurrentThread(Object debugProbes, Thread currentThread) throws ReflectiveOperationException {
List<Long> coroutinesIds = new ArrayList<>();
List infos = (List)invoke(debugProbes, DUMP_COROUTINES_INFO_METHOD);
List infos = (List)invoke(debugProbes, "dumpCoroutinesInfo");
for (Object info : infos) {
if (invoke(info, GET_LAST_OBSERVED_THREAD_METHOD) == currentThread) {
coroutinesIds.add((Long)invoke(info, GET_SEQUENCE_NUMBER_METHOD));
if (invoke(info, "getLastObservedThread") == currentThread) {
coroutinesIds.add((Long)invoke(info, "getSequenceNumber"));
}
}
long[] res = new long[coroutinesIds.size()];
@@ -34,8 +28,8 @@ public final class CoroutinesDebugHelper {
public static long tryGetContinuationId(Object continuation) throws ReflectiveOperationException {
Object rootContinuation = getCoroutineOwner(continuation, true);
if (rootContinuation.getClass().getSimpleName().contains(COROUTINE_OWNER_CLASS)) {
Object debugCoroutineInfo = getField(rootContinuation, DEBUG_COROUTINE_INFO_FIELD);
return (long) getField(debugCoroutineInfo, SEQUENCE_NUMBER_FIELD);
Object debugCoroutineInfo = getField(rootContinuation, "info");
return (long) getField(debugCoroutineInfo, "sequenceNumber");
}
return -1;
}
@@ -44,7 +38,7 @@ public final class CoroutinesDebugHelper {
// it is invoked when kotlinx-coroutines debug agent is enabled.
private static Object getCoroutineOwner(Object continuation, boolean checkForCoroutineOwner) throws ReflectiveOperationException {
Method getCallerFrame = Class.forName("kotlin.coroutines.jvm.internal.CoroutineStackFrame", false, continuation.getClass().getClassLoader())
.getDeclaredMethod(GET_CALLER_FRAME_METHOD);
.getDeclaredMethod("getCallerFrame");
getCallerFrame.setAccessible(true);
Object current = continuation;
while (true) {