Code Review
/
vpnservice.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
BUG 3510: Disable Node events in fibmanager
[vpnservice.git]
/
fibmanager
/
fibmanager-impl
/
src
/
main
/
java
/
org
/
opendaylight
/
vpnservice
/
fibmanager
/
FibManagerProvider.java
diff --git
a/fibmanager/fibmanager-impl/src/main/java/org/opendaylight/vpnservice/fibmanager/FibManagerProvider.java
b/fibmanager/fibmanager-impl/src/main/java/org/opendaylight/vpnservice/fibmanager/FibManagerProvider.java
index bb16187c2bd507dc420ab78e69fe711d0318d98f..ef16ec09ba6ba3ea580c328c1145afbe9e091c97 100644
(file)
--- a/
fibmanager/fibmanager-impl/src/main/java/org/opendaylight/vpnservice/fibmanager/FibManagerProvider.java
+++ b/
fibmanager/fibmanager-impl/src/main/java/org/opendaylight/vpnservice/fibmanager/FibManagerProvider.java
@@
-7,6
+7,7
@@
*/
package org.opendaylight.vpnservice.fibmanager;
*/
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;
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 FibManager fibManager;
private IMdsalApiManager mdsalManager;
private IVpnManager vpnmanager;
- private FibNodeCapableListener fibNcListener;
+
//
private FibNodeCapableListener fibNcListener;
@Override
public void onSessionInitiated(ProviderContext session) {
@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);
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);
}
} 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();
public void close() throws Exception {
LOG.info("FibManagerProvider Closed");
fibManager.close();
- fibNcListener.close();
+
//
fibNcListener.close();
}
public void setMdsalManager(IMdsalApiManager mdsalManager) {
}
public void setMdsalManager(IMdsalApiManager mdsalManager) {
@@
-55,15
+56,16
@@
public class FibManagerProvider implements BindingAwareProvider, IFibManager, Au
public void setVpnmanager(IVpnManager vpnmanager) {
this.vpnmanager = vpnmanager;
public void setVpnmanager(IVpnManager vpnmanager) {
this.vpnmanager = vpnmanager;
+ vpnmanager.setFibService(this);
}
@Override
}
@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
fibManager.populateFibOnNewDpn(dpnId, vpnId, rd);
}
@Override
- public void cleanUpDpnForVpn(
long
dpnId, long vpnId, String rd) {
- fibManager.
populateFibOnNewD
pn(dpnId, vpnId, rd);
+ public void cleanUpDpnForVpn(
BigInteger
dpnId, long vpnId, String rd) {
+ fibManager.
cleanUpDpnForV
pn(dpnId, vpnId, rd);
}
}
}
}