X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FNoOpTransactionContext.java;h=89a8c03c6a0272b6e38d04139cc5a85877aa5256;hb=55a9b9f42a14c56060f74b38f84d444c0fbfecc4;hp=d14a936ac3249d643d8e06d727072517450ebb73;hpb=123afd8b015173c459f4937c84eb2e91286f65a8;p=controller.git 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 d14a936ac3..89a8c03c6a 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 @@ -9,6 +9,8 @@ package org.opendaylight.controller.cluster.datastore; import akka.actor.ActorSelection; import com.google.common.util.concurrent.SettableFuture; +import java.util.Optional; +import java.util.SortedSet; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.opendaylight.controller.cluster.datastore.exceptions.NoShardLeaderException; import org.opendaylight.controller.cluster.datastore.messages.AbstractRead; @@ -36,13 +38,14 @@ final class NoOpTransactionContext extends AbstractTransactionContext { @Override public Future directCommit(final Boolean havePermit) { - LOG.debug("Tx {} directCommit called, failure: {}", getIdentifier(), failure); + LOG.debug("Tx {} directCommit called, failure", getIdentifier(), failure); return akka.dispatch.Futures.failed(failure); } @Override - public Future readyTransaction(final Boolean havePermit) { - LOG.debug("Tx {} readyTransaction called, failure: {}", getIdentifier(), failure); + public Future readyTransaction(final Boolean havePermit, + final Optional> participatingShardNamess) { + LOG.debug("Tx {} readyTransaction called, failure", getIdentifier(), failure); return akka.dispatch.Futures.failed(failure); }