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%2Fsal%2Fdom%2Fbroker%2Fimpl%2FHashMapDataStore.java;h=1f82bd71b4a4cdf07ce8bfbd0c8d0e3829659aa2;hp=d7309b9ed31717ebe8641bdc4bee5f15ce8d948f;hb=de3e413b633b7555ae8f3fe2ec163dbb7dda5da8;hpb=5700d3fd27b5a76671b595822cf2dad9274acd2f diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/HashMapDataStore.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/HashMapDataStore.java index d7309b9ed3..1f82bd71b4 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/HashMapDataStore.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/HashMapDataStore.java @@ -18,7 +18,7 @@ import org.opendaylight.controller.sal.core.api.data.DataStore; import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.common.RpcResultBuilder; 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.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -26,44 +26,44 @@ public final class HashMapDataStore implements DataStore, AutoCloseable { private static final Logger LOG = LoggerFactory .getLogger(HashMapDataStore.class); - private final Map configuration = new ConcurrentHashMap(); - private final Map operational = new ConcurrentHashMap(); + private final Map configuration = new ConcurrentHashMap(); + private final Map operational = new ConcurrentHashMap(); @Override - public boolean containsConfigurationPath(final InstanceIdentifier path) { + public boolean containsConfigurationPath(final YangInstanceIdentifier path) { return configuration.containsKey(path); } @Override - public boolean containsOperationalPath(final InstanceIdentifier path) { + public boolean containsOperationalPath(final YangInstanceIdentifier path) { return operational.containsKey(path); } @Override - public Iterable getStoredConfigurationPaths() { + public Iterable getStoredConfigurationPaths() { return configuration.keySet(); } @Override - public Iterable getStoredOperationalPaths() { + public Iterable getStoredOperationalPaths() { return operational.keySet(); } @Override - public CompositeNode readConfigurationData(final InstanceIdentifier path) { + public CompositeNode readConfigurationData(final YangInstanceIdentifier path) { LOG.trace("Reading configuration path {}", path); return configuration.get(path); } @Override - public CompositeNode readOperationalData(InstanceIdentifier path) { + public CompositeNode readOperationalData(YangInstanceIdentifier path) { LOG.trace("Reading operational path {}", path); return operational.get(path); } @Override - public DataCommitHandler.DataCommitTransaction requestCommit( - final DataModification modification) { + public DataCommitHandler.DataCommitTransaction requestCommit( + final DataModification modification) { return new HashMapDataStoreTransaction(modification, this); } @@ -72,24 +72,24 @@ public final class HashMapDataStore implements DataStore, AutoCloseable { } public RpcResult finish(HashMapDataStoreTransaction transaction) { - final DataModification modification = transaction + final DataModification modification = transaction .getModification(); - for (final InstanceIdentifier removal : modification + for (final YangInstanceIdentifier removal : modification .getRemovedConfigurationData()) { LOG.trace("Removing configuration path {}", removal); remove(configuration, removal); } - for (final InstanceIdentifier removal : modification + for (final YangInstanceIdentifier removal : modification .getRemovedOperationalData()) { LOG.trace("Removing operational path {}", removal); remove(operational, removal); } if (LOG.isTraceEnabled()) { - for (final InstanceIdentifier a : modification + for (final YangInstanceIdentifier a : modification .getUpdatedConfigurationData().keySet()) { LOG.trace("Adding configuration path {}", a); } - for (final InstanceIdentifier a : modification + for (final YangInstanceIdentifier a : modification .getUpdatedOperationalData().keySet()) { LOG.trace("Adding operational path {}", a); } @@ -100,15 +100,15 @@ public final class HashMapDataStore implements DataStore, AutoCloseable { return RpcResultBuilder. success().build(); } - public void remove(final Map map, - final InstanceIdentifier identifier) { - Set affected = new HashSet(); - for (final InstanceIdentifier path : map.keySet()) { + public void remove(final Map map, + final YangInstanceIdentifier identifier) { + Set affected = new HashSet(); + for (final YangInstanceIdentifier path : map.keySet()) { if (identifier.contains(path)) { affected.add(path); } } - for (final InstanceIdentifier pathToRemove : affected) { + for (final YangInstanceIdentifier pathToRemove : affected) { LOG.trace("Removed path {}", pathToRemove); map.remove(pathToRemove); }