MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

[debugger] Improve detecting when coroutine stepping is ended

Browse Source 
IDEA-381878 IDEA-365578

GitOrigin-RevId: 7e33cd4ecaba91088ed537b895b14f018c59e2c8
This commit is contained in:
Alexey.Merkulov
2025-11-08 00:55:18 +00:00
committed by intellij-monorepo-bot
parent a2223d1ef4
commit 277042a171
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/debugger/impl/src/com/intellij/debugger/engine/SteppingProgressTracker.kt
+5 -5
View File
@@ -12,7 +12,7 @@ import kotlinx.coroutines.CompletableDeferred
import org.jetbrains.annotations.Nls
import java.util.concurrent.CompletableFuture
private data class TrackedSteppingData(val stepCompetedStatus: CompletableDeferred<Unit>, val threadFilter: (ThreadReferenceProxy?) -> Boolean)
private data class TrackedSteppingData(val stepCompetedStatus: CompletableDeferred<Unit>, val threadFilter: (ThreadReferenceProxy?, SuspendContextImpl) -> Boolean)
internal class SteppingProgressTracker(private val debuggerProcessImpl: DebugProcessImpl) {
private val trackedStepping = mutableListOf<TrackedSteppingData>()
@@ -21,7 +21,7 @@ internal class SteppingProgressTracker(private val debuggerProcessImpl: DebugPro
debuggerProcessImpl.addDebugProcessListener(object : DebugProcessListener {
override fun paused(suspendContext: SuspendContext) {
val thread = suspendContext.thread
val completedSteps = trackedStepping.filter { it.threadFilter(thread) }
val completedSteps = trackedStepping.filter { it.threadFilter(thread, suspendContext as SuspendContextImpl) }
for ((stepCompetedStatus, _) in completedSteps) {
stepCompetedStatus.complete(Unit)
}
@@ -30,7 +30,7 @@ internal class SteppingProgressTracker(private val debuggerProcessImpl: DebugPro
})
}
fun addStepping(stepCompetedStatus: CompletableDeferred<Unit>, threadFilter: (ThreadReferenceProxy?) -> Boolean) {
fun addStepping(stepCompetedStatus: CompletableDeferred<Unit>, threadFilter: (ThreadReferenceProxy?, SuspendContextImpl) -> Boolean) {
trackedStepping.add(TrackedSteppingData(stepCompetedStatus, threadFilter))
}
}
@@ -75,8 +75,8 @@ private class CancelingSteppingListener : SteppingListener {
}
val tracker = suspendContext.debugProcess.mySteppingProgressTracker
tracker.addStepping(stepCompetedStatus) { thread ->
!needSuspendOnlyThread || thread == null || thread == threadForStepping
tracker.addStepping(stepCompetedStatus) { thread, suspendContext ->
thread == null || filter != null && filter.checkSameThread(thread.threadReference, suspendContext) || thread == threadForStepping
}
}
}