2 * Copyright (c) 2020 PANTHEON.tech, s.r.o. 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.mdsal.binding.dom.adapter.query;
10 import static com.google.common.base.Verify.verifyNotNull;
11 import static java.util.Objects.requireNonNull;
13 import com.google.common.base.VerifyException;
14 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
15 import java.lang.invoke.MethodHandles;
16 import java.lang.invoke.VarHandle;
17 import java.util.Map.Entry;
18 import java.util.Spliterator;
19 import java.util.function.Function;
20 import java.util.stream.Stream;
21 import org.eclipse.jdt.annotation.NonNullByDefault;
22 import org.eclipse.jdt.annotation.Nullable;
23 import org.opendaylight.mdsal.binding.api.query.QueryResult;
24 import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTree;
25 import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeNode;
26 import org.opendaylight.mdsal.binding.dom.codec.api.BindingDataObjectCodecTreeNode;
27 import org.opendaylight.mdsal.dom.api.query.DOMQueryResult;
28 import org.opendaylight.yangtools.yang.binding.DataObject;
29 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
30 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
31 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
34 final class DefaultQueryResult<T extends DataObject>
35 implements QueryResult<T>, Function<Entry<YangInstanceIdentifier, NormalizedNode<?, ?>>, QueryResult.Item<T>> {
36 private static final VarHandle ITEM_CODEC;
40 ITEM_CODEC = MethodHandles.lookup().findVarHandle(DefaultQueryResult.class,
41 "itemCodec", BindingDataObjectCodecTreeNode.class);
42 } catch (NoSuchFieldException | IllegalAccessException e) {
43 throw new ExceptionInInitializerError(e);
47 private final DOMQueryResult domResult;
48 private final BindingCodecTree codec;
50 @SuppressWarnings("unused")
51 @SuppressFBWarnings(value = "NP_STORE_INTO_NONNULL_FIELD", justification = "Ungrokked type annotation")
52 private volatile @Nullable BindingDataObjectCodecTreeNode<T> itemCodec = null;
54 DefaultQueryResult(final BindingCodecTree codec, final DOMQueryResult domResult) {
55 this.codec = requireNonNull(codec);
56 this.domResult = requireNonNull(domResult);
60 public Spliterator<? extends Item<T>> spliterator() {
61 return new DefaultQueryResultSpliterator<>(this, domResult.spliterator());
65 public Stream<? extends Item<T>> stream() {
66 return domResult.stream().map(this);
70 public Stream<? extends Item<T>> parallelStream() {
71 return domResult.parallelStream().map(this);
75 public Item<T> apply(final Entry<YangInstanceIdentifier, NormalizedNode<?, ?>> domItem) {
76 return new DefaultQueryResultItem<>(this, domItem);
79 T createObject(final Entry<YangInstanceIdentifier, NormalizedNode<?, ?>> domItem) {
80 final @Nullable BindingDataObjectCodecTreeNode<T> local =
81 (BindingDataObjectCodecTreeNode<T>) ITEM_CODEC.getAcquire(this);
82 return (local != null ? local : loadItemCodec(domItem.getKey())).deserialize(domItem.getValue());
85 InstanceIdentifier<T> createPath(final YangInstanceIdentifier domPath) {
86 return verifyNotNull(codec.getInstanceIdentifierCodec().toBinding(domPath), "path");
89 private BindingDataObjectCodecTreeNode<T> loadItemCodec(final YangInstanceIdentifier domPath) {
90 final BindingCodecTreeNode codecNode = codec.getSubtreeCodec(domPath);
91 if (!(codecNode instanceof BindingDataObjectCodecTreeNode)) {
92 throw new VerifyException("Unexpected codec " + codecNode);
95 @SuppressWarnings("unchecked")
96 final BindingDataObjectCodecTreeNode<T> ret = (BindingDataObjectCodecTreeNode<T>) codecNode;
97 final Object witness = ITEM_CODEC.compareAndExchangeRelease(this, null, ret);
98 return witness == null ? ret : (BindingDataObjectCodecTreeNode<T>) witness;