X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=nexthopmgr%2Fnexthopmgr-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fnexthopmgr%2FNexthopmgrProvider.java;h=68758b6d079de4c3420fb75f228ea4249a996e97;hb=5d87e53cdbed3197a5035ae7452583bd5ae8c638;hp=23397f76178690e18ae11b4711e61a88298526c3;hpb=f663fe9d2a357079006332e7cfff423037156455;p=vpnservice.git diff --git a/nexthopmgr/nexthopmgr-impl/src/main/java/org/opendaylight/vpnservice/nexthopmgr/NexthopmgrProvider.java b/nexthopmgr/nexthopmgr-impl/src/main/java/org/opendaylight/vpnservice/nexthopmgr/NexthopmgrProvider.java index 23397f76..68758b6d 100644 --- a/nexthopmgr/nexthopmgr-impl/src/main/java/org/opendaylight/vpnservice/nexthopmgr/NexthopmgrProvider.java +++ b/nexthopmgr/nexthopmgr-impl/src/main/java/org/opendaylight/vpnservice/nexthopmgr/NexthopmgrProvider.java @@ -10,27 +10,33 @@ package org.opendaylight.vpnservice.nexthopmgr; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; import org.opendaylight.controller.sal.binding.api.BindingAwareProvider; +import org.opendaylight.vpnservice.nexthopmgr.NexthopManager; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class NexthopmgrProvider implements BindingAwareProvider, - AutoCloseable { +public class NexthopmgrProvider implements BindingAwareProvider, AutoCloseable { private static final Logger LOG = LoggerFactory.getLogger(NexthopmgrProvider.class); - // private nexthopmgr nhManager; + private VpnInterfaceChangeListener vpnIfListener; + private OdlInterfaceChangeListener odlIfListener; + private NexthopManager nhManager; @Override public void onSessionInitiated(ProviderContext session) { - final DataBroker dataBroker = session.getSALService(DataBroker.class); - // nhManager = new nexthopManager(dataBroker); - LOG.info("NexthopmgrProvider Session Initiated"); + final DataBroker dbx = session.getSALService(DataBroker.class); + nhManager = new NexthopManager(dbx); + vpnIfListener = new VpnInterfaceChangeListener(dbx, nhManager); + odlIfListener = new OdlInterfaceChangeListener(dbx, nhManager); + LOG.info("NexthopmgrProvider Session Initiated"); } @Override public void close() throws Exception { - //nhManager.close(); - LOG.info("NexthopmgrProvider Closed"); + vpnIfListener.close(); + odlIfListener.close(); + nhManager.close(); + LOG.info("NexthopmgrProvider Closed"); } }