Initial commit for NeutronVpn

[vpnservice.git] / neutronvpn / neutronvpn-impl / src / main / java / org / opendaylight / vpnservice / neutronvpn / NeutronvpnProvider.java

diff --git a/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronvpnProvider.java b/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronvpnProvider.java
new file mode 100644 (file)
index 0000000..ccfc14e
--- /dev/null
+++ b/neutronvpn/neutronvpn-impl/src/main/java/org/opendaylight/vpnservice/neutronvpn/NeutronvpnProvider.java
@@ -0,0 +1,142 @@
+/*
+ * Copyright (c) 2015 - 2016 Ericsson India Global Services Pvt Ltd. 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.vpnservice.neutronvpn;
+
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
+import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
+import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
+import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
+import org.opendaylight.vpnservice.mdsalutil.interfaces.IMdsalApiManager;
+import org.opendaylight.vpnservice.neutronvpn.interfaces.INeutronVpnManager;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.lockmanager.rev150819.LockManagerService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.neutronvpn.rev150602.NeutronvpnService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+public class NeutronvpnProvider implements BindingAwareProvider, INeutronVpnManager, AutoCloseable {
+
+    private static final Logger LOG = LoggerFactory.getLogger(NeutronvpnProvider.class);
+    private NeutronvpnManager nvManager;
+    private IMdsalApiManager mdsalManager;
+    private LockManagerService lockManager;
+    private NeutronBgpvpnChangeListener bgpvpnListener;
+    private NeutronNetworkChangeListener networkListener;
+    private NeutronSubnetChangeListener subnetListener;
+    private NeutronRouterChangeListener routerListener;
+    private NeutronPortChangeListener portListener;
+    private RpcProviderRegistry rpcProviderRegistry;
+
+    public NeutronvpnProvider(RpcProviderRegistry rpcRegistry) {
+        this.rpcProviderRegistry = rpcRegistry;
+    }
+
+    public RpcProviderRegistry getRpcProviderRegistry() {
+        return rpcProviderRegistry;
+    }
+
+    public void setRpcProviderRegistry(RpcProviderRegistry rpcProviderRegistry) {
+        this.rpcProviderRegistry = rpcProviderRegistry;
+    }
+
+    public void setMdsalManager(IMdsalApiManager mdsalManager) {
+        this.mdsalManager = mdsalManager;
+    }
+
+    public void setLockManager(LockManagerService lockManager) {
+        this.lockManager = lockManager;
+    }
+
+    @Override
+    public void onSessionInitiated(ProviderContext session) {
+        try {
+            final DataBroker dbx = session.getSALService(DataBroker.class);
+            nvManager = new NeutronvpnManager(dbx, mdsalManager);
+            final BindingAwareBroker.RpcRegistration<NeutronvpnService> rpcRegistration =
+                    getRpcProviderRegistry().addRpcImplementation(NeutronvpnService.class, nvManager);
+            bgpvpnListener = new NeutronBgpvpnChangeListener(dbx, nvManager);
+            networkListener = new NeutronNetworkChangeListener(dbx, nvManager);
+            subnetListener = new NeutronSubnetChangeListener(dbx, nvManager);
+            routerListener = new NeutronRouterChangeListener(dbx, nvManager);
+            portListener = new NeutronPortChangeListener(dbx, nvManager);
+            nvManager.setLockManager(lockManager);
+
+            LOG.info("NeutronvpnProvider Session Initiated");
+        } catch (Exception e) {
+            LOG.error("Error initializing services", e);
+        }
+    }
+
+    @Override
+    public void close() throws Exception {
+        portListener.close();
+        subnetListener.close();
+        routerListener.close();
+        networkListener.close();
+        bgpvpnListener.close();
+        nvManager.close();
+        LOG.info("NeutronvpnProvider Closed");
+    }
+
+    @Override
+    public List<String> showNeutronPortsCLI() {
+        return nvManager.showNeutronPortsCLI();
+    }
+
+    @Override
+    public List<String> showVpnConfigCLI(Uuid vuuid) {
+        return nvManager.showVpnConfigCLI(vuuid);
+    }
+
+    @Override
+    public void addSubnetToVpn(Uuid vpnId, Uuid subnet) {
+        nvManager.addSubnetToVpn(vpnId, subnet);
+    }
+
+    @Override
+    public List<Uuid> getSubnetsforVpn(Uuid vpnid) {
+        return nvManager.getSubnetsforVpn(vpnid);
+    }
+
+    @Override
+    public void removeSubnetFromVpn(Uuid vpnId, Uuid subnet) {
+        nvManager.removeSubnetFromVpn(vpnId, subnet);
+    }
+
+    @Override
+    public Port getNeutronPort(String name) {
+        return nvManager.getNeutronPort(name);
+    }
+
+    @Override
+    public Subnet getNeutronSubnet(Uuid subnetId) {
+        return nvManager.getNeutronSubnet(subnetId);
+    }
+
+    @Override
+    public String uuidToTapPortName(Uuid id) {
+        return NeutronvpnUtils.uuidToTapPortName(id);
+    }
+
+    @Override
+    public Port getNeutronPort(Uuid portId) {
+        return nvManager.getNeutronPort(portId);
+    }
+
+    @Override
+    public IpAddress getNeutronSubnetGateway(Uuid subnetId) {
+        return nvManager.getNeutronSubnetGateway(subnetId);
+    }
+
+}