From d669645b1a5b421a40e49ff8fb531972783156d3 Mon Sep 17 00:00:00 2001 From: Milos Fabian Date: Tue, 18 Feb 2014 10:44:24 +0100 Subject: [PATCH] SalRemoteClientDeployer - instantiate SalRemoteClient for given URL. SalRemoteClient: -Creates schema context. -Initialize mapping service -Creates restconf client -Starts sal remote service broker -Provides consumer registaration Change-Id: Idc0d8be4c088bac8a4df24b98e482184a6e54665 Signed-off-by: Milos Fabian --- .../broker/client/SalRemoteClient.java | 16 ++++ .../client/SalRemoteClientDeployer.java | 18 +++++ .../broker/client/SalRemoteClientImpl.java | 76 +++++++++++++++++++ 3 files changed, 110 insertions(+) create mode 100644 opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClient.java create mode 100644 opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientDeployer.java create mode 100644 opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientImpl.java diff --git a/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClient.java b/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClient.java new file mode 100644 index 0000000000..0044d367f8 --- /dev/null +++ b/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClient.java @@ -0,0 +1,16 @@ +/* + * 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.controller.sal.restconf.broker.client; + +import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; + +public interface SalRemoteClient extends AutoCloseable { + + ConsumerContext registerConsumer(); + +} diff --git a/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientDeployer.java b/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientDeployer.java new file mode 100644 index 0000000000..a1bb81b0bb --- /dev/null +++ b/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientDeployer.java @@ -0,0 +1,18 @@ +/* + * 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.controller.sal.restconf.broker.client; + +import java.net.URL; + +public class SalRemoteClientDeployer { + + public static SalRemoteClient createSalRemoteClient(final URL url) { + return new SalRemoteClientImpl(url); + } + +} diff --git a/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientImpl.java b/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientImpl.java new file mode 100644 index 0000000000..ec62568a1b --- /dev/null +++ b/opendaylight/md-sal/sal-restconf-broker/src/main/java/org/opendaylight/controller/sal/restconf/broker/client/SalRemoteClientImpl.java @@ -0,0 +1,76 @@ +/* + * 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.controller.sal.restconf.broker.client; + +import java.net.URL; + +import javassist.ClassPool; + +import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ConsumerContext; +import org.opendaylight.controller.sal.binding.api.BindingAwareConsumer; +import org.opendaylight.controller.sal.restconf.broker.SalRemoteServiceBroker; +import org.opendaylight.yangtools.restconf.client.RestconfClientFactory; +import org.opendaylight.yangtools.restconf.client.api.RestconfClientContext; +import org.opendaylight.yangtools.restconf.client.api.UnsupportedProtocolException; +import org.opendaylight.yangtools.sal.binding.generator.impl.ModuleInfoBackedContext; +import org.opendaylight.yangtools.sal.binding.generator.impl.RuntimeGeneratedMappingServiceImpl; +import org.opendaylight.yangtools.yang.binding.Augmentation; +import org.opendaylight.yangtools.yang.binding.util.BindingReflections; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.google.common.base.Preconditions; + +class SalRemoteClientImpl implements SalRemoteClient { + + private static final Logger logger = LoggerFactory.getLogger(SalRemoteClientImpl.class); + + private final RestconfClientContext restconfClientContext; + private final SalRemoteServiceBroker salRemoteBroker; + private final RuntimeGeneratedMappingServiceImpl mappingService; + + public SalRemoteClientImpl(final URL url) { + Preconditions.checkNotNull(url); + + this.mappingService = new RuntimeGeneratedMappingServiceImpl(); + this.mappingService.setPool(ClassPool.getDefault()); + this.mappingService.init(); + + final ModuleInfoBackedContext moduleInfo = ModuleInfoBackedContext.create(); + moduleInfo.addModuleInfos(BindingReflections.loadModuleInfos()); + this.mappingService.onGlobalContextUpdated(moduleInfo.tryToCreateSchemaContext().get()); + + try { + this.restconfClientContext = new RestconfClientFactory().getRestconfClientContext(url, this.mappingService, + this.mappingService); + + this.salRemoteBroker = new SalRemoteServiceBroker("remote-broker", restconfClientContext); + this.salRemoteBroker.start(); + } catch (UnsupportedProtocolException e) { + logger.error("Unsupported protocol {}.", url.getProtocol(), e); + throw new IllegalArgumentException("Unsupported protocol.", e); + } + } + + @Override + public ConsumerContext registerConsumer() { + return this.salRemoteBroker.registerConsumer(new BindingAwareConsumer() { + + @Override + public void onSessionInitialized(ConsumerContext session) { + } + }, null); + } + + @Override + public void close() throws Exception { + this.restconfClientContext.close(); + this.salRemoteBroker.close(); + } + +} -- 2.36.6