Author: chetanm
Date: Thu Nov 24 14:01:46 2016
New Revision: 1771134

URL: http://svn.apache.org/viewvc?rev=1771134&view=rev
Log:
OAK-4898 - Allow for external changes to have a CommitInfo attached

-- Switch to Nonnull annotation for CommitInfo param
-- Pass CommitInfo.EMPTY_EXTERNAL while dispatching changes
   - As part of initial Observer registration

Modified:
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/memory/MemoryNodeStore.java
    
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/multiplex/MultiplexingNodeStore.java

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/memory/MemoryNodeStore.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/memory/MemoryNodeStore.java?rev=1771134&r1=1771133&r2=1771134&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/memory/MemoryNodeStore.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/memory/MemoryNodeStore.java
 Thu Nov 24 14:01:46 2016
@@ -84,7 +84,7 @@ public class MemoryNodeStore implements
 
     @Override
     public synchronized Closeable addObserver(Observer observer) {
-        observer.contentChanged(getRoot(), null);
+        observer.contentChanged(getRoot(), CommitInfo.EMPTY_EXTERNAL);
 
         Closeable closeable = new Closeable() {
             @Override
@@ -124,7 +124,7 @@ public class MemoryNodeStore implements
     @Override
     public synchronized NodeState merge(
             @Nonnull NodeBuilder builder, @Nonnull CommitHook commitHook,
-            @Nullable CommitInfo info) throws CommitFailedException {
+            @Nonnull CommitInfo info) throws CommitFailedException {
         checkArgument(builder instanceof MemoryNodeBuilder);
         MemoryNodeBuilder mnb = (MemoryNodeBuilder) builder;
         checkArgument(mnb.isRoot());

Modified: 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/multiplex/MultiplexingNodeStore.java
URL: 
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/multiplex/MultiplexingNodeStore.java?rev=1771134&r1=1771133&r2=1771134&view=diff
==============================================================================
--- 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/multiplex/MultiplexingNodeStore.java
 (original)
+++ 
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/multiplex/MultiplexingNodeStore.java
 Thu Nov 24 14:01:46 2016
@@ -277,7 +277,7 @@ public class MultiplexingNodeStore imple
 
     @Override
     public Closeable addObserver(final Observer observer) {
-        observer.contentChanged(getRoot(), null);
+        observer.contentChanged(getRoot(), CommitInfo.EMPTY_EXTERNAL);
         observers.add(observer);
         return new Closeable() {
             @Override


Reply via email to