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=fe36661e671032d82caf8579967efa92e84b9513;hb=8ec5f25a203b59a09ef54169adedb35f069c7561;hp=d9a53ab29189b47e004623bb5938841a6affa34e;hpb=918285d16d9414e1061cf565ad45194725fc64a9;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 d9a53ab291..fe36661e67 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 @@ -12,7 +12,8 @@ import com.google.common.util.concurrent.SettableFuture; import java.util.Optional; import java.util.SortedSet; import org.opendaylight.controller.cluster.datastore.messages.AbstractRead; -import org.opendaylight.controller.cluster.datastore.modification.AbstractModification; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import scala.concurrent.Future; /* @@ -24,10 +25,14 @@ interface TransactionContext { Future readyTransaction(Boolean havePermit, Optional> participatingShardNames); - void executeModification(AbstractModification modification, Boolean havePermit); - void executeRead(AbstractRead readCmd, SettableFuture promise, Boolean havePermit); + void executeDelete(YangInstanceIdentifier path, Boolean havePermit); + + void executeMerge(YangInstanceIdentifier path, NormalizedNode data, Boolean havePermit); + + void executeWrite(YangInstanceIdentifier path, NormalizedNode data, Boolean havePermit); + Future directCommit(Boolean havePermit); /**