X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=dhcpservice%2Fdhcpservice-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fdhcpservice%2FDhcpProvider.java;fp=dhcpservice%2Fdhcpservice-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fdhcpservice%2FDhcpProvider.java;h=5f15135fb3103bb5505ad1f2b48d3d165fe8bb0b;hb=dedcfdb5a227fc36b5ab61ab485e2f614d426804;hp=ce1a0a11c227c06c31555ab69aa5699841b2f8a0;hpb=50c7445579aba08f89c8b99f8c421bac639ec97e;p=vpnservice.git diff --git a/dhcpservice/dhcpservice-impl/src/main/java/org/opendaylight/vpnservice/dhcpservice/DhcpProvider.java b/dhcpservice/dhcpservice-impl/src/main/java/org/opendaylight/vpnservice/dhcpservice/DhcpProvider.java index ce1a0a11..5f15135f 100644 --- a/dhcpservice/dhcpservice-impl/src/main/java/org/opendaylight/vpnservice/dhcpservice/DhcpProvider.java +++ b/dhcpservice/dhcpservice-impl/src/main/java/org/opendaylight/vpnservice/dhcpservice/DhcpProvider.java @@ -7,7 +7,7 @@ */ package org.opendaylight.vpnservice.dhcpservice; -import java.math.BigInteger; +import org.opendaylight.vpnservice.neutronvpn.interfaces.INeutronVpnManager; import org.opendaylight.controller.sal.binding.api.NotificationProviderService; import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingService; @@ -28,6 +28,8 @@ public class DhcpProvider implements BindingAwareProvider, AutoCloseable { private NotificationProviderService notificationService; private DhcpManager dhcpManager; private NodeListener dhcpNodeListener; + private INeutronVpnManager neutronVpnManager; + private DhcpConfigListener dhcpConfigListener; @Override public void onSessionInitiated(ProviderContext session) { @@ -37,10 +39,12 @@ public class DhcpProvider implements BindingAwareProvider, AutoCloseable { final PacketProcessingService pktProcessingService = session.getRpcService(PacketProcessingService.class); dhcpManager = new DhcpManager(dataBroker); dhcpManager.setMdsalManager(mdsalManager); + dhcpManager.setNeutronVpnService(neutronVpnManager); dhcpPktHandler = new DhcpPktHandler(dataBroker, dhcpManager); dhcpPktHandler.setPacketProcessingService(pktProcessingService); packetListener = notificationService.registerNotificationListener(dhcpPktHandler); dhcpNodeListener = new NodeListener(dataBroker, dhcpManager); + dhcpConfigListener = new DhcpConfigListener(dataBroker, dhcpManager); } catch (Exception e) { LOG.error("Error initializing services", e); } @@ -51,6 +55,10 @@ public class DhcpProvider implements BindingAwareProvider, AutoCloseable { this.mdsalManager = mdsalManager; } + public void setNeutronVpnManager(INeutronVpnManager neutronVpnManager) { + this.neutronVpnManager = neutronVpnManager; + } + @Override public void close() throws Exception { if(packetListener != null) {