Author: cziegeler
Date: Tue Apr 7 09:24:31 2015
New Revision: 1671771
URL: http://svn.apache.org/r1671771
Log:
SLING-4564 : Use a single listener registered for multiple path in JCR
installer.
Modified:
sling/trunk/installer/providers/jcr/src/main/java/org/apache/sling/installer/provider/jcr/impl/RootFolderListener.java
Modified:
sling/trunk/installer/providers/jcr/src/main/java/org/apache/sling/installer/provider/jcr/impl/RootFolderListener.java
URL:
http://svn.apache.org/viewvc/sling/trunk/installer/providers/jcr/src/main/java/org/apache/sling/installer/provider/jcr/impl/RootFolderListener.java?rev=1671771&r1=1671770&r2=1671771&view=diff
==============================================================================
---
sling/trunk/installer/providers/jcr/src/main/java/org/apache/sling/installer/provider/jcr/impl/RootFolderListener.java
(original)
+++
sling/trunk/installer/providers/jcr/src/main/java/org/apache/sling/installer/provider/jcr/impl/RootFolderListener.java
Tue Apr 7 09:24:31 2015
@@ -18,6 +18,7 @@
*/
package org.apache.sling.installer.provider.jcr.impl;
+import java.util.Iterator;
import java.util.List;
import javax.jcr.RepositoryException;
@@ -42,10 +43,13 @@ class RootFolderListener implements Even
private final InstallerConfig cfg;
+ private final String pathWithSlash;
+
RootFolderListener(final Session session, final String path, final
RescanTimer timer, final InstallerConfig cfg)
throws RepositoryException {
this.timer = timer;
this.watchedPath = path;
+ this.pathWithSlash = path;
this.cfg = cfg;
final int eventTypes = Event.NODE_ADDED | Event.NODE_REMOVED
@@ -73,8 +77,15 @@ class RootFolderListener implements Even
public void onEvent(final EventIterator it) {
// we only do the global scan for node changes
boolean globalScan = false;
- // copy watched folders
+ // copy watched folders and remove all for other roots
final List<WatchedFolder> checkFolders = cfg.cloneWatchedFolders();
+ final Iterator<WatchedFolder> i = checkFolders.iterator();
+ while ( i.hasNext() ) {
+ final WatchedFolder wf = i.next();
+ if ( !wf.getPathWithSlash().startsWith(this.pathWithSlash)) {
+ i.remove();
+ }
+ }
while(it.hasNext()) {
final Event e = it.nextEvent();
logger.debug("Got event {}", e);
@@ -84,10 +95,12 @@ class RootFolderListener implements Even
try {
final String path = e.getPath();
- for(final WatchedFolder folder : checkFolders) {
+ final Iterator<WatchedFolder> ii = checkFolders.iterator();
+ while ( ii.hasNext() ) {
+ final WatchedFolder folder = ii.next();
if ( path.startsWith(folder.getPathWithSlash()) ) {
folder.markForScan();
- checkFolders.remove(folder);
+ ii.remove();
break;
}
}
