Skip to content

Commit 3b88fee

Browse files
committed
[utbot-logs]
compilation fix
1 parent b39d1b8 commit 3b88fee

File tree

4 files changed

+5
-6
lines changed

4 files changed

+5
-6
lines changed

utbot-instrumentation/src/main/kotlin/org/utbot/instrumentation/ConcreteExecutor.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -285,7 +285,7 @@ class ConcreteExecutor<TIResult, TInstrumentation : Instrumentation<TIResult>> p
285285
if (alive) {
286286
try {
287287
processInstance?.run {
288-
protocol.synchronizationModel.stopProcess.start(lifetime, Unit)
288+
protocol.synchronizationModel.stopProcess.fire(Unit)
289289
}
290290
} catch (_: Exception) {}
291291
processInstance = null

utbot-intellij/src/main/kotlin/org/utbot/intellij/plugin/process/EngineProcess.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -395,7 +395,7 @@ class EngineProcess private constructor(val project: Project, private val classN
395395

396396
init {
397397
lifetime.onTermination {
398-
protocol.synchronizationModel.stopProcess.start(Unit)
398+
protocol.synchronizationModel.stopProcess.fire(Unit)
399399
}
400400
settingsModel.settingFor.set { params ->
401401
SettingForResult(AbstractSettings.allSettings[params.key]?.let { settings: AbstractSettings ->

utbot-rd/src/main/kotlin/org/utbot/rd/ClientProcessUtil.kt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import com.jetbrains.rd.util.lifetime.Lifetime
1010
import com.jetbrains.rd.util.lifetime.LifetimeDefinition
1111
import com.jetbrains.rd.util.lifetime.isAlive
1212
import com.jetbrains.rd.util.lifetime.plusAssign
13+
import com.jetbrains.rd.util.reactive.adviseEternal
1314
import com.jetbrains.rd.util.threading.SingleThreadScheduler
1415
import com.jetbrains.rd.util.trace
1516
import kotlinx.coroutines.CancellationException
@@ -178,7 +179,7 @@ class ClientProtocolBuilder {
178179
clientProtocol.synchronizationModel.suspendTimeoutTimer.set { param ->
179180
watchdog.suspendTimeout = param
180181
}
181-
clientProtocol.synchronizationModel.stopProcess.set { _ -> watchdog.stopProtocol() }
182+
clientProtocol.synchronizationModel.stopProcess.adviseEternal { _ -> watchdog.stopProtocol() }
182183
clientProtocol.block(watchdog)
183184
}
184185

utbot-rd/src/main/kotlin/org/utbot/rd/ProcessWithRdServer.kt

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -94,9 +94,7 @@ class ProcessWithRdServerImpl private constructor(
9494

9595
override fun terminate() {
9696
silent {
97-
// todo - i can wait here forever, so i need only start
98-
// and wait for some time, may be blocking wait and only then terminate
99-
protocol.synchronizationModel.stopProcess.startBlocking(Unit)
97+
protocol.synchronizationModel.stopProcess.fire(Unit)
10098
}
10199
child.terminate()
102100
}

0 commit comments

Comments
 (0)