opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/connect/dom/DomToBindingCommitHandler.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.RegistrationListener;
   6 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler;
   7 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandlerRegistration;
   8 import org.opendaylight.controller.md.sal.common.api.data.DataModification;
   9 import org.opendaylight.controller.sal.binding.api.data.DataProviderService;
  10 import org.opendaylight.controller.sal.common.util.CommitHandlerTransactions;
  11 import org.opendaylight.yangtools.yang.binding.DataObject;
  12 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  13 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
  14 import org.opendaylight.yangtools.yang.data.impl.codec.BindingIndependentMappingService;
  15 import org.opendaylight.yangtools.yang.data.impl.codec.DeserializationException;
  16 import org.slf4j.Logger;
  17 import org.slf4j.LoggerFactory;
  18
  19 class DomToBindingCommitHandler implements //
  20     RegistrationListener<DataCommitHandlerRegistration<InstanceIdentifier<? extends DataObject>, DataObject>>, //
  21     DataCommitHandler<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> {
  22
  23     private final Logger LOG = LoggerFactory.getLogger(DomToBindingCommitHandler.class);
  24
  25     private final ConcurrentMap<Object, DomToBindingTransaction> bindingOpenedTransactions;
  26     private final ConcurrentMap<Object, BindingToDomTransaction> domOpenedTransactions;
  27
  28     DomToBindingCommitHandler(final ConcurrentMap<Object, DomToBindingTransaction> bindingOpenedTransactions,
  29         final ConcurrentMap<Object, BindingToDomTransaction> domOpenedTransactions) {
  30         this.bindingOpenedTransactions = bindingOpenedTransactions;
  31         this.domOpenedTransactions = domOpenedTransactions;
  32     }
  33
  34     private DataProviderService baDataService;
  35     private BindingIndependentMappingService mappingService;
  36
  37     public void setBindingAwareDataService(DataProviderService baDataService) {
  38         this.baDataService = baDataService;
  39     }
  40
  41     public void setMappingService(BindingIndependentMappingService mappingService) {
  42         this.mappingService = mappingService;
  43     }
  44
  45     @Override
  46     public void onRegister(final DataCommitHandlerRegistration<InstanceIdentifier<? extends DataObject>, DataObject> registration) {
  47         mappingService.toDataDom(registration.getPath());
  48     }
  49
  50     @Override
  51     public void onUnregister(
  52         final DataCommitHandlerRegistration<InstanceIdentifier<? extends DataObject>, DataObject> registration) {
  53         // NOOP for now
  54         // FIXME: do registration based on only active commit handlers.
  55     }
  56
  57     @Override
  58     public org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler.DataCommitTransaction<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> requestCommit(
  59         final DataModification<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> domTransaction) {
  60         Object identifier = domTransaction.getIdentifier();
  61
  62         /**
  63          * We checks if the transcation was originated in this mapper. If it
  64          * was originated in this mapper we are returing allways success
  65          * commit hanlder to prevent creating loop in two-phase commit and
  66          * duplicating data.
  67          */
  68         if (domOpenedTransactions.containsKey(identifier)) {
  69             return CommitHandlerTransactions.allwaysSuccessfulTransaction(domTransaction);
  70         }
  71
  72         org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction baTransaction = createDomToBindingTransaction(domTransaction);
  73         DomToBindingTransaction forwardedTransaction = new DomToBindingTransaction(baTransaction, domTransaction, bindingOpenedTransactions);
  74         LOG.trace("Forwarding DOM Transaction: {} as Binding Transaction: {}.", domTransaction.getIdentifier(),
  75             baTransaction.getIdentifier());
  76         return forwardedTransaction;
  77     }
  78
  79     private org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction createDomToBindingTransaction(
  80         final DataModification<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> source) {
  81         if (baDataService == null) {
  82             final String msg = "Binding Aware Service is not initialized correctly! DOM to Binding Transaction cannot be created for ";
  83             LOG.error(msg + "{}", source);
  84             throw new IllegalStateException(msg + source);
  85         }
  86         if (mappingService == null) {
  87             final String msg = "Mapping Service is not initialized correctly! DOM to Binding Transaction cannot be created for ";
  88             LOG.error(msg + "{}", source);
  89             throw new IllegalStateException(msg + source);
  90         }
  91
  92         org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction target = baDataService
  93             .beginTransaction();
  94         for (org.opendaylight.yangtools.yang.data.api.InstanceIdentifier entry : source.getRemovedConfigurationData()) {
  95             try {
  96
  97                 InstanceIdentifier<?> baEntry = mappingService.fromDataDom(entry);
  98                 target.removeConfigurationData(baEntry);
  99             } catch (DeserializationException e) {
 100                 LOG.error("Ommiting from BA transaction: {}.", entry, e);
 101             }
 102         }
 103         for (org.opendaylight.yangtools.yang.data.api.InstanceIdentifier entry : source.getRemovedOperationalData()) {
 104             try {
 105
 106                 InstanceIdentifier<?> baEntry = mappingService.fromDataDom(entry);
 107                 target.removeOperationalData(baEntry);
 108             } catch (DeserializationException e) {
 109                 LOG.error("Ommiting from BA transaction: {}.", entry, e);
 110             }
 111         }
 112         for (Map.Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> entry : source
 113             .getUpdatedConfigurationData().entrySet()) {
 114             try {
 115                 InstanceIdentifier<?> baKey = mappingService.fromDataDom(entry.getKey());
 116                 DataObject baData = mappingService.dataObjectFromDataDom(baKey, entry.getValue());
 117                 target.putConfigurationData(baKey, baData);
 118             } catch (DeserializationException e) {
 119                 LOG.error("Ommiting from BA transaction: {}.", entry.getKey(), e);
 120             }
 121         }
 122         for (Map.Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> entry : source
 123             .getUpdatedOperationalData().entrySet()) {
 124             try {
 125
 126                 InstanceIdentifier<?> baKey = mappingService.fromDataDom(entry.getKey());
 127                 DataObject baData = mappingService.dataObjectFromDataDom(baKey, entry.getValue());
 128                 target.putOperationalData(baKey, baData);
 129             } catch (DeserializationException e) {
 130                 LOG.error("Ommiting from BA transaction: {}.", entry.getKey(), e);
 131             }
 132         }
 133         return target;
 134     }
 135 }