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

[chetanm]

Author: chetanm
Date: Fri May  5 10:55:31 2017
New Revision: 1794011

URL: http://svn.apache.org/viewvc?rev=1794011&view=rev
Log:
OAK-6176 - Service to provide access to async indexer state

-- Add a method to construct lastIndexedTo property
-- Add a method to check if given name is async name or not

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

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java?rev=1794011&r1=1794010&r2=1794011&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
 Fri May  5 10:55:31 2017
@@ -207,7 +207,7 @@ public class AsyncIndexUpdate implements
     public AsyncIndexUpdate(@Nonnull String name, @Nonnull NodeStore store,
                             @Nonnull IndexEditorProvider provider, 
StatisticsProvider statsProvider, boolean switchOnSync) {
         this.name = checkValidName(name);
-        this.lastIndexedTo = name + "-LastIndexedTo";
+        this.lastIndexedTo = lastIndexedTo(name);
         this.store = checkNotNull(store);
         this.provider = checkNotNull(provider);
         this.switchOnSync = switchOnSync;
@@ -230,6 +230,10 @@ public class AsyncIndexUpdate implements
         return asyncName;
     }
 
+    public static boolean isAsyncLaneName(String asyncName){
+        return IndexConstants.ASYNC_REINDEX_VALUE.equals(asyncName) || 
asyncName.endsWith("async");
+    }
+
     /**
      * Index update callback that tries to raise the async status flag when
      * the first index change is detected.
@@ -781,6 +785,10 @@ public class AsyncIndexUpdate implements
         return name + "-lease";
     }
 
+    static String lastIndexedTo(String name) {
+        return name + "-LastIndexedTo";
+    }
+
     private static String getTempCpName(String name) {
         return name + "-temp";
     }