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);