BUG 3510: Disable Node events in fibmanager
[vpnservice.git] / fibmanager / fibmanager-impl / src / main / java / org / opendaylight / vpnservice / fibmanager / FibManagerProvider.java
index bb16187c2bd507dc420ab78e69fe711d0318d98f..ef16ec09ba6ba3ea580c328c1145afbe9e091c97 100644 (file)
@@ -7,6 +7,7 @@
  */
 package org.opendaylight.vpnservice.fibmanager;
 
+import java.math.BigInteger;
 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;
@@ -25,7 +26,7 @@ public class FibManagerProvider implements BindingAwareProvider, IFibManager, Au
   private FibManager fibManager;
   private IMdsalApiManager mdsalManager;
   private IVpnManager vpnmanager;
-  private FibNodeCapableListener fibNcListener;
+  //private FibNodeCapableListener fibNcListener;
 
   @Override
   public void onSessionInitiated(ProviderContext session) {
@@ -36,7 +37,7 @@ public class FibManagerProvider implements BindingAwareProvider, IFibManager, Au
       fibManager = new FibManager(dataBroker, nexthopService);
       fibManager.setMdsalManager(mdsalManager);
       fibManager.setVpnmanager(vpnmanager);
-      fibNcListener = new FibNodeCapableListener(dataBroker, fibManager);
+      //fibNcListener = new FibNodeCapableListener(dataBroker, fibManager);
     } catch (Exception e) {
       LOG.error("Error initializing services", e);
     }
@@ -46,7 +47,7 @@ public class FibManagerProvider implements BindingAwareProvider, IFibManager, Au
   public void close() throws Exception {
     LOG.info("FibManagerProvider Closed");
     fibManager.close();
-    fibNcListener.close();
+    //fibNcListener.close();
   }
 
   public void setMdsalManager(IMdsalApiManager mdsalManager) {
@@ -55,15 +56,16 @@ public class FibManagerProvider implements BindingAwareProvider, IFibManager, Au
 
   public void setVpnmanager(IVpnManager vpnmanager) {
     this.vpnmanager = vpnmanager;
+    vpnmanager.setFibService(this);
   }
 
   @Override
-  public void populateFibOnNewDpn(long dpnId, long vpnId, String rd) {
+  public void populateFibOnNewDpn(BigInteger dpnId, long vpnId, String rd) {
     fibManager.populateFibOnNewDpn(dpnId, vpnId, rd);
   }
 
   @Override
-  public void cleanUpDpnForVpn(long dpnId, long vpnId, String rd) {
-    fibManager.populateFibOnNewDpn(dpnId, vpnId, rd);
+  public void cleanUpDpnForVpn(BigInteger dpnId, long vpnId, String rd) {
+    fibManager.cleanUpDpnForVpn(dpnId, vpnId, rd);
   }
 }