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%2FTransactionContext.java;h=4eea785964b1e8ef9b4023390547a813408863e4;hb=dea515c8870769408b9bea29f555d6b71ff43211;hp=b6af31e641ce48e95903f935984181340a9eaf72;hpb=37f0504d391efd8b7d61403759fcc22a6dd3a093;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionContext.java index b6af31e641..4eea785964 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionContext.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionContext.java @@ -9,9 +9,7 @@ package org.opendaylight.controller.cluster.datastore; import akka.actor.ActorSelection; import com.google.common.base.Optional; -import com.google.common.util.concurrent.CheckedFuture; -import java.util.List; -import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException; +import com.google.common.util.concurrent.SettableFuture; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import scala.concurrent.Future; @@ -31,10 +29,11 @@ interface TransactionContext { void mergeData(YangInstanceIdentifier path, NormalizedNode data); - CheckedFuture>, ReadFailedException> readData( - final YangInstanceIdentifier path); + void readData(final YangInstanceIdentifier path, SettableFuture>> proxyFuture); - CheckedFuture dataExists(YangInstanceIdentifier path); + void dataExists(YangInstanceIdentifier path, SettableFuture proxyFuture); - List> getRecordedOperationFutures(); -} \ No newline at end of file + boolean supportsDirectCommit(); + + Future directCommit(); +}