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

indexes: update stub indexes in non-cancellable section

Browse Source 
GitOrigin-RevId: cdb22ddb3edb0cd949da43846f8d153d4d763882
This commit is contained in:
Dmitry Batkovich
2020-05-07 08:09:49 +00:00
committed by intellij-monorepo-bot
parent 076de9ccba
commit 03045af2fd
1 changed files with 49 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/lang-impl/src/com/intellij/psi/stubs/StubIndexImpl.java
+49 -46
View File
@@ -584,53 +584,56 @@ public final class StubIndexImpl extends StubIndexEx implements PersistentStateC
int fileId,
@NotNull Set<K> oldKeys,
@NotNull Set<K> newKeys) {
try {
if (FileBasedIndexImpl.DO_TRACE_STUB_INDEX_UPDATE) {
LOG.info("stub index '" + stubIndexKey + "' update: " + fileId +
" old = " + Arrays.toString(oldKeys.toArray()) +
" new = " + Arrays.toString(newKeys.toArray()) +
" updated_id = " + System.identityHashCode(newKeys));
}
final UpdatableIndex<K, Void, FileContent> index = getIndex(stubIndexKey);
if (index == null) return;
index.updateWithMap(new AbstractUpdateData<K, Void>(fileId) {
@Override
protected boolean iterateKeys(@NotNull KeyValueUpdateProcessor<? super K, ? super Void> addProcessor,
@NotNull KeyValueUpdateProcessor<? super K, ? super Void> updateProcessor,
@NotNull RemovedKeyProcessor<? super K> removeProcessor) throws StorageException {
if (FileBasedIndexImpl.DO_TRACE_STUB_INDEX_UPDATE) {
LOG.info("iterating keys updated_id = " + System.identityHashCode(newKeys));
}
boolean modified = false;
for (K oldKey : oldKeys) {
if (!newKeys.contains(oldKey)) {
removeProcessor.process(oldKey, fileId);
if (!modified) modified = true;
}
}
for (K oldKey : newKeys) {
if (!oldKeys.contains(oldKey)) {
addProcessor.process(oldKey, null, fileId);
if (!modified) modified = true;
}
}
if (FileBasedIndexImpl.DO_TRACE_STUB_INDEX_UPDATE) {
LOG.info("keys iteration finished updated_id = " + System.identityHashCode(newKeys) + "; modified = " + modified);
}
return modified;
ProgressManager.getInstance().executeNonCancelableSection(() -> {
try {
if (FileBasedIndexImpl.DO_TRACE_STUB_INDEX_UPDATE) {
LOG.info("stub index '" + stubIndexKey + "' update: " + fileId +
" old = " + Arrays.toString(oldKeys.toArray()) +
" new = " + Arrays.toString(newKeys.toArray()) +
" updated_id = " + System.identityHashCode(newKeys));
}
});
}
catch (StorageException e) {
LOG.info(e);
requestRebuild();
}
final UpdatableIndex<K, Void, FileContent> index = getIndex(stubIndexKey);
if (index == null) return;
index.updateWithMap(new AbstractUpdateData<K, Void>(fileId) {
@Override
protected boolean iterateKeys(@NotNull KeyValueUpdateProcessor<? super K, ? super Void> addProcessor,
@NotNull KeyValueUpdateProcessor<? super K, ? super Void> updateProcessor,
@NotNull RemovedKeyProcessor<? super K> removeProcessor) throws StorageException {
if (FileBasedIndexImpl.DO_TRACE_STUB_INDEX_UPDATE) {
LOG.info("iterating keys updated_id = " + System.identityHashCode(newKeys));
}
boolean modified = false;
for (K oldKey : oldKeys) {
if (!newKeys.contains(oldKey)) {
removeProcessor.process(oldKey, fileId);
if (!modified) modified = true;
}
}
for (K oldKey : newKeys) {
if (!oldKeys.contains(oldKey)) {
addProcessor.process(oldKey, null, fileId);
if (!modified) modified = true;
}
}
if (FileBasedIndexImpl.DO_TRACE_STUB_INDEX_UPDATE) {
LOG.info("keys iteration finished updated_id = " + System.identityHashCode(newKeys) + "; modified = " + modified);
}
return modified;
}
});
}
catch (StorageException e) {
LOG.info(e);
requestRebuild();
}
});
}
private class StubIndexInitialization extends IndexInfrastructure.DataInitialization<AsyncState> {