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%2Fstore%2Fimpl%2Ftree%2Fdata%2FInMemoryDataTreeModification.java;h=7d0c81e39de8efe564c33925280c9dbb9c71ff22;hp=df3ef8b7e128b2be29eb5473bd86d056cba218d2;hb=7206d41640f98943c64da8f8486e5205b279c943;hpb=0f366ff59742b728025efa3db408c57f2794050e diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/tree/data/InMemoryDataTreeModification.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/tree/data/InMemoryDataTreeModification.java index df3ef8b7e1..7d0c81e39d 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/tree/data/InMemoryDataTreeModification.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/store/impl/tree/data/InMemoryDataTreeModification.java @@ -88,30 +88,32 @@ final class InMemoryDataTreeModification implements DataTreeModification { @Override public Optional> readNode(final InstanceIdentifier path) { - Entry modification = TreeNodeUtils.findClosestsOrFirstMatch(rootNode, path, NodeModification.IS_TERMINAL_PREDICATE); - - Optional result = resolveSnapshot(modification); + /* + * Walk the tree from the top, looking for the first node between root and + * the requested path which has been modified. If no such node exists, + * we use the node itself. + */ + final Entry entry = TreeNodeUtils.findClosestsOrFirstMatch(rootNode, path, NodeModification.IS_TERMINAL_PREDICATE); + final InstanceIdentifier key = entry.getKey(); + final NodeModification mod = entry.getValue(); + + final Optional result = resolveSnapshot(key, mod); if (result.isPresent()) { NormalizedNode data = result.get().getData(); - return NormalizedNodeUtils.findNode(modification.getKey(), data, path); + return NormalizedNodeUtils.findNode(key, data, path); + } else { + return Optional.absent(); } - return Optional.absent(); - } - - private Optional resolveSnapshot( - final Entry keyModification) { - InstanceIdentifier path = keyModification.getKey(); - NodeModification modification = keyModification.getValue(); - return resolveSnapshot(path, modification); } private Optional resolveSnapshot(final InstanceIdentifier path, final NodeModification modification) { + final Optional> potentialSnapshot = modification.getSnapshotCache(); + if(potentialSnapshot.isPresent()) { + return potentialSnapshot.get(); + } + try { - Optional> potentialSnapshot = modification.getSnapshotCache(); - if(potentialSnapshot.isPresent()) { - return potentialSnapshot.get(); - } return resolveModificationStrategy(path).apply(modification, modification.getOriginal(), StoreUtils.increase(snapshot.getRootNode().getSubtreeVersion())); } catch (Exception e) {