X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fdom%2Fbroker%2Fimpl%2FAbstractDOMForwardedTransactionFactory.java;h=4bb71978699f5a1aa6fc84cad9cd12a2df259036;hp=08888c13cffec8b43da6efa8fb9703bcc9beb37c;hb=9958ef4e1096731404d3c8060ef8376cd105f8ef;hpb=dbd3524a5cdd27dd49fd09f1cf4ff0ff40e85c5e diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/AbstractDOMForwardedTransactionFactory.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/AbstractDOMForwardedTransactionFactory.java index 08888c13cf..4bb7197869 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/AbstractDOMForwardedTransactionFactory.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/AbstractDOMForwardedTransactionFactory.java @@ -9,6 +9,7 @@ package org.opendaylight.controller.md.sal.dom.broker.impl; import com.google.common.base.Preconditions; import com.google.common.util.concurrent.CheckedFuture; +import java.util.Collection; import java.util.EnumMap; import java.util.Map; import java.util.Map.Entry; @@ -23,11 +24,14 @@ import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransactio import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort; import org.opendaylight.controller.sal.core.spi.data.DOMStoreTransactionFactory; import org.opendaylight.controller.sal.core.spi.data.DOMStoreWriteTransaction; +import org.opendaylight.yangtools.concepts.Path; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; /** - * * Abstract composite transaction factory. * + *

* Provides an convenience common implementation for composite DOM Transactions, * where subtransaction is identified by {@link LogicalDatastoreType} type and * implementation of subtransaction is provided by @@ -53,7 +57,7 @@ abstract class AbstractDOMForwardedTransactionFactory * Callback invoked when {@link DOMDataWriteTransaction#submit()} is invoked * on transaction created by this factory. * * @param transaction - * Transaction on which {@link DOMDataWriteTransaction#commit()} + * Transaction on which {@link DOMDataWriteTransaction#submit()} * was invoked. * @param cohorts * Iteratable of cohorts for subtransactions associated with @@ -76,20 +81,24 @@ abstract class AbstractDOMForwardedTransactionFactory submit(final DOMDataWriteTransaction transaction, - final Iterable cohorts); + protected abstract CheckedFuture + submit(DOMDataWriteTransaction transaction, Collection cohorts); /** * Creates a new composite read-only transaction * + *

* Creates a new composite read-only transaction backed by one transaction * per factory in {@link #getTxFactories()}. * + *

* Subtransaction for reading is selected by supplied * {@link LogicalDatastoreType} as parameter for - * {@link DOMDataReadOnlyTransaction#read(LogicalDatastoreType,org.opendaylight.yangtools.yang.data.api.InstanceIdentifier)} - * . + * {@link DOMDataReadOnlyTransaction#read(LogicalDatastoreType, + * org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier)}. * + *

* Id of returned transaction is retrieved via * {@link #newTransactionIdentifier()}. * @@ -115,34 +124,37 @@ abstract class AbstractDOMForwardedTransactionFactory * Implementation of composite Write-only transaction is following: * - *