/* * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.mdsal.binding.javav2.dom.codec.impl.context.base; import static java.util.Objects.requireNonNull; import com.google.common.annotations.Beta; import com.google.common.collect.Iterables; import javax.annotation.Nonnull; import javax.annotation.concurrent.GuardedBy; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.AugmentationNodeContext; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.CaseNodeCodecContext; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.ChoiceNodeCodecContext; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.ContainerNodeCodecContext; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.KeyedListNodeCodecContext; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.ListNodeCodecContext; import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.context.base.NodeCodecContext.CodecContextFactory; import org.opendaylight.mdsal.binding.javav2.spec.base.Item; import org.opendaylight.mdsal.binding.javav2.spec.base.TreeRoot; import org.opendaylight.yangtools.concepts.Identifiable; import org.opendaylight.yangtools.yang.common.QNameModule; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.AugmentationIdentifier; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument; import org.opendaylight.yangtools.yang.model.api.AugmentationSchemaNode; import org.opendaylight.yangtools.yang.model.api.CaseSchemaNode; import org.opendaylight.yangtools.yang.model.api.ChoiceSchemaNode; import org.opendaylight.yangtools.yang.model.api.ContainerSchemaNode; import org.opendaylight.yangtools.yang.model.api.DataSchemaNode; import org.opendaylight.yangtools.yang.model.api.ListSchemaNode; import org.opendaylight.yangtools.yang.model.api.NotificationDefinition; import org.opendaylight.yangtools.yang.model.api.SchemaContext; @Beta public final class DataContainerCodecPrototype implements NodeContextSupplier { private final T schema; private final QNameModule namespace; private final CodecContextFactory factory; private final Class bindingClass; private final Item bindingArg; private final YangInstanceIdentifier.PathArgument yangArg; private volatile DataContainerCodecContext instance = null; @SuppressWarnings({"rawtypes", "unchecked"}) private DataContainerCodecPrototype(final Class cls, final YangInstanceIdentifier.PathArgument arg, final T nodeSchema, final CodecContextFactory factory) { this.bindingClass = requireNonNull(cls); this.yangArg = requireNonNull(arg); this.schema = requireNonNull(nodeSchema); this.factory = requireNonNull(factory); this.bindingArg = new Item(bindingClass); if (arg instanceof AugmentationIdentifier) { this.namespace = Iterables.getFirst( ((AugmentationIdentifier) arg).getPossibleChildNames(), null).getModule(); } else { this.namespace = arg.getNodeType().getModule(); } } @SuppressWarnings({ "unchecked", "rawtypes" }) public static DataContainerCodecPrototype from(final Class cls, final T schema, final CodecContextFactory factory) { return new DataContainerCodecPrototype(cls, NodeIdentifier.create(schema.getQName()), schema, factory); } @SuppressWarnings({ "rawtypes", "unchecked" }) static DataContainerCodecPrototype from(final Class augClass, final AugmentationIdentifier arg, final AugmentationSchemaNode schema, final CodecContextFactory factory) { return new DataContainerCodecPrototype(augClass, arg, schema, factory); } public static DataContainerCodecPrototype from(final Class augClass, final NotificationDefinition schema, final CodecContextFactory factory) { final PathArgument arg = NodeIdentifier.create(schema.getQName()); return new DataContainerCodecPrototype<>(augClass, arg, schema, factory); } public static DataContainerCodecPrototype rootPrototype(final CodecContextFactory factory) { final SchemaContext schema = factory.getRuntimeContext().getSchemaContext(); final NodeIdentifier arg = NodeIdentifier.create(schema.getQName()); return new DataContainerCodecPrototype<>(TreeRoot.class, arg, schema, factory); } public T getSchema() { return schema; } protected QNameModule getNamespace() { return namespace; } protected CodecContextFactory getFactory() { return factory; } public Class getBindingClass() { return bindingClass; } protected Item getBindingArg() { return bindingArg; } protected YangInstanceIdentifier.PathArgument getYangArg() { return yangArg; } @Nonnull @Override public DataContainerCodecContext get() { DataContainerCodecContext tmp = instance; if (tmp == null) { synchronized (this) { tmp = instance; if (tmp == null) { tmp = createInstance(); instance = tmp; } } } return tmp; } @GuardedBy("this") @SuppressWarnings({"rawtypes", "unchecked"}) protected DataContainerCodecContext createInstance() { if (schema instanceof ContainerSchemaNode) { return new ContainerNodeCodecContext(this); } else if (schema instanceof ListSchemaNode) { if (Identifiable.class.isAssignableFrom(getBindingClass())) { return new KeyedListNodeCodecContext(this); } else { return new ListNodeCodecContext(this); } } else if (schema instanceof ChoiceSchemaNode) { return new ChoiceNodeCodecContext(this); } else if (schema instanceof AugmentationSchemaNode) { return new AugmentationNodeContext(this); } else if (schema instanceof CaseSchemaNode) { return new CaseNodeCodecContext(this); } throw new IllegalArgumentException("Unsupported type " + bindingClass + " " + schema); } boolean isChoice() { return schema instanceof ChoiceSchemaNode; } }