opensource/kilocode
3
0
Fork 0
mirror of https://github.com/Kilo-Org/kilocode.git synced 2026-09-21 05:52:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(jetbrains): replace synchronized(errors) with CopyOnWriteArrayList

Browse Source
This commit is contained in:
kirillk
2026-04-14 12:59:24 -04:00
parent 52d97250fa
commit 9ad515c18e
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/kilo-jetbrains/backend/src/main/kotlin/ai/kilocode/backend/app/KiloBackendAppService.kt
+6 -5
View File
@@ -29,6 +29,7 @@ import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock
import java.net.ConnectException
import java.net.SocketTimeoutException
import java.util.concurrent.CopyOnWriteArrayList
import java.util.concurrent.atomic.AtomicReference
/**
@@ -176,7 +177,7 @@ class KiloBackendAppService private constructor(
val progress = AtomicReference(LoadProgress())
_appState.value = KiloAppState.Loading(progress.get())
val errors = mutableListOf<LoadError>()
val errors = CopyOnWriteArrayList<LoadError>()
var cfg: Config? = null
var prof: KiloProfile200Response? = null
var notifs: List<KiloNotifications200ResponseInner> = emptyList()
@@ -187,7 +188,7 @@ class KiloBackendAppService private constructor(
val result = fetchProfile()
val status = when {
result.error != null -> {
synchronized(errors) { errors.add(result.error) }
errors.add(result.error)
throw LoadFailure(result.error)
}
result.value != null -> {
@@ -207,7 +208,7 @@ class KiloBackendAppService private constructor(
.also { _appState.value = KiloAppState.Loading(it) }
} else {
val err = result.error!!
synchronized(errors) { errors.add(err) }
errors.add(err)
throw LoadFailure(err)
}
}
@@ -219,7 +220,7 @@ class KiloBackendAppService private constructor(
.also { _appState.value = KiloAppState.Loading(it) }
} else {
val err = result.error!!
synchronized(errors) { errors.add(err) }
errors.add(err)
throw LoadFailure(err)
}
}
@@ -246,7 +247,7 @@ class KiloBackendAppService private constructor(
log.warn("Application start failed: ${e.message}")
_appState.value = KiloAppState.Error(
message = "Failed to load required data",
errors = synchronized(errors) { errors.toList() },
errors = errors.toList(),
)
}
}