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

fix flaky test

Browse Source 
GitOrigin-RevId: 084e90f3aee877ec6e1dfb11643a6d872dd5a3a1
This commit is contained in:
Alexander Kass
2020-06-17 16:35:56 +03:00
committed by intellij-monorepo-bot
parent ba438948a5
commit 01aa4017b5
1 changed files with 18 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/credential-store/src/NativeCredentialStoreWrapper.kt
+18 -4
View File
@@ -10,12 +10,14 @@ import com.intellij.notification.NotificationType
import com.intellij.notification.SingletonNotificationManager
import com.intellij.openapi.application.ApplicationNamesInfo
import com.intellij.openapi.progress.ProcessCanceledException
import com.intellij.openapi.util.Conditions
import com.intellij.openapi.util.SystemInfo
import com.intellij.openapi.util.registry.Registry
import com.intellij.util.concurrency.QueueProcessor
import org.jetbrains.annotations.TestOnly
import java.io.Closeable
import java.util.concurrent.TimeUnit
import java.util.function.BiConsumer
internal val NOTIFICATION_MANAGER by lazy {
// we use name "Password Safe" instead of "Credentials Store" because it was named so previously (and no much sense to rename it)
@@ -25,10 +27,14 @@ internal val NOTIFICATION_MANAGER by lazy {
private val REMOVED_CREDENTIALS = Credentials("REMOVED_CREDENTIALS")
// used only for native keychains, not for KeePass, so, postponedCredentials and other is not overhead if KeePass is used
private class NativeCredentialStoreWrapper(private val store: CredentialStore) : CredentialStore, Closeable {
private val fallbackStore = lazy { InMemoryCredentialStore() }
private class NativeCredentialStoreWrapper internal constructor(
private val store: CredentialStore,
private val queueProcessor: QueueProcessor<() -> Unit>
) : CredentialStore, Closeable {
private val queueProcessor = QueueProcessor<() -> Unit> { it() }
constructor(store: CredentialStore): this(store, QueueProcessor<() -> Unit> { it() })
private val fallbackStore = lazy { InMemoryCredentialStore() }
private val postponedCredentials = InMemoryCredentialStore()
@@ -148,4 +154,12 @@ private class LinuxCredentialStoreFactory : CredentialStoreFactory {
}
@TestOnly
fun wrappedInMemory(): CredentialStore = NativeCredentialStoreWrapper(InMemoryCredentialStore())
fun wrappedInMemory(): CredentialStore = NativeCredentialStoreWrapper(InMemoryCredentialStore(), QueueProcessor<() -> Unit>(
BiConsumer { item, continuation ->
try {
QueueProcessor.runSafely(item)
}
finally {
continuation.run()
}
}, true, QueueProcessor.ThreadToUse.AWT, Conditions.alwaysFalse<Any>()))