changes for config subsystem - BUG 754

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / yang / gen / v1 / urn / opendaylight / params / xml / ns / yang / openflow / _switch / connection / provider / impl / rev140328 / SwitchConnectionProviderModule.java

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/params/xml/ns/yang/openflow/_switch/connection/provider/impl/rev140328/SwitchConnectionProviderModule.java b/openflow-protocol-impl/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/params/xml/ns/yang/openflow/_switch/connection/provider/impl/rev140328/SwitchConnectionProviderModule.java
new file mode 100644 (file)
index 0000000..6dbdef0
--- /dev/null
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/params/xml/ns/yang/openflow/_switch/connection/provider/impl/rev140328/SwitchConnectionProviderModule.java
@@ -0,0 +1,137 @@
+/**
+* Generated file
+
+* Generated from: yang module name: openflow-switch-connection-provider-impl  yang module local name: openflow-switch-connection-provider-impl
+* Generated by: org.opendaylight.controller.config.yangjmxgenerator.plugin.JMXGenerator
+* Generated at: Fri Mar 28 17:50:58 PDT 2014
+*
+* Do not modify this file unless it is present under src/main directory
+*/
+package org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow._switch.connection.provider.impl.rev140328;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+import org.opendaylight.openflowjava.protocol.api.connection.ConnectionConfiguration;
+import org.opendaylight.openflowjava.protocol.impl.connection.SwitchConnectionProviderImpl;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+*
+*/
+public final class SwitchConnectionProviderModule extends org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow._switch.connection.provider.impl.rev140328.AbstractSwitchConnectionProviderModule
+ {
+    
+    private static Logger LOG = LoggerFactory
+            .getLogger(SwitchConnectionProviderModule.class);
+
+    /**
+     * @param identifier
+     * @param dependencyResolver
+     */
+    public SwitchConnectionProviderModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
+        super(identifier, dependencyResolver);
+    }
+
+    /**
+     * @param identifier
+     * @param dependencyResolver
+     * @param oldModule
+     * @param oldInstance
+     */
+    public SwitchConnectionProviderModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver,
+            SwitchConnectionProviderModule oldModule, java.lang.AutoCloseable oldInstance) {
+        super(identifier, dependencyResolver, oldModule, oldInstance);
+    }
+
+    @Override
+    protected void customValidation(){
+        // Add custom validation for module attributes here.
+    }
+
+    @Override
+    public java.lang.AutoCloseable createInstance() {
+        LOG.info("SwitchConnectionProvider started.");
+        SwitchConnectionProviderImpl switchConnectionProviderImpl = new SwitchConnectionProviderImpl();
+        try {
+            ConnectionConfiguration connConfiguration = createConnectionConfiguration();
+            switchConnectionProviderImpl.setConfiguration(connConfiguration);
+        } catch (UnknownHostException e) {
+            throw new IllegalArgumentException(e.getMessage(), e);
+        }
+        return switchConnectionProviderImpl;
+    }
+
+    /**
+     * @return
+     * @throws UnknownHostException 
+     */
+    private ConnectionConfiguration createConnectionConfiguration() throws UnknownHostException {
+        final InetAddress address = extractIpAddressBin(getAddress());
+        final Integer port = getPort();
+        final long switchIdleTimeout = getSwitchIdleTimeout();
+        
+        return new ConnectionConfiguration() {
+            @Override
+            public InetAddress getAddress() {
+                return address;
+            }
+            @Override
+            public int getPort() {
+                return port;
+            }
+            @Override
+            public Object getTransferProtocol() {
+                // TODO Auto-generated method stub
+                return null;
+            }
+            @Override
+            public FEATURE_SUPPORT getTlsSupport() {
+                // TODO Auto-generated method stub
+                return null;
+            }
+            @Override
+            public long getSwitchIdleTimeout() {
+                return switchIdleTimeout;
+            }
+            @Override
+            public Object getSslContext() {
+                // TODO Auto-generated method stub
+                return null;
+            }
+        };
+    }
+
+    /**
+     * @param address
+     * @return
+     * @throws UnknownHostException 
+     */
+    private static InetAddress extractIpAddressBin(IpAddress address) throws UnknownHostException {
+        byte[] addressBin = null;
+        if (address != null) {
+            if (address.getIpv4Address() != null) {
+                addressBin = address2bin(address.getIpv4Address().getValue());
+            } else if (address.getIpv6Address() != null) {
+                addressBin = address2bin(address.getIpv6Address().getValue());
+            }
+        }
+        
+        if (addressBin == null) {
+            return null;
+        } else {
+            return InetAddress.getByAddress(addressBin);
+        }
+    }
+
+    /**
+     * @param value
+     * @return
+     */
+    private static byte[] address2bin(String value) {
+        //TODO: translate ipv4 or ipv6 into byte[]
+        return null;
+    }
+}