X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FLocalTransactionContext.java;h=6b3006941817e05e4a7de6789e67871dda506846;hb=82be660900ab9bdd84941a0c3498c1ae36982aba;hp=da6d6d14fe9a2c5a574914df0e36d463b0345a09;hpb=7e62b4a59f9e43bcd0585845f1aeb55c44199f27;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java index da6d6d14fe..6b30069418 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/LocalTransactionContext.java @@ -7,21 +7,24 @@ */ package org.opendaylight.controller.cluster.datastore; +import static java.util.Objects.requireNonNull; + import akka.actor.ActorSelection; -import com.google.common.base.Preconditions; import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.MoreExecutors; import com.google.common.util.concurrent.SettableFuture; import java.util.Optional; import java.util.SortedSet; +import java.util.function.Consumer; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.opendaylight.controller.cluster.datastore.messages.AbstractRead; -import org.opendaylight.controller.cluster.datastore.modification.AbstractModification; import org.opendaylight.mdsal.common.api.ReadFailedException; import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction; import org.opendaylight.mdsal.dom.spi.store.DOMStoreTransaction; import org.opendaylight.mdsal.dom.spi.store.DOMStoreWriteTransaction; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import scala.concurrent.Future; /** @@ -30,7 +33,7 @@ import scala.concurrent.Future; * * @author Thomas Pantelis */ -abstract class LocalTransactionContext extends AbstractTransactionContext { +abstract class LocalTransactionContext extends TransactionContext { private final DOMStoreTransaction txDelegate; private final LocalTransactionReadySupport readySupport; private Exception operationError; @@ -38,21 +41,20 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { LocalTransactionContext(final DOMStoreTransaction txDelegate, final TransactionIdentifier identifier, final LocalTransactionReadySupport readySupport) { super(identifier); - this.txDelegate = Preconditions.checkNotNull(txDelegate); + this.txDelegate = requireNonNull(txDelegate); this.readySupport = readySupport; } - protected abstract DOMStoreWriteTransaction getWriteDelegate(); + abstract DOMStoreWriteTransaction getWriteDelegate(); - protected abstract DOMStoreReadTransaction getReadDelegate(); + abstract DOMStoreReadTransaction getReadDelegate(); - @Override @SuppressWarnings("checkstyle:IllegalCatch") - public void executeModification(final AbstractModification modification, final Boolean havePermit) { + private void executeModification(final Consumer consumer) { incrementModificationCount(); if (operationError == null) { try { - modification.apply(getWriteDelegate()); + consumer.accept(getWriteDelegate()); } catch (Exception e) { operationError = e; } @@ -60,7 +62,22 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { } @Override - public void executeRead(final AbstractRead readCmd, final SettableFuture proxyFuture, + void executeDelete(final YangInstanceIdentifier path, final Boolean havePermit) { + executeModification(transaction -> transaction.delete(path)); + } + + @Override + void executeMerge(final YangInstanceIdentifier path, final NormalizedNode data, final Boolean havePermit) { + executeModification(transaction -> transaction.merge(path, data)); + } + + @Override + void executeWrite(final YangInstanceIdentifier path, final NormalizedNode data, final Boolean havePermit) { + executeModification(transaction -> transaction.write(path, data)); + } + + @Override + void executeRead(final AbstractRead readCmd, final SettableFuture proxyFuture, final Boolean havePermit) { Futures.addCallback(readCmd.apply(getReadDelegate()), new FutureCallback() { @Override @@ -76,26 +93,26 @@ abstract class LocalTransactionContext extends AbstractTransactionContext { }, MoreExecutors.directExecutor()); } - private LocalThreePhaseCommitCohort ready() { - logModificationCount(); - return readySupport.onTransactionReady(getWriteDelegate(), operationError); - } - @Override - public Future readyTransaction(final Boolean havePermit, + Future readyTransaction(final Boolean havePermit, final Optional> participatingShardNames) { final LocalThreePhaseCommitCohort cohort = ready(); return cohort.initiateCoordinatedCommit(participatingShardNames); } @Override - public Future directCommit(final Boolean havePermit) { + Future directCommit(final Boolean havePermit) { final LocalThreePhaseCommitCohort cohort = ready(); return cohort.initiateDirectCommit(); } @Override - public void closeTransaction() { + void closeTransaction() { txDelegate.close(); } + + private LocalThreePhaseCommitCohort ready() { + logModificationCount(); + return readySupport.onTransactionReady(getWriteDelegate(), operationError); + } }