Author: chetanm Date: Thu Sep 15 07:17:40 2016 New Revision: 1760851 URL: http://svn.apache.org/viewvc?rev=1760851&view=rev Log: OAK-4412 - Lucene hybrid index
In case queue is stopped drop and further process doc call Modified: jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/hybrid/DocumentQueue.java Modified: jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/hybrid/DocumentQueue.java URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/hybrid/DocumentQueue.java?rev=1760851&r1=1760850&r2=1760851&view=diff ============================================================================== --- jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/hybrid/DocumentQueue.java (original) +++ jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/hybrid/DocumentQueue.java Thu Sep 15 07:17:40 2016 @@ -165,6 +165,12 @@ public class DocumentQueue implements Cl } private void processDoc(String indexPath, Iterable<LuceneDoc> docs){ + + //Drop the write call if stopped + if (stopped) { + return; + } + IndexNode indexNode = tracker.acquireIndexNode(indexPath); if (indexNode == null) { log.debug("No IndexNode found for index [{}].", indexPath); @@ -205,7 +211,5 @@ public class DocumentQueue implements Cl docsQueue.clear(); docsQueue.add(STOP); stopped = true; - - //TODO Should we wait for STOP to be processed } }