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;
private static final Logger LOG = LoggerFactory
.getLogger(HashMapDataStore.class);
- private final Map<InstanceIdentifier, CompositeNode> configuration = new ConcurrentHashMap<InstanceIdentifier, CompositeNode>();
- private final Map<InstanceIdentifier, CompositeNode> operational = new ConcurrentHashMap<InstanceIdentifier, CompositeNode>();
+ private final Map<YangInstanceIdentifier, CompositeNode> configuration = new ConcurrentHashMap<YangInstanceIdentifier, CompositeNode>();
+ private final Map<YangInstanceIdentifier, CompositeNode> operational = new ConcurrentHashMap<YangInstanceIdentifier, CompositeNode>();
@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<InstanceIdentifier> getStoredConfigurationPaths() {
+ public Iterable<YangInstanceIdentifier> getStoredConfigurationPaths() {
return configuration.keySet();
}
@Override
- public Iterable<InstanceIdentifier> getStoredOperationalPaths() {
+ public Iterable<YangInstanceIdentifier> 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<InstanceIdentifier, CompositeNode> requestCommit(
- final DataModification<InstanceIdentifier, CompositeNode> modification) {
+ public DataCommitHandler.DataCommitTransaction<YangInstanceIdentifier, CompositeNode> requestCommit(
+ final DataModification<YangInstanceIdentifier, CompositeNode> modification) {
return new HashMapDataStoreTransaction(modification, this);
}
}
public RpcResult<Void> finish(HashMapDataStoreTransaction transaction) {
- final DataModification<InstanceIdentifier, CompositeNode> modification = transaction
+ final DataModification<YangInstanceIdentifier, CompositeNode> 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);
}
return RpcResultBuilder.<Void> success().build();
}
- public void remove(final Map<InstanceIdentifier, CompositeNode> map,
- final InstanceIdentifier identifier) {
- Set<InstanceIdentifier> affected = new HashSet<InstanceIdentifier>();
- for (final InstanceIdentifier path : map.keySet()) {
+ public void remove(final Map<YangInstanceIdentifier, CompositeNode> map,
+ final YangInstanceIdentifier identifier) {
+ Set<YangInstanceIdentifier> affected = new HashSet<YangInstanceIdentifier>();
+ 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);
}