Instantiate IovisorRenderer in the IovisorProviderModule

Change-Id: I74b30556026a5b83427df9a806802528a5289468
Signed-off-by: adetalhouet <adetalhouet@inocybe.com>

diff --git a/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderModule.java b/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderModule.java
index 6e1e8088f504aedbc8aebf558c04295253bb8838..5553a1b84533dc04dbd1e4b906ed9a5723f1e529 100644 (file)
--- a/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderModule.java
+++ b/renderers/iovisor/src/main/java/org/opendaylight/controller/config/yang/config/iovisor_provider/impl/IovisorProviderModule.java
@@ -1,4 +1,7 @@
 package org.opendaylight.controller.config.yang.config.iovisor_provider.impl;
+
+import org.opendaylight.groupbasedpolicy.renderer.iovisor.IovisorRenderer;
+
 public class IovisorProviderModule extends org.opendaylight.controller.config.yang.config.iovisor_provider.impl.AbstractIovisorProviderModule {
     public IovisorProviderModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
         super(identifier, dependencyResolver);
@@ -15,8 +18,6 @@ public class IovisorProviderModule extends org.opendaylight.controller.config.ya
 
     @Override
     public java.lang.AutoCloseable createInstance() {
-        // TODO:implement
-        throw new java.lang.UnsupportedOperationException();
+        return  new IovisorRenderer(getDataBrokerDependency());
     }
-
 }

diff --git a/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/IovisorRenderer.java b/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/IovisorRenderer.java
index e0b1bf84d9283b40faafdb77c0fe7680ec8a0a81..ddda3f5909e2531e9e13ef2d97178f0a21c017df 100644 (file)
--- a/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/IovisorRenderer.java
+++ b/renderers/iovisor/src/main/java/org/opendaylight/groupbasedpolicy/renderer/iovisor/IovisorRenderer.java
@@ -8,12 +8,8 @@
 
 package org.opendaylight.groupbasedpolicy.renderer.iovisor;
 
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.NotificationService;
-import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
+import org.opendaylight.groupbasedpolicy.renderer.iovisor.endpoint.EndpointManager;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -24,24 +20,18 @@ public class IovisorRenderer implements AutoCloseable {
 
     private static final Logger LOG = LoggerFactory.getLogger(IovisorRenderer.class);
 
-    private final DataBroker dataBroker;
-    private final ScheduledExecutorService executor;
-
-
-    public IovisorRenderer(final DataBroker dataProvider, RpcProviderRegistry rpcRegistry,
-            NotificationService notificationService) {
-        super();
-        this.dataBroker = dataProvider;
-
-        int numCPU = Runtime.getRuntime().availableProcessors();
-        executor = Executors.newScheduledThreadPool(numCPU * 2);
+    private EndpointManager endPointManager;
 
+    public IovisorRenderer(final DataBroker dataBroker) {
         LOG.info("IOVisor Renderer has Started");
+        this.endPointManager = new EndpointManager(dataBroker);
     }
 
     @Override
     public void close() throws Exception {
-        executor.shutdownNow();
+        if (endPointManager != null) {
+            endPointManager.close();
+        }
     }
 
 }