X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fmdsal-trace%2Fdom-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Ftrace%2Fdom%2Fimpl%2FTracingReadWriteTransaction.java;h=ae331cb39630b360b43f190cb818dbf9093ab455;hp=fe57c8108d817a94d0699f3704daa5b6eb8e179d;hb=aaea3e9a92ae9d6fac04c4a065db4b35cbca9ed0;hpb=c2b97e243117918acf5aa77d58ad5dc25d32c105 diff --git a/opendaylight/md-sal/mdsal-trace/dom-impl/src/main/java/org/opendaylight/controller/md/sal/trace/dom/impl/TracingReadWriteTransaction.java b/opendaylight/md-sal/mdsal-trace/dom-impl/src/main/java/org/opendaylight/controller/md/sal/trace/dom/impl/TracingReadWriteTransaction.java index fe57c8108d..ae331cb396 100644 --- a/opendaylight/md-sal/mdsal-trace/dom-impl/src/main/java/org/opendaylight/controller/md/sal/trace/dom/impl/TracingReadWriteTransaction.java +++ b/opendaylight/md-sal/mdsal-trace/dom-impl/src/main/java/org/opendaylight/controller/md/sal/trace/dom/impl/TracingReadWriteTransaction.java @@ -9,20 +9,19 @@ package org.opendaylight.controller.md.sal.trace.dom.impl; import com.google.common.base.Optional; import com.google.common.util.concurrent.CheckedFuture; -import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.FluentFuture; import java.util.Objects; -import org.opendaylight.controller.md.sal.common.api.TransactionStatus; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException; -import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException; import org.opendaylight.controller.md.sal.dom.api.DOMDataReadWriteTransaction; import org.opendaylight.controller.md.sal.trace.closetracker.impl.CloseTracked; import org.opendaylight.controller.md.sal.trace.closetracker.impl.CloseTrackedRegistry; import org.opendaylight.controller.md.sal.trace.closetracker.impl.CloseTrackedTrait; -import org.opendaylight.yangtools.yang.common.RpcResult; +import org.opendaylight.mdsal.common.api.CommitInfo; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +@Deprecated(forRemoval = true) class TracingReadWriteTransaction extends AbstractTracingWriteTransaction implements DOMDataReadWriteTransaction, CloseTracked { @@ -33,7 +32,7 @@ class TracingReadWriteTransaction TracingReadWriteTransaction(DOMDataReadWriteTransaction delegate, TracingBroker tracingBroker, CloseTrackedRegistry readWriteTransactionsRegistry) { super(delegate, tracingBroker); - this.closeTracker = new CloseTrackedTrait<>(readWriteTransactionsRegistry); + this.closeTracker = new CloseTrackedTrait<>(readWriteTransactionsRegistry, this); this.delegate = Objects.requireNonNull(delegate); } @@ -49,13 +48,7 @@ class TracingReadWriteTransaction } @Override - public CheckedFuture submit() { - closeTracker.removeFromTrackedRegistry(); - return super.submit(); - } - - @Override - public ListenableFuture> commit() { + public FluentFuture commit() { closeTracker.removeFromTrackedRegistry(); return super.commit(); } @@ -70,4 +63,9 @@ class TracingReadWriteTransaction public StackTraceElement[] getAllocationContextStackTrace() { return closeTracker.getAllocationContextStackTrace(); } + + @Override + public CloseTracked getRealCloseTracked() { + return this; + } }