X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-inmemory-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fstore%2Fimpl%2FChainedTransactionCommitImpl.java;h=ff55c01a25be1fc824daaf563018e9b9e10abfd2;hp=05e3d5cb26e5944dc46de6a6d3e7b7fc87ad56b3;hb=978152c5de3bf78ab6da5da4c2db391eec063429;hpb=0f3ae2f9e4151a60245a2b295cc7998f0d0e745f diff --git a/opendaylight/md-sal/sal-inmemory-datastore/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/ChainedTransactionCommitImpl.java b/opendaylight/md-sal/sal-inmemory-datastore/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/ChainedTransactionCommitImpl.java index 05e3d5cb26..ff55c01a25 100644 --- a/opendaylight/md-sal/sal-inmemory-datastore/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/ChainedTransactionCommitImpl.java +++ b/opendaylight/md-sal/sal-inmemory-datastore/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/ChainedTransactionCommitImpl.java @@ -13,13 +13,14 @@ import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort; import org.opendaylight.controller.sal.core.spi.data.ForwardingDOMStoreThreePhaseCommitCohort; +import org.opendaylight.controller.sal.core.spi.data.SnapshotBackedWriteTransaction; final class ChainedTransactionCommitImpl extends ForwardingDOMStoreThreePhaseCommitCohort { - private final SnapshotBackedWriteTransaction transaction; + private final SnapshotBackedWriteTransaction transaction; private final DOMStoreThreePhaseCommitCohort delegate; private final DOMStoreTransactionChainImpl txChain; - ChainedTransactionCommitImpl(final SnapshotBackedWriteTransaction transaction, + ChainedTransactionCommitImpl(final SnapshotBackedWriteTransaction transaction, final DOMStoreThreePhaseCommitCohort delegate, final DOMStoreTransactionChainImpl txChain) { this.transaction = Preconditions.checkNotNull(transaction); this.delegate = Preconditions.checkNotNull(delegate); @@ -37,12 +38,12 @@ final class ChainedTransactionCommitImpl extends ForwardingDOMStoreThreePhaseCom Futures.addCallback(commitFuture, new FutureCallback() { @Override public void onFailure(final Throwable t) { - txChain.onTransactionFailed(transaction, t); + txChain.transactionFailed(transaction, t); } @Override public void onSuccess(final Void result) { - txChain.onTransactionCommited(transaction); + txChain.transactionCommited(transaction); } }); return commitFuture;