BUG 5697 : Consumer support in shards

[mdsal.git] / dom / mdsal-dom-inmemory-datastore / src / main / java / org / opendaylight / mdsal / dom / store / inmemory / InMemoryDOMDataTreeShard.java

diff --git a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShard.java b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShard.java
index 5ccc8e4f3b9943d2c3c78716e7584db12ddf95d2..4a48a6471ac20ee5805abd83092f48eb7e47be98 100644 (file)
--- a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShard.java
+++ b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShard.java
@@ -17,10 +17,15 @@ import java.util.HashMap;
 import java.util.Iterator;
 import java.util.Map;
 import java.util.Map.Entry;
+import java.util.concurrent.ExecutorService;
+import javax.annotation.Nonnull;
 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeChangeListener;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeShard;
 import org.opendaylight.mdsal.dom.spi.DOMDataTreePrefixTable;
+import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
 import org.opendaylight.yangtools.yang.data.api.schema.tree.CursorAwareDataTreeSnapshot;
 import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree;
 import org.opendaylight.yangtools.yang.data.api.schema.tree.TreeType;
@@ -29,7 +34,7 @@ import org.opendaylight.yangtools.yang.model.api.SchemaContext;
 import org.opendaylight.yangtools.yang.model.api.SchemaContextListener;
 
 @Beta
-public class InMemoryDOMDataTreeShard implements WriteableDOMDataTreeShard, SchemaContextListener {
+public class InMemoryDOMDataTreeShard implements ReadableWriteableDOMDataTreeShard, SchemaContextListener {
 
     private static final class SubshardProducerSpecification {
         private final Collection<DOMDataTreeIdentifier> prefixes = new ArrayList<>(1);
@@ -52,39 +57,27 @@ public class InMemoryDOMDataTreeShard implements WriteableDOMDataTreeShard, Sche
         }
     }
 
-    private static final class ChildShardContext {
-        private final WriteableDOMDataTreeShard shard;
-        private final DOMDataTreeIdentifier prefix;
-
-        public ChildShardContext(final DOMDataTreeIdentifier prefix, final WriteableDOMDataTreeShard shard) {
-            this.prefix = Preconditions.checkNotNull(prefix);
-            this.shard = Preconditions.checkNotNull(shard);
-        }
-
-        public WriteableDOMDataTreeShard getShard() {
-            return shard;
-        }
-
-        public DOMDataTreeIdentifier getPrefix() {
-            return prefix;
-        }
-    }
-
     private final DOMDataTreePrefixTable<ChildShardContext> childShardsTable = DOMDataTreePrefixTable.create();
+
     private final Map<DOMDataTreeIdentifier, ChildShardContext> childShards = new HashMap<>();
     private final DOMDataTreeIdentifier prefix;
     private final DataTree dataTree;
 
-    private InMemoryDOMDataTreeShard(final DOMDataTreeIdentifier prefix) {
+    private InMemoryDOMDataTreeShardChangePublisher shardChangePublisher;
+
+    private InMemoryDOMDataTreeShard(final DOMDataTreeIdentifier prefix, final ExecutorService dataTreeChangeExecutor,
+                                     final int maxDataChangeListenerQueueSize) {
         this.prefix = Preconditions.checkNotNull(prefix);
 
         final TreeType treeType = treeTypeFor(prefix.getDatastoreType());
-        this.dataTree = prefix.getRootIdentifier().isEmpty() ? InMemoryDataTreeFactory.getInstance().create(treeType)
-                : InMemoryDataTreeFactory.getInstance().create(treeType, prefix.getRootIdentifier());
+        this.dataTree = InMemoryDataTreeFactory.getInstance().create(treeType, prefix.getRootIdentifier());
+
+        this.shardChangePublisher = new InMemoryDOMDataTreeShardChangePublisher(dataTreeChangeExecutor, maxDataChangeListenerQueueSize, dataTree, prefix.getRootIdentifier(), childShards);
     }
 
-    public static InMemoryDOMDataTreeShard create(final DOMDataTreeIdentifier id) {
-        return new InMemoryDOMDataTreeShard(id);
+    public static InMemoryDOMDataTreeShard create(final DOMDataTreeIdentifier id, final ExecutorService dataTreeChangeExecutor,
+                                                  final int maxDataChangeListenerQueueSize) {
+        return new InMemoryDOMDataTreeShard(id, dataTreeChangeExecutor, maxDataChangeListenerQueueSize);
     }
 
     @Override
@@ -113,6 +106,12 @@ public class InMemoryDOMDataTreeShard implements WriteableDOMDataTreeShard, Sche
         return new InMemoryDOMDataTreeShardProducer(this, prefixes);
     }
 
+    @Nonnull
+    @Override
+    public <L extends DOMDataTreeChangeListener> ListenerRegistration<L> registerTreeChangeListener(@Nonnull YangInstanceIdentifier treeId, @Nonnull L listener) {
+        return shardChangePublisher.registerTreeChangeListener(treeId, listener);
+    }
+
     private void addChildShard(final DOMDataTreeIdentifier prefix, final DOMDataTreeShard child) {
         ChildShardContext context = createContextFor(prefix, child);
         childShards.put(prefix, context);
@@ -212,6 +211,6 @@ public class InMemoryDOMDataTreeShard implements WriteableDOMDataTreeShard, Sche
             builder.addSubshard(spec.getPrefix(), foreignContext);
         }
 
-        return new InmemoryDOMDataTreeShardWriteTransaction(builder.build(), dataTree);
+        return new InmemoryDOMDataTreeShardWriteTransaction(builder.build(), dataTree, shardChangePublisher);
     }
 }