X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=yang%2Fyang-data-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fyangtools%2Fyang%2Fdata%2Fapi%2FYangInstanceIdentifier.java;h=9944d741e66cd64a99e61c82393646e8c9dae6a3;hb=24d06767f3a0ead8152a745fb05eda1d4a37ba77;hp=e9f940a4555bad2af63797018916240a4209d3a3;hpb=feb866798e33453d6e9255e5f197a64296d33e93;p=yangtools.git diff --git a/yang/yang-data-api/src/main/java/org/opendaylight/yangtools/yang/data/api/YangInstanceIdentifier.java b/yang/yang-data-api/src/main/java/org/opendaylight/yangtools/yang/data/api/YangInstanceIdentifier.java index e9f940a455..9944d741e6 100644 --- a/yang/yang-data-api/src/main/java/org/opendaylight/yangtools/yang/data/api/YangInstanceIdentifier.java +++ b/yang/yang-data-api/src/main/java/org/opendaylight/yangtools/yang/data/api/YangInstanceIdentifier.java @@ -1,35 +1,39 @@ /* * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. + * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.yangtools.yang.data.api; +import com.google.common.annotations.Beta; import com.google.common.base.Optional; import com.google.common.base.Preconditions; -import com.google.common.collect.ImmutableList; -import com.google.common.collect.ImmutableMap; +import com.google.common.cache.CacheBuilder; +import com.google.common.cache.CacheLoader; +import com.google.common.cache.LoadingCache; import com.google.common.collect.ImmutableSet; import com.google.common.collect.Iterables; -import com.google.common.collect.Lists; - import java.io.Serializable; import java.lang.reflect.Array; -import java.util.ArrayList; import java.util.Arrays; -import java.util.Collections; +import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Objects; import java.util.Set; - +import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; +import javax.annotation.Nonnull; +import javax.annotation.Nullable; import org.opendaylight.yangtools.concepts.Builder; import org.opendaylight.yangtools.concepts.Immutable; import org.opendaylight.yangtools.concepts.Path; import org.opendaylight.yangtools.util.HashCodeBuilder; +import org.opendaylight.yangtools.util.ImmutableOffsetMap; +import org.opendaylight.yangtools.util.SharedSingletonMap; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.common.QNameModule; import org.opendaylight.yangtools.yang.data.api.schema.LeafSetEntryNode; @@ -42,16 +46,18 @@ import org.opendaylight.yangtools.yang.data.api.schema.LeafSetEntryNode; * which conceptually is XPath expression minimized to uniquely identify element * in data tree which conforms to constraints maintained by YANG Model, * effectively this makes Instance Identifier a path to element in data tree. + *

*

* Constraints put in YANG specification on instance-identifier allowed it to be * effectively represented in Java and it's evaluation does not require * full-blown XPath processor. - *

+ *

*

Path Arguments

+ *

* Path to the node represented in instance identifier consists of * {@link PathArgument} which carries necessary information to uniquely identify * node on particular level in the subtree. - *

+ *

* * * - * @see http://tools.ietf.org/html/rfc6020#section-9.13 + * @see RFC6020 */ -public final class YangInstanceIdentifier implements Path, Immutable, Serializable { - private static final YangInstanceIdentifier EMPTY = trustedCreate(Collections.emptyList()); +public abstract class YangInstanceIdentifier implements Path, Immutable, Serializable { + /** + * An empty {@link YangInstanceIdentifier}. It corresponds to the path of the conceptual + * root of the YANG namespace. + */ + public static final YangInstanceIdentifier EMPTY = FixedYangInstanceIdentifier.EMPTY_INSTANCE; - private static final long serialVersionUID = 2L; - private final Iterable pathArguments; - private final int hash; + private static final AtomicReferenceFieldUpdater TOSTRINGCACHE_UPDATER = + AtomicReferenceFieldUpdater.newUpdater(YangInstanceIdentifier.class, String.class, "toStringCache"); + private static final long serialVersionUID = 4L; - private transient volatile ImmutableList legacyPath = null; + private final int hash; private transient volatile String toStringCache = null; - private final ImmutableList getLegacyPath() { - // Temporary variable saves a volatile read - ImmutableList ret = legacyPath; - if (ret == null) { - synchronized (this) { - // We could have used a synchronized block, but let's just not bother - ret = ImmutableList.copyOf(pathArguments); - legacyPath = ret; - } - } - - return ret; + // Package-private to prevent outside subclassing + YangInstanceIdentifier(final int hash) { + this.hash = hash; } + @Nonnull abstract YangInstanceIdentifier createRelativeIdentifier(int skipFromRoot); + @Nonnull abstract Collection tryPathArguments(); + @Nonnull abstract Collection tryReversePathArguments(); + /** - * Returns a list of path arguments. + * Check if this instance identifier has empty path arguments, e.g. it is + * empty and corresponds to {@link #EMPTY}. * - * @deprecated Use {@link #getPathArguments()} instead. - * @return Immutable list of path arguments. + * @return True if this instance identifier is empty, false otherwise. */ - @Deprecated - public List getPath() { - return getLegacyPath(); - } + public abstract boolean isEmpty(); + + /** + * Return an optimized version of this identifier, useful when the identifier + * will be used very frequently. + * + * @return A optimized equivalent instance. + */ + @Beta + public abstract YangInstanceIdentifier toOptimized(); + + /** + * Return the conceptual parent {@link YangInstanceIdentifier}, which has + * one item less in {@link #getPathArguments()}. + * + * @return Parent {@link YangInstanceIdentifier}, or null if this object is {@link #EMPTY}. + */ + @Nullable public abstract YangInstanceIdentifier getParent(); + + /** + * Return the ancestor {@link YangInstanceIdentifier} with a particular depth, e.g. number of path arguments. + * + * @param depth Ancestor depth + * @return Ancestor {@link YangInstanceIdentifier} + * @throws IllegalArgumentException if the specified depth is negative or is greater than the depth of this object. + */ + @Nonnull public abstract YangInstanceIdentifier getAncestor(int depth); /** * Returns an ordered iteration of path arguments. * * @return Immutable iteration of path arguments. */ - public Iterable getPathArguments() { - return pathArguments; - } + public abstract List getPathArguments(); /** * Returns an iterable of path arguments in reverse order. This is useful @@ -116,9 +142,7 @@ public final class YangInstanceIdentifier implements Path getReversePathArguments() { - return getLegacyPath().reverse(); - } + public abstract List getReversePathArguments(); /** * Returns the last PathArgument. This is equivalent of iterating @@ -126,39 +150,28 @@ public final class YangInstanceIdentifier implements Path path, final int hash) { - this.pathArguments = Preconditions.checkNotNull(path, "path must not be null."); - this.hash = hash; - } + public static YangInstanceIdentifier create(final Iterable path) { + if (Iterables.isEmpty(path)) { + return EMPTY; + } - private static final YangInstanceIdentifier trustedCreate(final Iterable path) { final HashCodeBuilder hash = new HashCodeBuilder<>(); for (PathArgument a : path) { hash.addArgument(a); } - return new YangInstanceIdentifier(path, hash.toInstance()); - } - - public static final YangInstanceIdentifier create(final Iterable path) { - if (Iterables.isEmpty(path)) { - return EMPTY; - } - - return trustedCreate(ImmutableList.copyOf(path)); + return FixedYangInstanceIdentifier.create(path, hash.build()); } - public static final YangInstanceIdentifier create(final PathArgument... path) { + public static YangInstanceIdentifier create(final PathArgument... path) { // We are forcing a copy, since we cannot trust the user return create(Arrays.asList(path)); } @Override - public int hashCode() { + public final int hashCode() { /* * The caching is safe, since the object contract requires * immutability of the object and all objects referenced from this @@ -169,22 +182,24 @@ public final class YangInstanceIdentifier implements Path relativeTo(final YangInstanceIdentifier ancestor) { - final Iterator lit = pathArguments.iterator(); - final Iterator oit = ancestor.pathArguments.iterator(); + final Iterator lit = getPathArguments().iterator(); + final Iterator oit = ancestor.getPathArguments().iterator(); int common = 0; while (oit.hasNext()) { @@ -237,7 +252,57 @@ public final class YangInstanceIdentifier implements Path lit = getPathArguments().iterator(); + final Iterator oit = other.getPathArguments().iterator(); + + while (lit.hasNext()) { + if (!oit.hasNext()) { + return false; + } + + if (!lit.next().equals(oit.next())) { + return false; + } + } + + return true; + } + + @Override + public final String toString() { + /* + * The toStringCache is safe, since the object contract requires + * immutability of the object and all objects referenced from this + * object. + * Used lists, maps are immutable. Path Arguments (elements) are also + * immutable, since the PathArgument contract requires immutability. + * The cache is thread-safe - if multiple computations occurs at the + * same time, cache will be overwritten with same result. + */ + String ret = toStringCache; + if (ret == null) { + final StringBuilder builder = new StringBuilder("/"); + PathArgument prev = null; + for (PathArgument argument : getPathArguments()) { + if (prev != null) { + builder.append('/'); + } + builder.append(argument.toRelativeString(prev)); + prev = argument; + } + + ret = builder.toString(); + TOSTRINGCACHE_UPDATER.lazySet(this, ret); + } + return ret; } private static int hashCode(final Object value) { @@ -245,7 +310,7 @@ public final class YangInstanceIdentifier implements Path { - /** - * Adds {@link NodeIdentifier} with supplied QName to path arguments of resulting instance identifier. - * - * @param nodeType QName of {@link NodeIdentifier} which will be added - * @return this builder - */ - InstanceIdentifierBuilder node(QName nodeType); - - /** - * Adds {@link NodeIdentifierWithPredicates} with supplied QName and key values to path arguments of resulting instance identifier. - * - * @param nodeType QName of {@link NodeIdentifierWithPredicates} which will be added - * @param keyValues Map of key components and their respective values for {@link NodeIdentifierWithPredicates} - * @return this builder - */ - InstanceIdentifierBuilder nodeWithKey(QName nodeType, Map keyValues); - - /** - * Adds {@link NodeIdentifierWithPredicates} with supplied QName and key, value. - * - * @param nodeType QName of {@link NodeIdentifierWithPredicates} which will be added - * @param key QName of key which will be added - * @param value value of key which will be added - * @return this builder - */ - InstanceIdentifierBuilder nodeWithKey(QName nodeType, QName key, Object value); - - /** - * - * Builds an {@link YangInstanceIdentifier} with path arguments from this builder - * - * @return {@link YangInstanceIdentifier} - */ - YangInstanceIdentifier build(); - } - /** * Simple path argument identifying a {@link org.opendaylight.yangtools.yang.data.api.schema.ContainerNode} or * {@link org.opendaylight.yangtools.yang.data.api.schema.LeafNode} leaf in particular subtree. */ public static final class NodeIdentifier extends AbstractPathArgument { private static final long serialVersionUID = -2255888212390871347L; + private static final LoadingCache CACHE = CacheBuilder.newBuilder().weakValues() + .build(new CacheLoader() { + @Override + public NodeIdentifier load(final QName key) { + return new NodeIdentifier(key); + } + }); public NodeIdentifier(final QName node) { super(node); } + + /** + * Return a NodeIdentifier for a particular QName. Unlike the constructor, this factory method uses a global + * instance cache, resulting in object reuse for equal inputs. + * + * @param node Node's QName + * @return A {@link NodeIdentifier} + */ + public static NodeIdentifier create(final QName node) { + return CACHE.getUnchecked(node); + } } /** @@ -473,11 +508,13 @@ public final class YangInstanceIdentifier implements Path keyValues) { super(node); - this.keyValues = ImmutableMap.copyOf(keyValues); + // Retains ImmutableMap for empty maps. For larger sizes uses a shared key set. + this.keyValues = ImmutableOffsetMap.unorderedCopyOf(keyValues); } public NodeIdentifierWithPredicates(final QName node, final QName key, final Object value) { - this(node, ImmutableMap.of(key, value)); + super(node); + this.keyValues = SharedSingletonMap.unorderedOf(key, value); } public Map getKeyValues() { @@ -485,9 +522,9 @@ public final class YangInstanceIdentifier implements Path entry : keyValues.entrySet()) { @@ -503,6 +540,11 @@ public final class YangInstanceIdentifier implements Path otherKeyValues = ((NodeIdentifierWithPredicates) obj).keyValues; + + // TODO: benchmark to see if just calling equals() on the two maps is not faster + if (keyValues == otherKeyValues) { + return true; + } if (keyValues.size() != otherKeyValues.size()) { return false; } @@ -548,9 +590,9 @@ public final class YangInstanceIdentifier implements PathRFC6020 */ public static final class AugmentationIdentifier implements PathArgument { private static final long serialVersionUID = -8122335594681936939L; @@ -611,18 +653,6 @@ public final class YangInstanceIdentifier implements Path childNames) { - this(childNames); - } - /** * Returns set of all possible child nodes * @@ -634,7 +664,7 @@ public final class YangInstanceIdentifier implements Path lit = pathArguments.iterator(); - final Iterator oit = other.pathArguments.iterator(); - - while (lit.hasNext()) { - if (!oit.hasNext()) { - return false; - } + /** + * Fluent Builder of Instance Identifier instances + */ + public interface InstanceIdentifierBuilder extends Builder { + /** + * Adds a {@link PathArgument} to to path arguments of resulting instance identifier. + * + * @param arg A {@link PathArgument} to be added + * @return this builder + */ + InstanceIdentifierBuilder node(PathArgument arg); - if (!lit.next().equals(oit.next())) { - return false; - } - } + /** + * Adds {@link NodeIdentifier} with supplied QName to path arguments of resulting instance identifier. + * + * @param nodeType QName of {@link NodeIdentifier} which will be added + * @return this builder + */ + InstanceIdentifierBuilder node(QName nodeType); - return true; - } + /** + * Adds {@link NodeIdentifierWithPredicates} with supplied QName and key values to path arguments of resulting instance identifier. + * + * @param nodeType QName of {@link NodeIdentifierWithPredicates} which will be added + * @param keyValues Map of key components and their respective values for {@link NodeIdentifierWithPredicates} + * @return this builder + */ + InstanceIdentifierBuilder nodeWithKey(QName nodeType, Map keyValues); - @Override - public String toString() { - /* - * The toStringCache is safe, since the object contract requires - * immutability of the object and all objects referenced from this - * object. - * Used lists, maps are immutable. Path Arguments (elements) are also - * immutable, since the PathArgument contract requires immutability. - * The cache is thread-safe - if multiple computations occurs at the - * same time, cache will be overwritten with same result. + /** + * Adds {@link NodeIdentifierWithPredicates} with supplied QName and key, value. + * + * @param nodeType QName of {@link NodeIdentifierWithPredicates} which will be added + * @param key QName of key which will be added + * @param value value of key which will be added + * @return this builder */ - String ret = toStringCache; - if (ret == null) { - synchronized (this) { - ret = toStringCache; - if (ret == null) { - final StringBuilder builder = new StringBuilder("/"); - PathArgument prev = null; - for (PathArgument argument : getPathArguments()) { - if (prev != null) { - builder.append('/'); - } - builder.append(argument.toRelativeString(prev)); - prev = argument; - } + InstanceIdentifierBuilder nodeWithKey(QName nodeType, QName key, Object value); - ret = builder.toString(); - toStringCache = ret; - } - } - } - return ret; + /** + * + * Builds an {@link YangInstanceIdentifier} with path arguments from this builder + * + * @return {@link YangInstanceIdentifier} + */ + @Override + YangInstanceIdentifier build(); } }