2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.md.sal.binding.compat;
10 import java.util.Collections;
11 import java.util.HashMap;
14 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
15 import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent;
16 import org.opendaylight.yangtools.yang.binding.DataObject;
17 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
20 public abstract class HydrogenDataChangeEvent implements
21 DataChangeEvent<InstanceIdentifier<? extends DataObject>, DataObject> {
23 private HydrogenDataChangeEvent() {
26 public static final DataChangeEvent<InstanceIdentifier<?>, DataObject> createOperational(
27 final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
28 return new OperationalChangeEvent(change);
31 public static final DataChangeEvent<InstanceIdentifier<?>, DataObject> createConfiguration(
32 final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
33 return new ConfigurationChangeEvent(change);
37 public Map<InstanceIdentifier<?>, DataObject> getCreatedOperationalData() {
38 return Collections.emptyMap();
42 public Map<InstanceIdentifier<?>, DataObject> getCreatedConfigurationData() {
43 return Collections.emptyMap();
47 public Map<InstanceIdentifier<?>, DataObject> getUpdatedOperationalData() {
48 return Collections.emptyMap();
52 public Map<InstanceIdentifier<?>, DataObject> getUpdatedConfigurationData() {
53 return Collections.emptyMap();
57 public Set<InstanceIdentifier<?>> getRemovedConfigurationData() {
58 return Collections.emptySet();
62 public Set<InstanceIdentifier<?>> getRemovedOperationalData() {
63 return Collections.emptySet();
67 public Map<InstanceIdentifier<?>, DataObject> getOriginalConfigurationData() {
68 return Collections.emptyMap();
72 public Map<InstanceIdentifier<?>, DataObject> getOriginalOperationalData() {
73 return Collections.emptyMap();
77 public DataObject getOriginalConfigurationSubtree() {
82 public DataObject getOriginalOperationalSubtree() {
87 public DataObject getUpdatedConfigurationSubtree() {
92 public DataObject getUpdatedOperationalSubtree() {
96 @SuppressWarnings({ "rawtypes", "unchecked" })
97 private static final class OperationalChangeEvent extends HydrogenDataChangeEvent {
99 private final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> delegate;
100 private Map<InstanceIdentifier<?>, DataObject> updatedCache;
102 public OperationalChangeEvent(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
103 this.delegate = change;
107 public Map<InstanceIdentifier<?>, DataObject> getCreatedOperationalData() {
108 return delegate.getCreatedData();
112 public Set<InstanceIdentifier<?>> getRemovedOperationalData() {
113 return delegate.getRemovedPaths();
117 public DataObject getOriginalOperationalSubtree() {
118 return delegate.getOriginalSubtree();
122 public DataObject getUpdatedOperationalSubtree() {
123 return delegate.getUpdatedSubtree();
127 public Map<InstanceIdentifier<?>, DataObject> getOriginalOperationalData() {
128 return (Map) delegate.getOriginalData();
132 public Map<InstanceIdentifier<?>, DataObject> getUpdatedOperationalData() {
133 if(updatedCache == null) {
134 final Map<InstanceIdentifier<?>, DataObject> created = delegate.getCreatedData();
135 final Map<InstanceIdentifier<?>, DataObject> updated = delegate.getUpdatedData();
136 final Map<InstanceIdentifier<?>, DataObject> updatedComposite =
137 new HashMap<>(created.size() + updated.size());
138 updatedComposite.putAll(created);
139 updatedComposite.putAll(updated);
140 updatedCache = Collections.unmodifiableMap(updatedComposite);
146 public String toString() {
147 return "OperationalChangeEvent [delegate=" + delegate + "]";
152 @SuppressWarnings({ "rawtypes", "unchecked" })
153 private static final class ConfigurationChangeEvent extends HydrogenDataChangeEvent {
155 private final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> delegate;
156 private Map<InstanceIdentifier<?>, DataObject> updatedCache;
158 public ConfigurationChangeEvent(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
159 this.delegate = change;
163 public Map<InstanceIdentifier<?>, DataObject> getCreatedConfigurationData() {
164 return delegate.getCreatedData();
168 public Set<InstanceIdentifier<?>> getRemovedConfigurationData() {
169 return delegate.getRemovedPaths();
173 public DataObject getOriginalConfigurationSubtree() {
174 return delegate.getOriginalSubtree();
178 public DataObject getUpdatedConfigurationSubtree() {
179 return delegate.getUpdatedSubtree();
183 public Map<InstanceIdentifier<?>, DataObject> getOriginalConfigurationData() {
184 return (Map) delegate.getOriginalData();
188 public Map<InstanceIdentifier<?>, DataObject> getUpdatedConfigurationData() {
189 if(updatedCache == null) {
190 final Map<InstanceIdentifier<?>, DataObject> created = delegate.getCreatedData();
191 final Map<InstanceIdentifier<?>, DataObject> updated = delegate.getUpdatedData();
192 final Map<InstanceIdentifier<?>, DataObject> updatedComposite =
193 new HashMap<>(created.size() + updated.size());
194 updatedComposite.putAll(created);
195 updatedComposite.putAll(updated);
196 updatedCache = Collections.unmodifiableMap(updatedComposite);
202 public String toString() {
203 return "ConfigurationChangeEvent [delegate=" + delegate + "]";