Change-Id: I74b30556026a5b83427df9a806802528a5289468
Signed-off-by: adetalhouet <adetalhouet@inocybe.com>
package org.opendaylight.controller.config.yang.config.iovisor_provider.impl;
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);
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);
@Override
public java.lang.AutoCloseable createInstance() {
@Override
public java.lang.AutoCloseable createInstance() {
- // TODO:implement
- throw new java.lang.UnsupportedOperationException();
+ return new IovisorRenderer(getDataBrokerDependency());
package org.opendaylight.groupbasedpolicy.renderer.iovisor;
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.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;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private static final Logger LOG = LoggerFactory.getLogger(IovisorRenderer.class);
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");
LOG.info("IOVisor Renderer has Started");
+ this.endPointManager = new EndpointManager(dataBroker);
}
@Override
public void close() throws Exception {
}
@Override
public void close() throws Exception {
- executor.shutdownNow();
+ if (endPointManager != null) {
+ endPointManager.close();
+ }