X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FNoOpTransactionContext.java;fp=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FNoOpTransactionContext.java;h=bfb0046ba027b809be6d53dd507d4d90eb491365;hp=d98a1b4046a33f456213c8528b88aa5387b70e85;hb=82be660900ab9bdd84941a0c3498c1ae36982aba;hpb=4984818d4212c06778b32be5b1338256b2b64dcb diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/NoOpTransactionContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/NoOpTransactionContext.java index d98a1b4046..bfb0046ba0 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/NoOpTransactionContext.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/NoOpTransactionContext.java @@ -22,7 +22,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import scala.concurrent.Future; -final class NoOpTransactionContext extends AbstractTransactionContext { +final class NoOpTransactionContext extends TransactionContext { private static final Logger LOG = LoggerFactory.getLogger(NoOpTransactionContext.class); private final Throwable failure; @@ -33,26 +33,25 @@ final class NoOpTransactionContext extends AbstractTransactionContext { } @Override - public void closeTransaction() { + void closeTransaction() { LOG.debug("NoOpTransactionContext {} closeTransaction called", getIdentifier()); } @Override - public Future directCommit(final Boolean havePermit) { + Future directCommit(final Boolean havePermit) { LOG.debug("Tx {} directCommit called, failure", getIdentifier(), failure); return akka.dispatch.Futures.failed(failure); } @Override - public Future readyTransaction(final Boolean havePermit, + Future readyTransaction(final Boolean havePermit, final Optional> participatingShardNamess) { LOG.debug("Tx {} readyTransaction called, failure", getIdentifier(), failure); return akka.dispatch.Futures.failed(failure); } @Override - public void executeRead(final AbstractRead readCmd, final SettableFuture proxyFuture, - final Boolean havePermit) { + void executeRead(final AbstractRead readCmd, final SettableFuture proxyFuture, final Boolean havePermit) { LOG.debug("Tx {} executeRead {} called path = {}", getIdentifier(), readCmd.getClass().getSimpleName(), readCmd.getPath()); @@ -67,17 +66,17 @@ final class NoOpTransactionContext extends AbstractTransactionContext { } @Override - public void executeDelete(final YangInstanceIdentifier path, final Boolean havePermit) { + void executeDelete(final YangInstanceIdentifier path, final Boolean havePermit) { LOG.debug("Tx {} executeDelete called path = {}", getIdentifier(), path); } @Override - public void executeMerge(final YangInstanceIdentifier path, final NormalizedNode data, final Boolean havePermit) { + void executeMerge(final YangInstanceIdentifier path, final NormalizedNode data, final Boolean havePermit) { LOG.debug("Tx {} executeMerge called path = {}", getIdentifier(), path); } @Override - public void executeWrite(final YangInstanceIdentifier path, final NormalizedNode data, final Boolean havePermit) { + void executeWrite(final YangInstanceIdentifier path, final NormalizedNode data, final Boolean havePermit) { LOG.debug("Tx {} executeWrite called path = {}", getIdentifier(), path); } }