Author: tommaso
Date: Thu Jan 17 09:05:58 2019
New Revision: 1851505
URL: http://svn.apache.org/viewvc?rev=1851505&view=rev
Log:
OAK-7903 - introduced constant for metric name
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexerService.java
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/TrackingCorruptIndexHandler.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=1851505&r1=1851504&r2=1851505&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
Thu Jan 17 09:05:58 2019
@@ -220,7 +220,7 @@ public class AsyncIndexUpdate implements
this.leaseTimeOut = DEFAULT_ASYNC_TIMEOUT;
this.statisticsProvider = statsProvider;
this.indexStats = new AsyncIndexStats(name, statsProvider);
-
this.corruptIndexHandler.setMeterStats(statsProvider.getMeter("corrupt-index",
StatsOptions.METRICS_ONLY));
+
this.corruptIndexHandler.setMeterStats(statsProvider.getMeter(TrackingCorruptIndexHandler.CORRUPT_INDEX_METER_NAME,
StatsOptions.METRICS_ONLY));
}
public AsyncIndexUpdate(@NotNull String name, @NotNull NodeStore store,
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexerService.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexerService.java?rev=1851505&r1=1851504&r2=1851505&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexerService.java
(original)
+++
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexerService.java
Thu Jan 17 09:05:58 2019
@@ -191,7 +191,7 @@ public class AsyncIndexerService {
TrackingCorruptIndexHandler corruptIndexHandler = new
TrackingCorruptIndexHandler();
corruptIndexHandler.setCorruptInterval(failingIndexTimeoutSeconds,
TimeUnit.SECONDS);
corruptIndexHandler.setErrorWarnInterval(errorWarnIntervalSeconds,
TimeUnit.SECONDS);
-
corruptIndexHandler.setMeterStats(statisticsProvider.getMeter("corrupt-index",
StatsOptions.METRICS_ONLY));
+
corruptIndexHandler.setMeterStats(statisticsProvider.getMeter(TrackingCorruptIndexHandler.CORRUPT_INDEX_METER_NAME,
StatsOptions.METRICS_ONLY));
if (failingIndexTimeoutSeconds <= 0){
log.info("[failingIndexTimeoutSeconds] is set to {}. Auto corrupt
index isolation handling is disabled, warning log would be " +
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/TrackingCorruptIndexHandler.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/TrackingCorruptIndexHandler.java?rev=1851505&r1=1851504&r2=1851505&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/TrackingCorruptIndexHandler.java
(original)
+++
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/TrackingCorruptIndexHandler.java
Thu Jan 17 09:05:58 2019
@@ -46,6 +46,9 @@ import org.slf4j.LoggerFactory;
import static com.google.common.base.Preconditions.checkNotNull;
public class TrackingCorruptIndexHandler implements CorruptIndexHandler {
+
+ static final String CORRUPT_INDEX_METER_NAME = "corrupt-index";
+
private final Logger log = LoggerFactory.getLogger(getClass());
private Clock clock = Clock.SIMPLE;
private long errorWarnIntervalMillis = TimeUnit.MINUTES.toMillis(15);