svn commit: r1755586 - /jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/file/FileStoreStatsTest.java

[md...@apache.org]

Author: mduerig
Date: Tue Aug  9 09:27:25 2016
New Revision: 1755586

URL: http://svn.apache.org/viewvc?rev=1755586&view=rev
Log:
OAK-4097: Add metric for FileStore journal writes
Test case covering the journal writer statistics
Credits to Andrei Dulceanu for the patch

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

Modified: jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/file/FileStoreStatsTest.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/file/FileStoreStatsTest.java?rev=1755586&r1=1755585&r2=1755586&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/file/FileStoreStatsTest.java (original)
+++ jackrabbit/oak/trunk/oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/file/FileStoreStatsTest.java Tue Aug  9 09:27:25 2016
@@ -30,6 +30,11 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 
 import org.apache.jackrabbit.oak.commons.concurrent.ExecutorCloser;
+import org.apache.jackrabbit.oak.segment.SegmentNodeStore;
+import org.apache.jackrabbit.oak.segment.SegmentNodeStoreBuilders;
+import org.apache.jackrabbit.oak.spi.commit.CommitInfo;
+import org.apache.jackrabbit.oak.spi.commit.EmptyHook;
+import org.apache.jackrabbit.oak.spi.state.NodeBuilder;
 import org.apache.jackrabbit.oak.stats.DefaultStatisticsProvider;
 import org.apache.jackrabbit.oak.stats.StatisticsProvider;
 import org.junit.After;
@@ -96,4 +101,22 @@ public class FileStoreStatsTest {
         assertEquals(1, stats.getJournalWriteStatsAsCount());
     }
 
+    @Test
+    public void testJournalWriteStats() throws Exception {
+        StatisticsProvider statsProvider = new DefaultStatisticsProvider(executor);
+        FileStore fileStore = fileStoreBuilder(segmentFolder.newFolder()).withStatisticsProvider(statsProvider).build();
+        FileStoreStats stats = new FileStoreStats(statsProvider, fileStore, 0);
+
+        SegmentNodeStore nodeStore = SegmentNodeStoreBuilders.builder(fileStore).build();
+
+        for (int i = 0; i < 10; i++) {
+            NodeBuilder root = nodeStore.getRoot().builder();
+            root.setProperty("count", i);
+            nodeStore.merge(root, EmptyHook.INSTANCE, CommitInfo.EMPTY);
+
+            fileStore.flush();
+        }
+
+        assertEquals(10, stats.getJournalWriteStatsAsCount());
+    }
 }