1 package org.opendaylight.controller.sal.binding.impl.connect.dom;
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;
19 class DomToBindingCommitHandler implements //
20 RegistrationListener<DataCommitHandlerRegistration<InstanceIdentifier<? extends DataObject>, DataObject>>, //
21 DataCommitHandler<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> {
23 private final Logger LOG = LoggerFactory.getLogger(DomToBindingCommitHandler.class);
25 private final ConcurrentMap<Object, DomToBindingTransaction> bindingOpenedTransactions;
26 private final ConcurrentMap<Object, BindingToDomTransaction> domOpenedTransactions;
28 DomToBindingCommitHandler(final ConcurrentMap<Object, DomToBindingTransaction> bindingOpenedTransactions,
29 final ConcurrentMap<Object, BindingToDomTransaction> domOpenedTransactions) {
30 this.bindingOpenedTransactions = bindingOpenedTransactions;
31 this.domOpenedTransactions = domOpenedTransactions;
34 private DataProviderService baDataService;
35 private BindingIndependentMappingService mappingService;
37 public void setBindingAwareDataService(DataProviderService baDataService) {
38 this.baDataService = baDataService;
41 public void setMappingService(BindingIndependentMappingService mappingService) {
42 this.mappingService = mappingService;
46 public void onRegister(final DataCommitHandlerRegistration<InstanceIdentifier<? extends DataObject>, DataObject> registration) {
47 mappingService.toDataDom(registration.getPath());
51 public void onUnregister(
52 final DataCommitHandlerRegistration<InstanceIdentifier<? extends DataObject>, DataObject> registration) {
54 // FIXME: do registration based on only active commit handlers.
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();
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
68 if (domOpenedTransactions.containsKey(identifier)) {
69 return CommitHandlerTransactions.allwaysSuccessfulTransaction(domTransaction);
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;
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);
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);
92 org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction target = baDataService
94 for (org.opendaylight.yangtools.yang.data.api.InstanceIdentifier entry : source.getRemovedConfigurationData()) {
97 InstanceIdentifier<?> baEntry = mappingService.fromDataDom(entry);
98 target.removeConfigurationData(baEntry);
99 } catch (DeserializationException e) {
100 LOG.error("Ommiting from BA transaction: {}.", entry, e);
103 for (org.opendaylight.yangtools.yang.data.api.InstanceIdentifier entry : source.getRemovedOperationalData()) {
106 InstanceIdentifier<?> baEntry = mappingService.fromDataDom(entry);
107 target.removeOperationalData(baEntry);
108 } catch (DeserializationException e) {
109 LOG.error("Ommiting from BA transaction: {}.", entry, e);
112 for (Map.Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> entry : source
113 .getUpdatedConfigurationData().entrySet()) {
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);
122 for (Map.Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> entry : source
123 .getUpdatedOperationalData().entrySet()) {
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);