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] IJPL-158332 Show button for newly opened files

Browse Source 
GitOrigin-RevId: 7c0fcdf40be8f28657ef1eb201fd02050b384d36
This commit is contained in:
Maksim Zuev
2024-07-30 17:13:52 +00:00
committed by intellij-monorepo-bot
parent a8b02f1e8a
commit f6f5a832c7
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/xdebugger-impl/src/com/intellij/xdebugger/impl/hotswap/HotSwapSessionManager.kt
+14 -4
View File
@@ -17,15 +17,19 @@ import java.util.concurrent.atomic.AtomicBoolean
@Service(Service.Level.PROJECT)
class HotSwapSessionManager(private val project: Project, private val parentScope: CoroutineScope) {
private val listeners = DisposableWrapperList<HotSwapChangesListener>()
private val sessions = DisposableWrapperList<HotSwapSession<*>>()
fun <T> createSession(provider: HotSwapProvider<T>, disposable: Disposable) {
val hotSwapSession = HotSwapSession(project, provider, parentScope)
Disposer.register(disposable, hotSwapSession)
sessions.add(hotSwapSession, disposable)
hotSwapSession.init()
}
internal fun addListener(listener: HotSwapChangesListener, disposable: Disposable) {
listeners.add(listener, disposable)
val currentSession = sessions.lastOrNull() ?: return
listener.onStatusChanged(currentSession, currentSession.currentStatus)
}
internal fun fireStatusChanged(session: HotSwapSession<*>, status: HotSwapVisibleStatus) {
@@ -50,30 +54,36 @@ class HotSwapSession<T>(val project: Project, internal val provider: HotSwapProv
internal val coroutineScope = parentScope.childScope("HotSwapSession $this")
private val hasActiveChanges = AtomicBoolean()
private lateinit var changesCollector: SourceFileChangesCollector<T>
@Volatile
internal var currentStatus: HotSwapVisibleStatus = HotSwapVisibleStatus.NO_CHANGES
private set(value) {
field = value
HotSwapSessionManager.getInstance(project).fireStatusChanged(this, value)
}
internal fun init() {
changesCollector = provider.createChangesCollector(this, coroutineScope, SourceFileChangesListener {
if (hasActiveChanges.compareAndSet(false, true)) {
HotSwapSessionManager.getInstance(project).fireStatusChanged(this@HotSwapSession, HotSwapVisibleStatus.CHANGES_READY)
currentStatus = HotSwapVisibleStatus.CHANGES_READY
}
})
Disposer.register(this, changesCollector)
}
override fun dispose() {
HotSwapSessionManager.getInstance(project).fireStatusChanged(this, HotSwapVisibleStatus.SESSION_COMPLETED)
currentStatus = HotSwapVisibleStatus.SESSION_COMPLETED
coroutineScope.cancel()
}
private fun completeHotSwap() {
if (hasActiveChanges.compareAndSet(true, false)) {
changesCollector.resetChanges()
HotSwapSessionManager.getInstance(project).fireStatusChanged(this, HotSwapVisibleStatus.NO_CHANGES)
currentStatus = HotSwapVisibleStatus.NO_CHANGES
}
}
internal fun startHotSwap() {
HotSwapSessionManager.getInstance(project).fireStatusChanged(this, HotSwapVisibleStatus.IN_PROGRESS)
currentStatus = HotSwapVisibleStatus.IN_PROGRESS
}
fun getChanges() = changesCollector.getChanges()