2 * Copyright (c) 2017 Pantheon Technologies 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
9 package org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.base;
11 import com.google.common.annotations.Beta;
12 import com.google.common.base.Preconditions;
13 import com.google.common.collect.Iterables;
14 import javax.annotation.Nonnull;
15 import javax.annotation.concurrent.GuardedBy;
16 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.AugmentationNodeContext;
17 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.CaseNodeCodecContext;
18 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.ChoiceNodeCodecContext;
19 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.ContainerNodeCodecContext;
20 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.KeyedListNodeCodecContext;
21 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.ListNodeCodecContext;
22 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.base.NodeCodecContext.CodecContextFactory;
23 import org.opendaylight.mdsal.binding.javav2.spec.base.Item;
24 import org.opendaylight.mdsal.binding.javav2.spec.base.TreeRoot;
25 import org.opendaylight.yangtools.concepts.Identifiable;
26 import org.opendaylight.yangtools.yang.common.QNameModule;
27 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
28 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.AugmentationIdentifier;
29 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
30 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument;
31 import org.opendaylight.yangtools.yang.model.api.AugmentationSchema;
32 import org.opendaylight.yangtools.yang.model.api.ChoiceCaseNode;
33 import org.opendaylight.yangtools.yang.model.api.ChoiceSchemaNode;
34 import org.opendaylight.yangtools.yang.model.api.ContainerSchemaNode;
35 import org.opendaylight.yangtools.yang.model.api.DataSchemaNode;
36 import org.opendaylight.yangtools.yang.model.api.ListSchemaNode;
37 import org.opendaylight.yangtools.yang.model.api.NotificationDefinition;
38 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
41 public final class DataContainerCodecPrototype<T> implements NodeContextSupplier {
43 private final T schema;
44 private final QNameModule namespace;
45 private final CodecContextFactory factory;
46 private final Class<?> bindingClass;
47 private final Item<?> bindingArg;
48 private final YangInstanceIdentifier.PathArgument yangArg;
49 private volatile DataContainerCodecContext<?,T> instance = null;
51 @SuppressWarnings({"rawtypes", "unchecked"})
52 private DataContainerCodecPrototype(final Class<?> cls, final YangInstanceIdentifier.PathArgument arg,
53 final T nodeSchema, final CodecContextFactory factory) {
54 this.bindingClass = Preconditions.checkNotNull(cls);
55 this.yangArg = Preconditions.checkNotNull(arg);
56 this.schema = Preconditions.checkNotNull(nodeSchema);
57 this.factory = Preconditions.checkNotNull(factory);
59 this.bindingArg = new Item(bindingClass);
61 if (arg instanceof AugmentationIdentifier) {
62 this.namespace = Iterables.getFirst(
63 ((AugmentationIdentifier) arg).getPossibleChildNames(), null).getModule();
65 this.namespace = arg.getNodeType().getModule();
69 @SuppressWarnings({ "unchecked", "rawtypes" })
70 public static <T extends DataSchemaNode> DataContainerCodecPrototype<T> from(final Class<?> cls, final T schema,
71 final CodecContextFactory factory) {
72 return new DataContainerCodecPrototype(cls, NodeIdentifier.create(schema.getQName()), schema, factory);
75 @SuppressWarnings({ "rawtypes", "unchecked" })
76 static DataContainerCodecPrototype<?> from(final Class<?> augClass, final AugmentationIdentifier arg,
77 final AugmentationSchema schema, final CodecContextFactory factory) {
78 return new DataContainerCodecPrototype(augClass, arg, schema, factory);
82 public static DataContainerCodecPrototype<NotificationDefinition> from(final Class<?> augClass,
83 final NotificationDefinition schema, final CodecContextFactory factory) {
84 final PathArgument arg = NodeIdentifier.create(schema.getQName());
85 return new DataContainerCodecPrototype<>(augClass, arg, schema, factory);
88 public static DataContainerCodecPrototype<SchemaContext> rootPrototype(final CodecContextFactory factory) {
89 final SchemaContext schema = factory.getRuntimeContext().getSchemaContext();
90 final NodeIdentifier arg = NodeIdentifier.create(schema.getQName());
91 return new DataContainerCodecPrototype<>(TreeRoot.class, arg, schema, factory);
94 public T getSchema() {
98 protected QNameModule getNamespace() {
102 protected CodecContextFactory getFactory() {
106 public Class<?> getBindingClass() {
110 protected Item<?> getBindingArg() {
114 protected YangInstanceIdentifier.PathArgument getYangArg() {
120 public DataContainerCodecContext<?,T> get() {
121 DataContainerCodecContext<?,T> tmp = instance;
123 synchronized (this) {
126 tmp = createInstance();
136 @SuppressWarnings({"rawtypes", "unchecked"})
137 protected DataContainerCodecContext<?, T> createInstance() {
138 if (schema instanceof ContainerSchemaNode) {
139 return new ContainerNodeCodecContext(this);
140 } else if (schema instanceof ListSchemaNode) {
141 if (Identifiable.class.isAssignableFrom(getBindingClass())) {
142 return new KeyedListNodeCodecContext(this);
144 return new ListNodeCodecContext(this);
146 } else if (schema instanceof ChoiceSchemaNode) {
147 return new ChoiceNodeCodecContext(this);
148 } else if (schema instanceof AugmentationSchema) {
149 return new AugmentationNodeContext(this);
150 } else if (schema instanceof ChoiceCaseNode) {
151 return new CaseNodeCodecContext(this);
153 throw new IllegalArgumentException("Unsupported type " + bindingClass + " " + schema);
157 return schema instanceof ChoiceSchemaNode;