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 md...@apache.org on 2017/03/22 13:31:48 UTC

svn commit: r1788107 - /jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/SegmentCompactionIT.java

Author: mduerig
Date: Wed Mar 22 13:31:48 2017
New Revision: 1788107

URL: http://svn.apache.org/viewvc?rev=1788107&view=rev
Log:
OAK-5969: SegmentCompactionIT should expose SegmentNodeStore statistics via JMX

Modified:
    jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/SegmentCompactionIT.java

Modified: jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/SegmentCompactionIT.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/SegmentCompactionIT.java?rev=1788107&r1=1788106&r2=1788107&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/SegmentCompactionIT.java (original)
+++ jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/SegmentCompactionIT.java Wed Mar 22 13:31:48 2017
@@ -225,6 +225,7 @@ public class SegmentCompactionIT {
         assumeTrue(ENABLED);
 
         ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
+        MetricStatisticsProvider statisticsProvider = new MetricStatisticsProvider(mBeanServer, executor);
         SegmentGCOptions gcOptions = defaultGCOptions()
                 .setEstimationDisabled(true)
                 .setForceTimeout(3600);
@@ -233,9 +234,11 @@ public class SegmentCompactionIT {
                 .withMemoryMapping(true)
                 .withGCMonitor(gcMonitor)
                 .withGCOptions(gcOptions)
-                .withStatisticsProvider(new MetricStatisticsProvider(mBeanServer, executor))
+                .withStatisticsProvider(statisticsProvider)
+                .build();
+        nodeStore = SegmentNodeStoreBuilders.builder(fileStore)
+                .withStatisticsProvider(statisticsProvider)
                 .build();
-        nodeStore = SegmentNodeStoreBuilders.builder(fileStore).build();
         WriterCacheManager cacheManager = builder.getCacheManager();
         Runnable cancelGC = new Runnable() {
             @Override
@@ -278,6 +281,8 @@ public class SegmentCompactionIT {
         assertNotNull(nodeDeduplicationCacheStats);
         registrations.add(registerMBean(nodeDeduplicationCacheStats,
                 new ObjectName("IT:TYPE=" + nodeDeduplicationCacheStats.getName())));
+        registrations.add(registerMBean(nodeStore.getStats(),
+                new ObjectName("IT:TYPE=" + "SegmentNodeStore statistics")));
         mBeanRegistration = new CompositeRegistration(registrations);
     }