Instantiate IovisorRenderer in the IovisorProviderModule

[groupbasedpolicy.git] / renderers / iovisor / src / main / java / org / opendaylight / groupbasedpolicy / renderer / iovisor / IovisorRenderer.java

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();
+        }
     }
 
 }