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%2FStandaloneFrontendHistory.java;h=df13cd1368243ac8c128bc2eccf9c5ba14617bca;hb=f70fb5eaee514ffa5963049ac12286c2dee4ff80;hp=0278c1d1e590fccf69498bdeacfe02bddeea7120;hpb=e9efe27538adb5ae575f77fda90f147d46341801;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/StandaloneFrontendHistory.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/StandaloneFrontendHistory.java index 0278c1d1e5..df13cd1368 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/StandaloneFrontendHistory.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/StandaloneFrontendHistory.java @@ -20,7 +20,7 @@ import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier; import org.opendaylight.controller.cluster.access.concepts.LocalHistoryIdentifier; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.opendaylight.controller.cluster.datastore.utils.MutableUnsignedLongSet; -import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification; +import org.opendaylight.yangtools.yang.data.tree.api.DataTreeModification; /** * Standalone transaction specialization of {@link AbstractFrontendHistory}. There can be multiple open transactions @@ -60,12 +60,14 @@ final class StandaloneFrontendHistory extends AbstractFrontendHistory { @Override FrontendTransaction createOpenSnapshot(final TransactionIdentifier id) { - return FrontendReadOnlyTransaction.create(this, tree.newReadOnlyTransaction(id)); + return FrontendReadOnlyTransaction.create(this, + new ReadOnlyShardDataTreeTransaction(tree, id, tree.takeSnapshot())); } @Override FrontendTransaction createOpenTransaction(final TransactionIdentifier id) { - return FrontendReadWriteTransaction.createOpen(this, tree.newReadWriteTransaction(id)); + return FrontendReadWriteTransaction.createOpen(this, + new ReadWriteShardDataTreeTransaction(tree, id, tree.takeSnapshot().newModification())); } @Override