LOG.debug("Modifying RIB instance with configuration: {}", global);
//restart existing rib instance with a new configuration
final RibImpl ribImpl = this.ribs.get(rootIdentifier);
+ LOG.debug("RIB instance modified {}", ribImpl);
if(ribImpl == null ) {
onGlobalCreated(rootIdentifier, global, configurationWriter);
} else if (!ribImpl.isGlobalEqual(global)) {
ribImpl.close();
initiateRibInstance(rootIdentifier, global, ribImpl, configurationWriter);
closedPeers.forEach(peer -> peer.restart(ribImpl, this.mappingService));
- }
- LOG.debug("RIB instance modified {}", ribImpl);
+ }
}
private List<PeerBean> closeAllBindedPeers(final InstanceIdentifier<Bgp> rootIdentifier) {
LOG.debug("Removing RIB instance: {}", rootIdentifier);
final RibImpl ribImpl = this.ribs.remove(rootIdentifier);
if (ribImpl != null) {
- ribImpl.close();
LOG.debug("RIB instance removed {}", ribImpl);
+ ribImpl.close();
}
}
@Override
public String toString() {
- return this.ribImpl.toString();
+ return this.ribImpl != null ? this.ribImpl.toString() : null;
}
private RIBImpl createRib(final ClusterSingletonServiceProvider provider, final Global global, final String bgpInstanceName,