Author: chetanm
Date: Wed Nov 16 09:23:25 2016
New Revision: 1769947

URL: http://svn.apache.org/viewvc?rev=1769947&view=rev
Log:
OAK-5113 - Avoid dispatching changes for checkpoint related changes

Add ignored testcase

Modified:
    
jackrabbit/oak/trunk/oak-it/src/test/java/org/apache/jackrabbit/oak/spi/state/CheckpointTest.java

Modified: 
jackrabbit/oak/trunk/oak-it/src/test/java/org/apache/jackrabbit/oak/spi/state/CheckpointTest.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-it/src/test/java/org/apache/jackrabbit/oak/spi/state/CheckpointTest.java?rev=1769947&r1=1769946&r2=1769947&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-it/src/test/java/org/apache/jackrabbit/oak/spi/state/CheckpointTest.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-it/src/test/java/org/apache/jackrabbit/oak/spi/state/CheckpointTest.java
 Wed Nov 16 09:23:25 2016
@@ -19,6 +19,11 @@
 
 package org.apache.jackrabbit.oak.spi.state;
 
+import java.util.concurrent.atomic.AtomicInteger;
+
+import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
+
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNull;
@@ -31,8 +36,11 @@ import org.apache.jackrabbit.oak.api.Com
 import org.apache.jackrabbit.oak.fixture.NodeStoreFixture;
 import org.apache.jackrabbit.oak.spi.commit.CommitInfo;
 import org.apache.jackrabbit.oak.spi.commit.EmptyHook;
+import org.apache.jackrabbit.oak.spi.commit.Observable;
+import org.apache.jackrabbit.oak.spi.commit.Observer;
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 
 public class CheckpointTest extends OakBaseTest {
@@ -83,6 +91,27 @@ public class CheckpointTest extends OakB
         assertEquals(props, store.checkpointInfo(cp));
     }
 
+    @Ignore("OAK-5113")
+    @Test
+    public void noContentChangeForCheckpoints() throws Exception{
+        final AtomicInteger invocationCount = new AtomicInteger();
+        ((Observable)store).addObserver(new Observer() {
+            @Override
+            public void contentChanged(@Nonnull NodeState root, @Nullable 
CommitInfo info) {
+                invocationCount.incrementAndGet();
+            }
+        });
+
+        invocationCount.set(0);
+
+        String cp = store.checkpoint(Long.MAX_VALUE);
+        assertEquals(0, invocationCount.get());
+
+        store.release(cp);
+        assertEquals(0, invocationCount.get());
+
+    }
+
     @Test
     public void retrieveAny() {
         assertTrue(store.retrieve("r42-0-0") == null);


Reply via email to