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

coalesce change file events in small frame, usually merge e.g. large copy file change notifications

Browse Source
This commit is contained in:
Maxim.Mossienko
2013-07-18 18:53:17 +02:00
parent 9788de6363
commit 40163c6bb7
1 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-impl/src/com/intellij/openapi/vfs/impl/local/FileWatcher.java
+27
View File
@@ -91,6 +91,8 @@ public class FileWatcher {
private final Object myLock = new Object();
private DirtyPaths myDirtyPaths = new DirtyPaths();
private final String[] myLastChangedPathes = new String[2];
private int myLastChangedPathIndex;
/** @deprecated use {@linkplain com.intellij.openapi.vfs.impl.local.LocalFileSystemImpl#getFileWatcher()} (to remove in IDEA 13) */
public static FileWatcher getInstance() {
@@ -153,6 +155,8 @@ public class FileWatcher {
synchronized (myLock) {
DirtyPaths dirtyPaths = myDirtyPaths;
myDirtyPaths = new DirtyPaths();
myLastChangedPathIndex = 0;
for(int i = 0; i < myLastChangedPathes.length; ++i) myLastChangedPathes[i] = null;
return dirtyPaths;
}
}
@@ -522,6 +526,8 @@ public class FileWatcher {
notifyOnEvent();
}
private int myChangeRequests, myFilteredRequests;
private void processChange(String path, WatcherOp op) {
if (SystemInfo.isWindows && op == WatcherOp.RECDIRTY && path.length() == 3 && Character.isLetter(path.charAt(0))) {
VirtualFile root = LocalFileSystem.getInstance().findFileByPath(path);
@@ -534,6 +540,27 @@ public class FileWatcher {
return;
}
if (op == WatcherOp.CHANGE) {
synchronized (myLock) {
++myChangeRequests;
// TODO: remove logging once finalized
if ((myChangeRequests & 0x3ff) == 0) LOG.info("Change requests:" + myChangeRequests + ", filtered:" + myFilteredRequests);
for(int i = 0; i < myLastChangedPathes.length; ++i) {
int last = myLastChangedPathIndex - i - 1;
if (last < 0) last += myLastChangedPathes.length;
String lastChangedPath = myLastChangedPathes[last];
if (lastChangedPath != null && lastChangedPath.equals(path)) {
++myFilteredRequests;
return;
}
}
myLastChangedPathes[myLastChangedPathIndex ++] = path;
if (myLastChangedPathIndex == myLastChangedPathes.length) myLastChangedPathIndex = 0;
}
}
boolean exactPath = op != WatcherOp.DIRTY && op != WatcherOp.RECDIRTY;
Collection<String> paths = checkWatchable(path, exactPath, false);