BUG-5280: move transactions keeping to history

[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / databroker / actors / dds / ClientLocalProxyHistory.java

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyHistory.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ClientLocalProxyHistory.java
similarity index 67%
rename from opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyHistory.java
rename to opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ClientLocalProxyHistory.java
index 8ccc4a6353d7acbd80b1da6f09073476e99093ad..f06e57cc369db228b1155ad683afc974e34153a5 100644 (file)
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyHistory.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/databroker/actors/dds/ClientLocalProxyHistory.java
@@ -7,17 +7,14 @@
  */
 package org.opendaylight.controller.cluster.databroker.actors.dds;
 
-import com.google.common.base.Preconditions;
 import org.opendaylight.controller.cluster.access.concepts.LocalHistoryIdentifier;
 import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
 import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree;
 
-final class LocalProxyHistory extends AbstractProxyHistory {
-    private final DataTree dataTree;
-
-    LocalProxyHistory(DistributedDataStoreClientBehavior client, LocalHistoryIdentifier identifier, DataTree dataTree) {
-        super(client, identifier);
-        this.dataTree = Preconditions.checkNotNull(dataTree);
+final class ClientLocalProxyHistory extends AbstractLocalProxyHistory {
+    ClientLocalProxyHistory(final DistributedDataStoreClientBehavior client, final LocalHistoryIdentifier identifier,
+        final DataTree dataTree) {
+        super(client, identifier, dataTree);
     }
 
     @Override
@@ -25,6 +22,6 @@ final class LocalProxyHistory extends AbstractProxyHistory {
             final TransactionIdentifier txId) {
         // FIXME: this violates history contract: we should use the last submitted transaction instead to ensure
         //        causality
-        return new LocalProxyTransaction(client, txId, dataTree.takeSnapshot());
+        return new LocalProxyTransaction(client, txId, takeSnapshot());
     }
 }
\ No newline at end of file