X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fyang%2Fmd%2Fsal%2Fbinding%2Fimpl%2FRuntimeMappingModule.java;h=51efa9e2e5498ef3e1e5e6296ea61fee9fa0646c;hb=74561c35949153a92df7d352be0fb135c30f39c4;hp=1bf15c182f5f93196fe0c3d27fc0438295df2812;hpb=15ea0e6c8aa1d507759bec112d153c510a172d4f;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/RuntimeMappingModule.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/RuntimeMappingModule.java index 1bf15c182f..a15b1d746c 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/RuntimeMappingModule.java +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/RuntimeMappingModule.java @@ -1,20 +1,39 @@ -/** - * Generated file - - * Generated from: yang module name: opendaylight-sal-binding-broker-impl yang module local name: runtime-generated-mapping - * Generated by: org.opendaylight.controller.config.yangjmxgenerator.plugin.JMXGenerator - * Generated at: Wed Nov 20 18:20:19 CET 2013 +/* + * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. * - * Do not modify this file unless it is present under src/main directory + * 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.controller.config.yang.md.sal.binding.impl; +import com.google.common.base.Optional; +import com.google.common.base.Preconditions; +import java.util.Hashtable; +import java.util.Map.Entry; +import java.util.Set; import javassist.ClassPool; - -import org.opendaylight.controller.sal.binding.dom.serializer.impl.RuntimeGeneratedMappingServiceImpl; +import org.opendaylight.controller.md.sal.binding.impl.BindingToNormalizedNodeCodec; +import org.opendaylight.controller.sal.binding.codegen.impl.SingletonHolder; +import org.opendaylight.yangtools.binding.data.codec.gen.impl.StreamWriterGenerator; +import org.opendaylight.yangtools.binding.data.codec.impl.BindingNormalizedNodeCodecRegistry; +import org.opendaylight.yangtools.concepts.Delegator; +import org.opendaylight.yangtools.sal.binding.generator.impl.GeneratedClassLoadingStrategy; +import org.opendaylight.yangtools.sal.binding.generator.impl.RuntimeGeneratedMappingServiceImpl; +import org.opendaylight.yangtools.yang.binding.DataContainer; +import org.opendaylight.yangtools.yang.binding.DataObject; +import org.opendaylight.yangtools.yang.binding.RpcService; +import org.opendaylight.yangtools.yang.common.QName; +import org.opendaylight.yangtools.yang.data.api.CompositeNode; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +import org.opendaylight.yangtools.yang.data.impl.codec.BindingIndependentMappingService; +import org.opendaylight.yangtools.yang.data.impl.codec.CodecRegistry; +import org.opendaylight.yangtools.yang.data.impl.codec.DeserializationException; +import org.opendaylight.yangtools.yang.model.api.SchemaContextListener; import org.osgi.framework.BundleContext; - -import com.google.common.base.Preconditions; +import org.osgi.framework.ServiceReference; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * @@ -22,16 +41,18 @@ import com.google.common.base.Preconditions; public final class RuntimeMappingModule extends org.opendaylight.controller.config.yang.md.sal.binding.impl.AbstractRuntimeMappingModule { + private static final Logger LOG = LoggerFactory.getLogger(RuntimeMappingModule.class); + private BundleContext bundleContext; - public RuntimeMappingModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, - org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) { + public RuntimeMappingModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, + final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) { super(identifier, dependencyResolver); } - public RuntimeMappingModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, - org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, - RuntimeMappingModule oldModule, java.lang.AutoCloseable oldInstance) { + public RuntimeMappingModule(final org.opendaylight.controller.config.api.ModuleIdentifier identifier, + final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, + final RuntimeMappingModule oldModule, final java.lang.AutoCloseable oldInstance) { super(identifier, dependencyResolver, oldModule, oldInstance); } @@ -43,24 +64,138 @@ public final class RuntimeMappingModule extends } @Override - public boolean canReuseInstance(AbstractRuntimeMappingModule oldModule) { + public boolean canReuseInstance(final AbstractRuntimeMappingModule oldModule) { return true; } @Override public java.lang.AutoCloseable createInstance() { - RuntimeGeneratedMappingServiceImpl service = new RuntimeGeneratedMappingServiceImpl(); - ClassPool pool = new ClassPool(); // Should be default singleton - service.setPool(pool); - service.start(getBundleContext()); - return service; + final GeneratedClassLoadingStrategy classLoading = getGlobalClassLoadingStrategy(); + final BindingIndependentMappingService legacyMapping = getGlobalLegacyMappingService(classLoading); + BindingNormalizedNodeCodecRegistry codecRegistry = new BindingNormalizedNodeCodecRegistry(new StreamWriterGenerator(SingletonHolder.JAVASSIST)); + BindingToNormalizedNodeCodec instance = new BindingToNormalizedNodeCodec(classLoading, legacyMapping, codecRegistry); + bundleContext.registerService(SchemaContextListener.class, instance, new Hashtable()); + return instance; + } + + private BindingIndependentMappingService getGlobalLegacyMappingService(final GeneratedClassLoadingStrategy classLoading) { + BindingIndependentMappingService potential = tryToReuseGlobalMappingServiceInstance(); + if(potential == null) { + potential = new RuntimeGeneratedMappingServiceImpl(ClassPool.getDefault(),classLoading); + bundleContext.registerService(SchemaContextListener.class, (SchemaContextListener) potential, new Hashtable()); + } + return potential; + } + + private GeneratedClassLoadingStrategy getGlobalClassLoadingStrategy() { + ServiceReference ref = bundleContext.getServiceReference(GeneratedClassLoadingStrategy.class); + return bundleContext.getService(ref); + } + + private BindingIndependentMappingService tryToReuseGlobalMappingServiceInstance() { + ServiceReference serviceRef = getBundleContext().getServiceReference(BindingIndependentMappingService.class); + if(serviceRef == null) { + return null; + } + return bundleContext.getService(serviceRef); + } private BundleContext getBundleContext() { return bundleContext; } - public void setBundleContext(BundleContext bundleContext) { + public void setBundleContext(final BundleContext bundleContext) { this.bundleContext = bundleContext; } + + private static final class RuntimeGeneratedMappingServiceProxy implements // + BindingIndependentMappingService, // + Delegator, // + AutoCloseable { + + private BindingIndependentMappingService delegate; + private ServiceReference reference; + private BundleContext bundleContext; + + public RuntimeGeneratedMappingServiceProxy(final BundleContext bundleContext, + final ServiceReference serviceRef, + final BindingIndependentMappingService delegate) { + this.bundleContext = Preconditions.checkNotNull(bundleContext); + this.reference = Preconditions.checkNotNull(serviceRef); + this.delegate = Preconditions.checkNotNull(delegate); + } + + @Override + public CodecRegistry getCodecRegistry() { + return delegate.getCodecRegistry(); + } + + @Override + public CompositeNode toDataDom(final DataObject data) { + return delegate.toDataDom(data); + } + + @Override + public Entry toDataDom( + final Entry, DataObject> entry) { + return delegate.toDataDom(entry); + } + + @Override + public YangInstanceIdentifier toDataDom( + final org.opendaylight.yangtools.yang.binding.InstanceIdentifier path) { + return delegate.toDataDom(path); + } + + @Override + public DataObject dataObjectFromDataDom( + final org.opendaylight.yangtools.yang.binding.InstanceIdentifier path, + final CompositeNode result) throws DeserializationException { + return delegate.dataObjectFromDataDom(path, result); + } + + @Override + public org.opendaylight.yangtools.yang.binding.InstanceIdentifier fromDataDom(final YangInstanceIdentifier entry) + throws DeserializationException { + return delegate.fromDataDom(entry); + } + + @Override + public Set getRpcQNamesFor(final Class service) { + return delegate.getRpcQNamesFor(service); + } + + @Override + public Optional> getRpcServiceClassFor(final String namespace, final String revision) { + return delegate.getRpcServiceClassFor(namespace,revision); + } + + @Override + public DataContainer dataObjectFromDataDom(final Class inputClass, final CompositeNode domInput) { + return delegate.dataObjectFromDataDom(inputClass, domInput); + } + + @Override + public void close() { + if(delegate != null) { + delegate = null; + + try { + bundleContext.ungetService(reference); + } catch (IllegalStateException e) { + // Indicates the BundleContext is no longer valid which can happen normally on shutdown. + LOG.debug( "Error unregistering service", e ); + } + + bundleContext= null; + reference = null; + } + } + + @Override + public BindingIndependentMappingService getDelegate() { + return delegate; + } + } }