Skip to content

Commit f8f7e85

Browse files
hchaundkarcharlesmcchan
authored andcommitted
Fpm additional logs
Change-Id: I23d8b2abde14ddf654c0379181c78e9818aa8094 (cherry picked from commit a533f14)
1 parent 6c8ed00 commit f8f7e85

File tree

1 file changed

+4
-2
lines changed
  • apps/routing/fpm/app/src/main/java/org/onosproject/routing/fpm

1 file changed

+4
-2
lines changed

apps/routing/fpm/app/src/main/java/org/onosproject/routing/fpm/FpmManager.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -415,6 +415,7 @@ private void stopServer() {
415415
}
416416

417417
if (clearRoutes) {
418+
log.debug("Clearing routes for the peer");
418419
peers.keySet().forEach(this::clearRoutes);
419420
}
420421
}
@@ -619,7 +620,7 @@ private void updateRoute(IpAddress pdPushNextHop, boolean isAdd, IpPrefix prefix
619620

620621
// Encode message in a channel buffer and transmit.
621622
ch.write(fpmMessage.encode());
622-
623+
log.debug("Fpm Message for updated route {}", fpmMessage.toString());
623624
} catch (RuntimeException e) {
624625
log.info("Route not sent over fpm connection.");
625626
}
@@ -695,6 +696,7 @@ public void fpmMessage(FpmPeer peer, FpmHeader fpmMessage) {
695696

696697
@Override
697698
public boolean peerConnected(FpmPeer peer) {
699+
log.info("FPM connection to {} was connected", peer);
698700
if (peers.keySet().contains(peer)) {
699701
return false;
700702
}
@@ -822,7 +824,7 @@ public void event(ClusterEvent event) {
822824
.filter(i -> i.connectedTo().equals(event.subject().id()))
823825
.findAny()
824826
.ifPresent(value::remove);
825-
827+
log.info("Connection {} removed for disabled peer {}", value, key);
826828
if (value.isEmpty()) {
827829
peers.remove(key);
828830
}

0 commit comments

Comments
 (0)