CDS: Implement front-end support for local transactions

[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / datastore / LocalTransactionChain.java

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionChain.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionChain.java
new file mode 100644 (file)
index 0000000..93e09db
--- /dev/null
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionChain.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.controller.cluster.datastore;
+
+import akka.actor.ActorSelection;
+import com.google.common.base.Preconditions;
+import org.opendaylight.controller.cluster.datastore.identifiers.TransactionIdentifier;
+import org.opendaylight.controller.sal.core.spi.data.AbstractSnapshotBackedTransactionChain;
+import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
+import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
+import org.opendaylight.controller.sal.core.spi.data.SnapshotBackedWriteTransaction;
+import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree;
+import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification;
+import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeSnapshot;
+
+/**
+ * Transaction chain instantiated on top of a locally-available DataTree. It does not instantiate
+ * a transaction in the leader and rather chains transactions on top of themselves.
+ */
+final class LocalTransactionChain extends AbstractSnapshotBackedTransactionChain<TransactionIdentifier>
+        implements LocalTransactionFactory {
+    private static final Throwable ABORTED = new Throwable("Transaction aborted");
+    private final TransactionChainProxy parent;
+    private final ActorSelection leader;
+    private final DataTree tree;
+
+    LocalTransactionChain(final TransactionChainProxy parent, final ActorSelection leader, final DataTree tree) {
+        this.parent = Preconditions.checkNotNull(parent);
+        this.leader = Preconditions.checkNotNull(leader);
+        this.tree = Preconditions.checkNotNull(tree);
+    }
+
+    DataTree getDataTree() {
+        return tree;
+    }
+
+    @Override
+    protected TransactionIdentifier nextTransactionIdentifier() {
+        throw new UnsupportedOperationException();
+    }
+
+    @Override
+    protected boolean getDebugTransactions() {
+        return false;
+    }
+
+    @Override
+    protected DataTreeSnapshot takeSnapshot() {
+        return tree.takeSnapshot();
+    }
+
+    @Override
+    protected DOMStoreThreePhaseCommitCohort createCohort(final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction, final DataTreeModification modification) {
+        return new LocalThreePhaseCommitCohort(parent.getActorContext(), leader, transaction, modification) {
+            @Override
+            protected void transactionAborted(final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
+                onTransactionFailed(transaction, ABORTED);
+            }
+
+            @Override
+            protected void transactionCommitted(final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
+                onTransactionCommited(transaction);
+            }
+        };
+    }
+
+    @Override
+    public DOMStoreReadWriteTransaction newReadWriteTransaction(TransactionIdentifier identifier) {
+        return super.newReadWriteTransaction(identifier);
+    }
+}