*/
package org.opendaylight.l2switch.loopremover;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.l2switch.loopremover.flow.InitialFlowWriter;
import org.opendaylight.l2switch.loopremover.topology.NetworkGraphImpl;
import org.opendaylight.l2switch.loopremover.topology.NetworkGraphService;
import org.opendaylight.l2switch.loopremover.topology.TopologyLinkDataChangeHandler;
+import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowService;
import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.loop.remover.config.rev140528.LoopRemoverConfig;
import org.opendaylight.yangtools.concepts.Registration;
import org.slf4j.LoggerFactory;
public class LoopRemoverProvider {
-
private static final Logger LOG = LoggerFactory.getLogger(LoopRemoverProvider.class);
private final DataBroker dataService;
private Registration topoNodeListnerReg;
private TopologyLinkDataChangeHandler topologyLinkDataChangeHandler;
- public LoopRemoverProvider(final DataBroker dataBroker,
- final SalFlowService salFlowService,
+ public LoopRemoverProvider(final DataBroker dataBroker, final SalFlowService salFlowService,
final LoopRemoverConfig config) {
this.dataService = dataBroker;
this.salFlowService = salFlowService;
public void init() {
//Write initial flows
- if (loopRemoverConfig.isIsInstallLldpFlow()) {
+ if (loopRemoverConfig.getIsInstallLldpFlow()) {
LOG.info("LoopRemover will install an lldp flow");
InitialFlowWriter initialFlowWriter = new InitialFlowWriter(salFlowService);
initialFlowWriter.setFlowTableId(loopRemoverConfig.getLldpFlowTableId());
// Register Topology DataChangeListener
NetworkGraphService networkGraphService = new NetworkGraphImpl();
this.topologyLinkDataChangeHandler = new TopologyLinkDataChangeHandler(dataService, networkGraphService);
- topologyLinkDataChangeHandler.setGraphRefreshDelay(loopRemoverConfig.getGraphRefreshDelay());
+ topologyLinkDataChangeHandler.setGraphRefreshDelay(loopRemoverConfig.getGraphRefreshDelay().toJava());
topologyLinkDataChangeHandler.setTopologyId(loopRemoverConfig.getTopologyId());
listenerRegistration = topologyLinkDataChangeHandler.registerAsDataChangeListener();