Fpm additional logs
Change-Id: I23d8b2abde14ddf654c0379181c78e9818aa8094
(cherry picked from commit a533f14b31bc38a57a44f1e839edd25fac745c67)
diff --git a/apps/routing/fpm/app/src/main/java/org/onosproject/routing/fpm/FpmManager.java b/apps/routing/fpm/app/src/main/java/org/onosproject/routing/fpm/FpmManager.java
index c64ac92..e922755 100644
--- a/apps/routing/fpm/app/src/main/java/org/onosproject/routing/fpm/FpmManager.java
+++ b/apps/routing/fpm/app/src/main/java/org/onosproject/routing/fpm/FpmManager.java
@@ -415,6 +415,7 @@
}
if (clearRoutes) {
+ log.debug("Clearing routes for the peer");
peers.keySet().forEach(this::clearRoutes);
}
}
@@ -619,7 +620,7 @@
// Encode message in a channel buffer and transmit.
ch.write(fpmMessage.encode());
-
+ log.debug("Fpm Message for updated route {}", fpmMessage.toString());
} catch (RuntimeException e) {
log.info("Route not sent over fpm connection.");
}
@@ -695,6 +696,7 @@
@Override
public boolean peerConnected(FpmPeer peer) {
+ log.info("FPM connection to {} was connected", peer);
if (peers.keySet().contains(peer)) {
return false;
}
@@ -822,7 +824,7 @@
.filter(i -> i.connectedTo().equals(event.subject().id()))
.findAny()
.ifPresent(value::remove);
-
+ log.info("Connection {} removed for disabled peer {}", value, key);
if (value.isEmpty()) {
peers.remove(key);
}