svn commit: r1770916 - /jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/IndexUpdateProvider.java

[chetanm]

Author: chetanm
Date: Wed Nov 23 06:16:42 2016
New Revision: 1770916

URL: http://svn.apache.org/viewvc?rev=1770916&view=rev
Log:
OAK-4939 - Isolate corrupted index and make async indexer more resilient

Allow passing in CorruptIndexHandler via IndexUpdateProvider

Modified:
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/IndexUpdateProvider.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/IndexUpdateProvider.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/IndexUpdateProvider.java?rev=1770916&r1=1770915&r2=1770916&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/IndexUpdateProvider.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/IndexUpdateProvider.java
 Wed Nov 23 06:16:42 2016
@@ -43,6 +43,8 @@ public class IndexUpdateProvider impleme
 
     private final MissingIndexProviderStrategy missingStrategy;
 
+    private CorruptIndexHandler corruptIndexHandler = CorruptIndexHandler.NOOP;
+
     public IndexUpdateProvider(IndexEditorProvider provider, boolean 
failOnMissingIndexProvider) {
         this(provider, null, failOnMissingIndexProvider);
     }
@@ -64,9 +66,12 @@ public class IndexUpdateProvider impleme
             NodeState before, NodeState after,
             NodeBuilder builder, CommitInfo info) {
 
-        IndexUpdate editor = new IndexUpdate(provider, async, after, builder, 
NOOP_CALLBACK, info)
+        IndexUpdate editor = new IndexUpdate(provider, async, after, builder, 
NOOP_CALLBACK, info, corruptIndexHandler)
                 .withMissingProviderStrategy(missingStrategy);
         return VisibleEditor.wrap(editor);
     }
 
+    public void setCorruptIndexHandler(CorruptIndexHandler 
corruptIndexHandler) {
+        this.corruptIndexHandler = corruptIndexHandler;
+    }
 }