this.exportPolicyPeerTrackerMap = exportPolicies.build();
this.renderStats = new RIBImplRuntimeMXBeanImpl(localBgpId, ribId, localAs, cId, this, this.localTablesKeys);
- LOG.info("RIB Singleton Service {} registered", getIdentifier());
+ LOG.info("RIB Singleton Service {} registered, RIB {}", getIdentifier().getValue(), this.ribId.getValue());
//this need to be always the last step
this.registration = registerClusterSingletonService(this);
}
if(this.configurationWriter != null) {
this.configurationWriter.apply();
}
- LOG.info("RIB Singleton Service {} instantiated", getIdentifier());
+ LOG.info("RIB Singleton Service {} instantiated, RIB {}", getIdentifier().getValue(), this.ribId.getValue());
LOG.debug("Instantiating RIB table {} at {}", this.ribId , this.yangRibId);
final ContainerNode bgpRib = Builders.containerBuilder().withNodeIdentifier(new NodeIdentifier(BgpRib.QNAME))
@Override
public synchronized ListenableFuture<Void> closeServiceInstance() {
- LOG.info("RIB {} closing instance", this.ribId.getValue());
+ LOG.info("Close RIB Singleton Service {}, RIB {}", getIdentifier().getValue(), this.ribId.getValue());
this.txChainToLocRibWriter.values().forEach(LocRibWriter::close);
this.txChainToLocRibWriter.clear();
this.dataTreeChangeService = rib.getService();
this.serviceGroupIdentifier = rib.getRibIServiceGroupIdentifier();
this.configurationWriter = configurationWriter;
- LOG.info("Application Peer Singleton Service {} registered", getIdentifier());
+ LOG.info("Application Peer Singleton Service {} registered, Application peer {}",
+ getIdentifier().getValue(), this.appRibId.getValue());
//this need to be always the last step
this.singletonServiceRegistration = rib.registerClusterSingletonService(this);
}
if(this.configurationWriter != null) {
this.configurationWriter.apply();
}
- LOG.info("Application Peer Singleton Service {} instantiated", getIdentifier());
+ LOG.info("Application Peer Singleton Service {} instantiated, Application peer {}",
+ getIdentifier().getValue(), this.appRibId.getValue());
final YangInstanceIdentifier yangIId = YangInstanceIdentifier.builder().node(ApplicationRib.QNAME)
.nodeWithKey(ApplicationRib.QNAME, APP_ID_QNAME, this.appRibId.getValue()).node(Tables.QNAME).node(Tables.QNAME).build();
this.applicationPeer.instantiateServiceInstance(this.dataTreeChangeService,
@Override
public ListenableFuture<Void> closeServiceInstance() {
- LOG.info("Application Peer Singleton Service {} instance closed", getIdentifier());
+ LOG.info("Application Peer Singleton Service {} instance closed, Application peer {}",
+ getIdentifier().getValue(), this.appRibId.getValue());
return this.applicationPeer.close();
}
@Override
public synchronized void close() throws Exception {
+ LOG.info("Closing BGP Deployer.");
this.registration.close();
this.peers.values().forEach(PeerBean::close);
this.peers.clear();
if(this.configurationWriter != null) {
this.configurationWriter.apply();
}
- LOG.info("Peer Singleton Service {} instantiated", getIdentifier().getValue());
+ LOG.info("Peer Singleton Service {} instantiated, Peer {}", getIdentifier().getValue(), this.neighborAddress);
this.bgpPeer.instantiateServiceInstance();
this.dispatcher.getBGPPeerRegistry().addPeer(this.neighborAddress, this.bgpPeer, this.prefs);
if (this.activeConnection) {
@Override
public ListenableFuture<Void> closeServiceInstance() {
- LOG.info("Close Peer Singleton Service {}", getIdentifier().getValue());
+ LOG.info("Close Peer Singleton Service {}, Peer {}", getIdentifier().getValue(), this.neighborAddress);
if (this.connection != null) {
this.connection.cancel(true);
this.connection = null;