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());
             }
 


Reply via email to