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/05/17 06:40:46 UTC

svn commit: r1795402 - /jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/directory/IndexConsistencyChecker.java

Author: chetanm
Date: Wed May 17 06:40:46 2017
New Revision: 1795402

URL: http://svn.apache.org/viewvc?rev=1795402&view=rev
Log:
OAK-5558 - Consistency checker for Lucene indexes

Provide option to pass in a PrintStream

Modified:
    jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/directory/IndexConsistencyChecker.java

Modified: jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/directory/IndexConsistencyChecker.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/directory/IndexConsistencyChecker.java?rev=1795402&r1=1795401&r2=1795402&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/directory/IndexConsistencyChecker.java (original)
+++ jackrabbit/oak/trunk/oak-lucene/src/main/java/org/apache/jackrabbit/oak/plugins/index/lucene/directory/IndexConsistencyChecker.java Wed May 17 06:40:46 2017
@@ -67,6 +67,8 @@ public class IndexConsistencyChecker {
     private final String indexPath;
     private final File workDirRoot;
     private File workDir;
+    private PrintStream printStream;
+    private boolean verbose;
 
     public enum Level {
         /**
@@ -220,6 +222,14 @@ public class IndexConsistencyChecker {
         this.workDirRoot = checkNotNull(workDirRoot);
     }
 
+    public void setPrintStream(PrintStream printStream) {
+        this.printStream = printStream;
+    }
+
+    public void setVerbose(boolean verbose) {
+        this.verbose = verbose;
+    }
+
     public Result check(Level level) throws IOException {
         return check(level, true);
     }
@@ -312,7 +322,9 @@ public class IndexConsistencyChecker {
             log.debug("[{}][{}] Directory content found to be consistent. Proceeding to IndexCheck", indexPath, dirName);
             CheckIndex ci = new CheckIndex(targetDir);
 
-            if (log.isDebugEnabled()) {
+            if (printStream != null) {
+                ci.setInfoStream(printStream, verbose);
+            } else if (log.isDebugEnabled()) {
                 ci.setInfoStream(new LoggingPrintStream(log), log.isTraceEnabled());
             }