X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=l2switch-main%2Fimplementation%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fyang%2Fgen%2Fv1%2Furn%2Fopendaylight%2Fl2switch%2Fmain%2Fimpl%2Frev140528%2FL2SwitchMainModule.java;h=a33ac1ef03630a40c7dddfc45b49fc894c2eab14;hb=3ea4d3ec7d59e804bc550955e687e30f609664f4;hp=4f650525b5551a9e078135cd43cdce5eaa8b1b98;hpb=90253227b58b0e4efa78b11b4471ea413ab9273a;p=l2switch.git diff --git a/l2switch-main/implementation/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/l2switch/main/impl/rev140528/L2SwitchMainModule.java b/l2switch-main/implementation/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/l2switch/main/impl/rev140528/L2SwitchMainModule.java index 4f650525..a33ac1ef 100644 --- a/l2switch-main/implementation/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/l2switch/main/impl/rev140528/L2SwitchMainModule.java +++ b/l2switch-main/implementation/src/main/java/org/opendaylight/yang/gen/v1/urn/opendaylight/l2switch/main/impl/rev140528/L2SwitchMainModule.java @@ -12,80 +12,83 @@ import org.opendaylight.yangtools.concepts.Registration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class L2SwitchMainModule extends org.opendaylight.yang.gen.v1.urn.opendaylight.l2switch.main.impl.rev140528.AbstractL2SwitchMainModule { +public class L2SwitchMainModule + extends org.opendaylight.yang.gen.v1.urn.opendaylight.l2switch.main.impl.rev140528.AbstractL2SwitchMainModule { - private final static Logger _logger = LoggerFactory.getLogger(L2SwitchMainModule.class); - private Registration invListenerReg = null, reactFlowWriterReg = null; + private final static Logger LOG = LoggerFactory.getLogger(L2SwitchMainModule.class); + private Registration invListenerReg = null, reactFlowWriterReg = null; - public L2SwitchMainModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) { - super(identifier, dependencyResolver); - } - - public L2SwitchMainModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, org.opendaylight.yang.gen.v1.urn.opendaylight.l2switch.main.impl.rev140528.L2SwitchMainModule oldModule, java.lang.AutoCloseable oldInstance) { - super(identifier, dependencyResolver, oldModule, oldInstance); - } + public L2SwitchMainModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, + org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) { + super(identifier, dependencyResolver); + } - @Override - public void customValidation() { - // add custom validation form module attributes here. - } + public L2SwitchMainModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, + org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, + org.opendaylight.yang.gen.v1.urn.opendaylight.l2switch.main.impl.rev140528.L2SwitchMainModule oldModule, + java.lang.AutoCloseable oldInstance) { + super(identifier, dependencyResolver, oldModule, oldInstance); + } - @Override - public java.lang.AutoCloseable createInstance() { - NotificationProviderService notificationService = getNotificationServiceDependency(); - DataBroker dataService = getDataBrokerDependency(); - RpcProviderRegistry rpcRegistryDependency = getRpcRegistryDependency(); - SalFlowService salFlowService = rpcRegistryDependency.getRpcService(SalFlowService.class); + @Override + public void customValidation() { + // add custom validation form module attributes here. + } - // Setup FlowWrtierService - FlowWriterServiceImpl flowWriterService = new FlowWriterServiceImpl(salFlowService); - flowWriterService.setFlowTableId(getReactiveFlowTableId()); - flowWriterService.setFlowPriority(getReactiveFlowPriority()); - flowWriterService.setFlowIdleTimeout(getReactiveFlowIdleTimeout()); - flowWriterService.setFlowHardTimeout(getReactiveFlowHardTimeout()); + @Override + public java.lang.AutoCloseable createInstance() { + NotificationProviderService notificationService = getNotificationServiceDependency(); + DataBroker dataService = getDataBrokerDependency(); + RpcProviderRegistry rpcRegistryDependency = getRpcRegistryDependency(); + SalFlowService salFlowService = rpcRegistryDependency.getRpcService(SalFlowService.class); - // Setup InventoryReader - InventoryReader inventoryReader = new InventoryReader(dataService); + // Setup FlowWrtierService + FlowWriterServiceImpl flowWriterService = new FlowWriterServiceImpl(salFlowService); + flowWriterService.setFlowTableId(getReactiveFlowTableId()); + flowWriterService.setFlowPriority(getReactiveFlowPriority()); + flowWriterService.setFlowIdleTimeout(getReactiveFlowIdleTimeout()); + flowWriterService.setFlowHardTimeout(getReactiveFlowHardTimeout()); - // Write initial flows - if (getIsInstallDropallFlow()) { - _logger.info("L2Switch will install a dropall flow on each switch"); - InitialFlowWriter initialFlowWriter = new InitialFlowWriter(salFlowService); - initialFlowWriter.setFlowTableId(getDropallFlowTableId()); - initialFlowWriter.setFlowPriority(getDropallFlowPriority()); - initialFlowWriter.setFlowIdleTimeout(getDropallFlowIdleTimeout()); - initialFlowWriter.setFlowHardTimeout(getDropallFlowHardTimeout()); - invListenerReg = notificationService.registerNotificationListener(initialFlowWriter); - } - else { - _logger.info("Dropall flows will not be installed"); - } + // Setup InventoryReader + InventoryReader inventoryReader = new InventoryReader(dataService); - if (getIsLearningOnlyMode()) { - _logger.info("L2Switch is in Learning Only Mode"); - } - else { - // Setup reactive flow writer - _logger.info("L2Switch will react to network traffic and install flows"); - ReactiveFlowWriter reactiveFlowWriter = new ReactiveFlowWriter(inventoryReader, flowWriterService); - reactFlowWriterReg = notificationService.registerNotificationListener(reactiveFlowWriter); - } + // Write initial flows + if (getIsInstallDropallFlow()) { + LOG.info("L2Switch will install a dropall flow on each switch"); + InitialFlowWriter initialFlowWriter = new InitialFlowWriter(salFlowService); + initialFlowWriter.setFlowTableId(getDropallFlowTableId()); + initialFlowWriter.setFlowPriority(getDropallFlowPriority()); + initialFlowWriter.setFlowIdleTimeout(getDropallFlowIdleTimeout()); + initialFlowWriter.setFlowHardTimeout(getDropallFlowHardTimeout()); + invListenerReg = notificationService.registerNotificationListener(initialFlowWriter); + } else { + LOG.info("Dropall flows will not be installed"); + } - final class CloseResources implements AutoCloseable { - @Override - public void close() throws Exception { - if(reactFlowWriterReg != null) { - reactFlowWriterReg.close(); + if (getIsLearningOnlyMode()) { + LOG.info("L2Switch is in Learning Only Mode"); + } else { + // Setup reactive flow writer + LOG.info("L2Switch will react to network traffic and install flows"); + ReactiveFlowWriter reactiveFlowWriter = new ReactiveFlowWriter(inventoryReader, flowWriterService); + reactFlowWriterReg = notificationService.registerNotificationListener(reactiveFlowWriter); } - if(invListenerReg != null) { - invListenerReg.close(); + + final class CloseResources implements AutoCloseable { + @Override + public void close() throws Exception { + if (reactFlowWriterReg != null) { + reactFlowWriterReg.close(); + } + if (invListenerReg != null) { + invListenerReg.close(); + } + LOG.info("L2SwitchMain (instance {}) torn down.", this); + } } - _logger.info("L2SwitchMain (instance {}) torn down.", this); - } + AutoCloseable ret = new CloseResources(); + LOG.info("L2SwitchMain (instance {}) initialized.", ret); + return ret; } - AutoCloseable ret = new CloseResources(); - _logger.info("L2SwitchMain (instance {}) initialized.", ret); - return ret; - } }