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%2Fcompat%2FTranslatingDataChangeEvent.java;h=d6d79cd624ae05ae178eaf67228525cfe4c80f43;hp=827e4ca63d524d94cf9824c2e989bebdb54a9ac8;hb=0eb621d29daaf08979c356e2148e99c48458e169;hpb=5081a78bb782babe13ff70f342b13baa01d6b5ce diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingDataChangeEvent.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingDataChangeEvent.java index 827e4ca63d..d6d79cd624 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingDataChangeEvent.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/compat/TranslatingDataChangeEvent.java @@ -17,64 +17,64 @@ import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent; import org.opendaylight.controller.md.sal.common.impl.util.compat.DataNormalizationException; import org.opendaylight.controller.md.sal.common.impl.util.compat.DataNormalizer; import org.opendaylight.yangtools.yang.data.api.CompositeNode; -import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import com.google.common.collect.Maps; public abstract class TranslatingDataChangeEvent implements - DataChangeEvent { +DataChangeEvent { private TranslatingDataChangeEvent() { } - public static DataChangeEvent createOperational( - final AsyncDataChangeEvent> change, final DataNormalizer normalizer) { + public static DataChangeEvent createOperational( + final AsyncDataChangeEvent> change, final DataNormalizer normalizer) { return new OperationalChangeEvent(change, normalizer); } - public static DataChangeEvent createConfiguration( - final AsyncDataChangeEvent> change, final DataNormalizer normalizer) { + public static DataChangeEvent createConfiguration( + final AsyncDataChangeEvent> change, final DataNormalizer normalizer) { return new ConfigurationChangeEvent(change, normalizer); } @Override - public Map getCreatedOperationalData() { + public Map getCreatedOperationalData() { return Collections.emptyMap(); } @Override - public Map getCreatedConfigurationData() { + public Map getCreatedConfigurationData() { return Collections.emptyMap(); } @Override - public Map getUpdatedOperationalData() { + public Map getUpdatedOperationalData() { return Collections.emptyMap(); } @Override - public Map getUpdatedConfigurationData() { + public Map getUpdatedConfigurationData() { return Collections.emptyMap(); } @Override - public Set getRemovedConfigurationData() { + public Set getRemovedConfigurationData() { return Collections.emptySet(); } @Override - public Set getRemovedOperationalData() { + public Set getRemovedOperationalData() { return Collections.emptySet(); } @Override - public Map getOriginalConfigurationData() { + public Map getOriginalConfigurationData() { return Collections.emptyMap(); } @Override - public Map getOriginalOperationalData() { + public Map getOriginalOperationalData() { return Collections.emptyMap(); } @@ -98,27 +98,26 @@ public abstract class TranslatingDataChangeEvent implements return null; } - @SuppressWarnings({ "rawtypes", "unchecked" }) private final static class OperationalChangeEvent extends TranslatingDataChangeEvent { - private final AsyncDataChangeEvent> delegate; + private final AsyncDataChangeEvent> delegate; private final DataNormalizer normalizer; - private Map updatedCache; + private Map updatedCache; - public OperationalChangeEvent(final AsyncDataChangeEvent> change, - final DataNormalizer normalizer) { + public OperationalChangeEvent(final AsyncDataChangeEvent> change, + final DataNormalizer normalizer) { this.delegate = change; this.normalizer = normalizer; } @Override - public Map getCreatedOperationalData() { + public Map getCreatedOperationalData() { return transformToLegacy(normalizer, delegate.getCreatedData()); } @Override - public Set getRemovedOperationalData() { + public Set getRemovedOperationalData() { return delegate.getRemovedPaths(); } @@ -135,16 +134,16 @@ public abstract class TranslatingDataChangeEvent implements } @Override - public Map getOriginalOperationalData() { + public Map getOriginalOperationalData() { return transformToLegacy(normalizer, delegate.getOriginalData()); } @Override - public Map getUpdatedOperationalData() { + public Map getUpdatedOperationalData() { if(updatedCache == null) { - final Map updated = transformToLegacy(normalizer, delegate.getUpdatedData()); - final Map created = getCreatedConfigurationData(); - final HashMap updatedComposite = new HashMap<>(created.size() + updated.size()); + final Map updated = transformToLegacy(normalizer, delegate.getUpdatedData()); + final Map created = getCreatedConfigurationData(); + final HashMap updatedComposite = new HashMap<>(created.size() + updated.size()); updatedComposite.putAll(created); updatedComposite.putAll(updated); updatedCache = Collections.unmodifiableMap(updatedComposite); @@ -159,10 +158,10 @@ public abstract class TranslatingDataChangeEvent implements } - private static Map transformToLegacy(final DataNormalizer normalizer, final Map> nodes) { - final Map legacy = Maps.newHashMap(); + private static Map transformToLegacy(final DataNormalizer normalizer, final Map> nodes) { + final Map legacy = Maps.newHashMap(); - for (final Map.Entry> entry : nodes.entrySet()) { + for (final Map.Entry> entry : nodes.entrySet()) { try { legacy.put(normalizer.toLegacy(entry.getKey()), normalizer.toLegacy(entry.getKey(), entry.getValue())); } catch (final DataNormalizationException e) { @@ -174,24 +173,24 @@ public abstract class TranslatingDataChangeEvent implements private final static class ConfigurationChangeEvent extends TranslatingDataChangeEvent { - private final AsyncDataChangeEvent> delegate; + private final AsyncDataChangeEvent> delegate; private final DataNormalizer normalizer; - private Map updatedCache; + private Map updatedCache; - public ConfigurationChangeEvent(final AsyncDataChangeEvent> change, - final DataNormalizer normalizer) { + public ConfigurationChangeEvent(final AsyncDataChangeEvent> change, + final DataNormalizer normalizer) { this.delegate = change; this.normalizer = normalizer; } @Override - public Map getCreatedConfigurationData() { + public Map getCreatedConfigurationData() { return transformToLegacy(normalizer, delegate.getCreatedData()); } @Override - public Set getRemovedConfigurationData() { + public Set getRemovedConfigurationData() { return delegate.getRemovedPaths(); } @@ -208,16 +207,16 @@ public abstract class TranslatingDataChangeEvent implements } @Override - public Map getOriginalConfigurationData() { + public Map getOriginalConfigurationData() { return transformToLegacy(normalizer, delegate.getOriginalData()); } @Override - public Map getUpdatedConfigurationData() { + public Map getUpdatedConfigurationData() { if(updatedCache == null) { - final Map updated = transformToLegacy(normalizer, delegate.getUpdatedData()); - final Map created = getCreatedConfigurationData(); - final HashMap updatedComposite = new HashMap<>(created.size() + updated.size()); + final Map updated = transformToLegacy(normalizer, delegate.getUpdatedData()); + final Map created = getCreatedConfigurationData(); + final HashMap updatedComposite = new HashMap<>(created.size() + updated.size()); updatedComposite.putAll(created); updatedComposite.putAll(updated); updatedCache = Collections.unmodifiableMap(updatedComposite);