opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/connect/dom/BindingToDomCommitHandler.java

   1 package org.opendaylight.controller.sal.binding.impl.connect.dom;
   2
   3 import java.util.Map;
   4 import java.util.concurrent.ConcurrentMap;
   5 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler;
   6 import org.opendaylight.controller.md.sal.common.api.data.DataModification;
   7 import org.opendaylight.controller.sal.common.util.CommitHandlerTransactions;
   8 import org.opendaylight.controller.sal.core.api.data.DataModificationTransaction;
   9 import org.opendaylight.controller.sal.core.api.data.DataProviderService;
  10 import org.opendaylight.yangtools.yang.binding.DataObject;
  11 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  12 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
  13 import org.opendaylight.yangtools.yang.data.impl.codec.BindingIndependentMappingService;
  14 import org.slf4j.Logger;
  15 import org.slf4j.LoggerFactory;
  16
  17 class BindingToDomCommitHandler implements
  18     DataCommitHandler<InstanceIdentifier<? extends DataObject>, DataObject> {
  19
  20     private final Logger LOG = LoggerFactory.getLogger(BindingToDomCommitHandler.class);
  21
  22     private final ConcurrentMap<Object, DomToBindingTransaction> bindingOpenedTransactions;
  23     private final ConcurrentMap<Object, BindingToDomTransaction> domOpenedTransactions;
  24     private org.opendaylight.controller.sal.core.api.data.DataProviderService biDataService;
  25     private BindingIndependentMappingService mappingService;
  26
  27     BindingToDomCommitHandler(final ConcurrentMap<Object, DomToBindingTransaction> bindingOpenedTransactions,
  28         final ConcurrentMap<Object, BindingToDomTransaction> domOpenedTransactions) {
  29         this.bindingOpenedTransactions = bindingOpenedTransactions;
  30         this.domOpenedTransactions = domOpenedTransactions;
  31     }
  32
  33     public void setBindingIndependentDataService(final DataProviderService biDataService) {
  34         this.biDataService = biDataService;
  35     }
  36
  37     public void setMappingService(BindingIndependentMappingService mappingService) {
  38         this.mappingService = mappingService;
  39     }
  40
  41     @Override
  42     public org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler.DataCommitTransaction<InstanceIdentifier<? extends DataObject>, DataObject> requestCommit(
  43         final DataModification<InstanceIdentifier<? extends DataObject>, DataObject> bindingTransaction) {
  44
  45         /**
  46          * Transaction was created as DOM transaction, in that case we do
  47          * not need to forward it back.
  48          */
  49         if (bindingOpenedTransactions.containsKey(bindingTransaction.getIdentifier())) {
  50             return CommitHandlerTransactions.allwaysSuccessfulTransaction(bindingTransaction);
  51         }
  52         DataModificationTransaction domTransaction = createBindingToDomTransaction(bindingTransaction);
  53         BindingToDomTransaction wrapped = new BindingToDomTransaction(domTransaction, bindingTransaction, domOpenedTransactions);
  54         LOG.trace("Forwarding Binding Transaction: {} as DOM Transaction: {} .",
  55             bindingTransaction.getIdentifier(), domTransaction.getIdentifier());
  56         return wrapped;
  57     }
  58
  59     private DataModificationTransaction createBindingToDomTransaction(
  60         final DataModification<InstanceIdentifier<? extends DataObject>, DataObject> source) {
  61         if (biDataService == null) {
  62             final String msg = "Binding Independent Service is not initialized correctly! Binding to DOM Transaction cannot be created for ";
  63             LOG.error(msg + "{}", source);
  64             throw new IllegalStateException(msg + source);
  65         }
  66         if (mappingService == null) {
  67             final String msg = "Mapping Service is not initialized correctly! Binding to DOM Transaction cannot be created for ";
  68             LOG.error(msg + "{}", source);
  69             throw new IllegalStateException(msg + source);
  70         }
  71         DataModificationTransaction target = biDataService.beginTransaction();
  72         LOG.debug("Created DOM Transaction {} for {},", target.getIdentifier(), source.getIdentifier());
  73         for (InstanceIdentifier<? extends DataObject> entry : source.getRemovedConfigurationData()) {
  74             org.opendaylight.yangtools.yang.data.api.InstanceIdentifier biEntry = mappingService.toDataDom(entry);
  75             target.removeConfigurationData(biEntry);
  76             LOG.debug("Delete of Binding Configuration Data {} is translated to {}", entry, biEntry);
  77         }
  78         for (InstanceIdentifier<? extends DataObject> entry : source.getRemovedOperationalData()) {
  79             org.opendaylight.yangtools.yang.data.api.InstanceIdentifier biEntry = mappingService.toDataDom(entry);
  80             target.removeOperationalData(biEntry);
  81             LOG.debug("Delete of Binding Operational Data {} is translated to {}", entry, biEntry);
  82         }
  83         for (Map.Entry<InstanceIdentifier<? extends DataObject>, DataObject> entry : source.getUpdatedConfigurationData()
  84             .entrySet()) {
  85             Map.Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> biEntry = mappingService
  86                 .toDataDom(entry);
  87             target.putConfigurationData(biEntry.getKey(), biEntry.getValue());
  88             LOG.debug("Update of Binding Configuration Data {} is translated to {}", entry, biEntry);
  89         }
  90         for (Map.Entry<InstanceIdentifier<? extends DataObject>, DataObject> entry : source.getUpdatedOperationalData()
  91             .entrySet()) {
  92             Map.Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> biEntry = mappingService
  93                 .toDataDom(entry);
  94             target.putOperationalData(biEntry.getKey(), biEntry.getValue());
  95             LOG.debug("Update of Binding Operational Data {} is translated to {}", entry, biEntry);
  96         }
  97         return target;
  98     }
  99 }