You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by ch...@apache.org on 2017/01/12 06:29:45 UTC

svn commit: r1778377 - /jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/hybrid/DocumentQueue.java

Author: chetanm
Date: Thu Jan 12 06:29:45 2017
New Revision: 1778377

URL: http://svn.apache.org/viewvc?rev=1778377&view=rev
Log:
OAK-5445 - Log the path of LuceneDoc while adding it to queue

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=1778377&r1=1778376&r2=1778377&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 Jan 12 06:29:45 2017
@@ -151,6 +151,9 @@ public class DocumentQueue implements Cl
         boolean added = docsQueue.offer(doc);
         if (added) {
             queueSizeStats.inc();
+            if (log.isTraceEnabled()){
+                log.trace("Adding {} without wait to queue at size {}", doc, docsQueue.size());
+            }
         }
         return added;
     }
@@ -168,6 +171,9 @@ public class DocumentQueue implements Cl
 
         if (added) {
             queueSizeStats.inc();
+            if (log.isTraceEnabled()){
+                log.trace("Adding {} to queue at size {}", doc, docsQueue.size());
+            }
         } else {
             dropped.mark();
         }
@@ -210,6 +216,10 @@ public class DocumentQueue implements Cl
         return docs;
     }
 
+    private void addedToQueue(LuceneDoc doc){
+
+    }
+
     private void processDocs(String indexPath, Iterable<LuceneDoc> docs){
 
         //Drop the write call if stopped