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

ExternalStorage — lazy create storage (if feature is disabled, storage should be not created)

Browse Source
This commit is contained in:
Vladimir Krivosheev
2017-04-28 18:31:18 +02:00
parent 1131e869eb
commit 1abba85444
1 changed files with 22 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/external-system-impl/src/com/intellij/openapi/externalSystem/configurationStore/ExternalSystemStreamProviderFactory.kt
+22 -17
View File
@@ -42,34 +42,39 @@ import java.util.*
private val EXTERNAL_STORAGE_ANNOTATION = FileStorageAnnotation(StoragePathMacros.MODULE_FILE, false, ExternalProjectStorage::class.java)
private val LOG = logger<ExternalSystemStreamProviderFactory>()
private fun isEnabled() = Registry.`is`("store.imported.project.elements.separately", false)
// todo handle module rename
internal class ExternalSystemStreamProviderFactory(private val project: Project) : StreamProviderFactory {
val nameToData = createStorage(project)
val nameToData by lazy { createStorage(project) }
private var isStorageFlushInProgress = false
init {
Disposer.register(project, Disposable { nameToData.close() })
if (isEnabled()) {
Disposer.register(project, Disposable { nameToData.close() })
// flush on save to be sure that data is saved (it is easy to reimport if corrupted (force exit, blue screen), but we need to avoid it if possible)
ApplicationManager.getApplication().messageBus
.connect(project)
.subscribe(ProjectEx.ProjectSaved.TOPIC, ProjectEx.ProjectSaved {
if (it === project && !isStorageFlushInProgress && nameToData.isDirty) {
isStorageFlushInProgress = true
ApplicationManager.getApplication().executeOnPooledThread {
try {
LOG.catchAndLog { nameToData.force() }
}
finally {
isStorageFlushInProgress = false
// flush on save to be sure that data is saved (it is easy to reimport if corrupted (force exit, blue screen), but we need to avoid it if possible)
ApplicationManager.getApplication().messageBus
.connect(project)
.subscribe(ProjectEx.ProjectSaved.TOPIC, ProjectEx.ProjectSaved {
if (it === project && !isStorageFlushInProgress && nameToData.isDirty) {
isStorageFlushInProgress = true
ApplicationManager.getApplication().executeOnPooledThread {
try {
LOG.catchAndLog { nameToData.force() }
}
finally {
isStorageFlushInProgress = false
}
}
}
}
})
})
}
}
override fun customizeStorageSpecs(component: PersistentStateComponent<*>, componentManager: ComponentManager, storages: List<Storage>, operation: StateStorageOperation): List<Storage>? {
if (componentManager !is Module || component !is ProjectModelElement || !Registry.`is`("store.imported.project.elements.separately", false)) {
if (componentManager !is Module || component !is ProjectModelElement || !isEnabled()) {
return null
}