X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fbinding%2Fimpl%2Fconnect%2Fdom%2FBindingToDomCommitHandler.java;fp=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fbinding%2Fimpl%2Fconnect%2Fdom%2FBindingToDomCommitHandler.java;h=0000000000000000000000000000000000000000;hp=44198bfc767bd8454a7bd83ef3bbfad4b553b3fa;hb=0dcdc14a4ff38b39fed0d07658941a09a4c043fd;hpb=b55b98c40f0dd78c192ab872aea283832460a335 diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/connect/dom/BindingToDomCommitHandler.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/connect/dom/BindingToDomCommitHandler.java deleted file mode 100644 index 44198bfc76..0000000000 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/connect/dom/BindingToDomCommitHandler.java +++ /dev/null @@ -1,104 +0,0 @@ -package org.opendaylight.controller.sal.binding.impl.connect.dom; - -import java.util.Map; -import java.util.concurrent.ConcurrentMap; - -import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler; -import org.opendaylight.controller.md.sal.common.api.data.DataModification; -import org.opendaylight.controller.sal.common.util.CommitHandlerTransactions; -import org.opendaylight.controller.sal.core.api.data.DataModificationTransaction; -import org.opendaylight.controller.sal.core.api.data.DataProviderService; -import org.opendaylight.yangtools.yang.binding.DataObject; -import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.CompositeNode; -import org.opendaylight.yangtools.yang.data.impl.codec.BindingIndependentMappingService; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * @deprecated This is part of the legacy DataBrokerService - */ -@Deprecated -class BindingToDomCommitHandler implements - DataCommitHandler, DataObject> { - - private final Logger LOG = LoggerFactory.getLogger(BindingToDomCommitHandler.class); - - private final ConcurrentMap bindingOpenedTransactions; - private final ConcurrentMap domOpenedTransactions; - private org.opendaylight.controller.sal.core.api.data.DataProviderService biDataService; - private BindingIndependentMappingService mappingService; - - BindingToDomCommitHandler(final ConcurrentMap bindingOpenedTransactions, - final ConcurrentMap domOpenedTransactions) { - this.bindingOpenedTransactions = bindingOpenedTransactions; - this.domOpenedTransactions = domOpenedTransactions; - } - - public void setBindingIndependentDataService(final DataProviderService biDataService) { - this.biDataService = biDataService; - } - - public void setMappingService(final BindingIndependentMappingService mappingService) { - this.mappingService = mappingService; - } - - @Override - public org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler.DataCommitTransaction, DataObject> requestCommit( - final DataModification, DataObject> bindingTransaction) { - - /** - * Transaction was created as DOM transaction, in that case we do - * not need to forward it back. - */ - if (bindingOpenedTransactions.containsKey(bindingTransaction.getIdentifier())) { - return CommitHandlerTransactions.allwaysSuccessfulTransaction(bindingTransaction); - } - DataModificationTransaction domTransaction = createBindingToDomTransaction(bindingTransaction); - BindingToDomTransaction wrapped = new BindingToDomTransaction(domTransaction, bindingTransaction, domOpenedTransactions); - LOG.trace("Forwarding Binding Transaction: {} as DOM Transaction: {} .", - bindingTransaction.getIdentifier(), domTransaction.getIdentifier()); - return wrapped; - } - - private DataModificationTransaction createBindingToDomTransaction( - final DataModification, DataObject> source) { - if (biDataService == null) { - final String msg = "Binding Independent Service is not initialized correctly! Binding to DOM Transaction cannot be created for "; - LOG.error(msg + "{}", source); - throw new IllegalStateException(msg + source); - } - if (mappingService == null) { - final String msg = "Mapping Service is not initialized correctly! Binding to DOM Transaction cannot be created for "; - LOG.error(msg + "{}", source); - throw new IllegalStateException(msg + source); - } - DataModificationTransaction target = biDataService.beginTransaction(); - LOG.debug("Created DOM Transaction {} for {},", target.getIdentifier(), source.getIdentifier()); - for (InstanceIdentifier entry : source.getRemovedConfigurationData()) { - org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier biEntry = mappingService.toDataDom(entry); - target.removeConfigurationData(biEntry); - LOG.debug("Delete of Binding Configuration Data {} is translated to {}", entry, biEntry); - } - for (InstanceIdentifier entry : source.getRemovedOperationalData()) { - org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier biEntry = mappingService.toDataDom(entry); - target.removeOperationalData(biEntry); - LOG.debug("Delete of Binding Operational Data {} is translated to {}", entry, biEntry); - } - for (Map.Entry, DataObject> entry : source.getUpdatedConfigurationData() - .entrySet()) { - Map.Entry biEntry = mappingService - .toDataDom(entry); - target.putConfigurationData(biEntry.getKey(), biEntry.getValue()); - LOG.debug("Update of Binding Configuration Data {} is translated to {}", entry, biEntry); - } - for (Map.Entry, DataObject> entry : source.getUpdatedOperationalData() - .entrySet()) { - Map.Entry biEntry = mappingService - .toDataDom(entry); - target.putOperationalData(biEntry.getKey(), biEntry.getValue()); - LOG.debug("Update of Binding Operational Data {} is translated to {}", entry, biEntry); - } - return target; - } -}