BUG-3128: Extract abstract shard implementations.

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

diff --git a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InmemoryDOMDataTreeShardWriteTransaction.java b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InmemoryDOMDataTreeShardWriteTransaction.java
index a476069a58060de9848578dfdbdfb984c5c4c845..57d78b860dbff1dd8cdb62b1c3aeafe0e3f805ce 100644 (file)
--- a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InmemoryDOMDataTreeShardWriteTransaction.java
+++ b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InmemoryDOMDataTreeShardWriteTransaction.java
@@ -20,6 +20,8 @@ import java.util.concurrent.atomic.AtomicLong;
 import org.opendaylight.mdsal.common.api.ReadFailedException;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier;
 import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteCursor;
+import org.opendaylight.mdsal.dom.spi.shard.DOMDataTreeShardWriteTransaction;
+import org.opendaylight.mdsal.dom.spi.shard.ForeignShardModificationContext;
 import org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort;
 import org.opendaylight.yangtools.concepts.Identifiable;
 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
@@ -38,21 +40,21 @@ class InmemoryDOMDataTreeShardWriteTransaction implements DOMDataTreeShardWriteT
         MERGE {
             @Override
             void applyOnLeaf(final DOMDataTreeWriteCursor cursor, final PathArgument child,
-                    final NormalizedNode<?, ?> data) {
+                             final NormalizedNode<?, ?> data) {
                 cursor.merge(child, data);
             }
         },
         DELETE {
             @Override
             void applyOnLeaf(final DOMDataTreeWriteCursor cursor, final PathArgument child,
-                    final NormalizedNode<?, ?> data) {
+                             final NormalizedNode<?, ?> data) {
                 cursor.delete(child);
             }
         },
         WRITE {
             @Override
             void applyOnLeaf(final DOMDataTreeWriteCursor cursor, final PathArgument child,
-                    final NormalizedNode<?, ?> data) {
+                             final NormalizedNode<?, ?> data) {
                 cursor.write(child, data);
             }
         };
@@ -60,7 +62,7 @@ class InmemoryDOMDataTreeShardWriteTransaction implements DOMDataTreeShardWriteT
         abstract void applyOnLeaf(DOMDataTreeWriteCursor cursor, PathArgument child, NormalizedNode<?, ?> data);
 
         void apply(final DOMDataTreeWriteCursor cursor, final YangInstanceIdentifier path,
-                final NormalizedNode<?, ?> data) {
+                   final NormalizedNode<?, ?> data) {
             int enterCount = 0;
             final Iterator<PathArgument> it = path.getPathArguments().iterator();
             if (it.hasNext()) {
@@ -116,7 +118,7 @@ class InmemoryDOMDataTreeShardWriteTransaction implements DOMDataTreeShardWriteT
 
     private DOMDataTreeWriteCursor getCursor() {
         if (cursor == null) {
-            cursor = new ShardDataModificationCursor(modification, this);
+            cursor = new InMemoryShardDataModificationCursor(modification, this);
         }
         return cursor;
     }
@@ -125,7 +127,7 @@ class InmemoryDOMDataTreeShardWriteTransaction implements DOMDataTreeShardWriteT
         final YangInstanceIdentifier relativePath = toRelative(path);
         Preconditions.checkArgument(!YangInstanceIdentifier.EMPTY.equals(relativePath),
                 "Deletion of shard root is not allowed");
-        SimpleCursorOperation.DELETE.apply(getCursor(), relativePath , null);
+        SimpleCursorOperation.DELETE.apply(getCursor(), relativePath, null);
     }
 
     void merge(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) {