Lower log level
Change-Id: I41c72ef6bba5bf59f76ab08c09fb44cf9a5bbae5
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java
index 34f8b4a..8d32585 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/device/impl/GossipDeviceStore.java
@@ -438,7 +438,7 @@
return Collections.emptyList();
}
- log.info("timestamp for {} {}", deviceId, newTimestamp);
+ log.debug("timestamp for {} {}", deviceId, newTimestamp);
final Timestamped<List<PortDescription>> timestampedInput
= new Timestamped<>(portDescriptions, newTimestamp);
@@ -461,7 +461,7 @@
merged = new Timestamped<List<PortDescription>>(mergedList, newTimestamp);
}
if (!events.isEmpty()) {
- log.info("Notifying peers of a port update topology event for providerId: {} and deviceId: {}",
+ log.info("Notifying peers of a ports update topology event for providerId: {} and deviceId: {}",
providerId, deviceId);
try {
notifyPeers(new InternalPortEvent(providerId, deviceId, merged));
@@ -735,7 +735,7 @@
if (myRole != MastershipRole.NONE) {
relinquishAtEnd = true;
}
- log.info("Temporarlily requesting role for {} to remove", deviceId);
+ log.debug("Temporarily requesting role for {} to remove", deviceId);
mastershipService.requestRoleFor(deviceId);
MastershipTermService termService = mastershipService.requestTermService();
MastershipTerm term = termService.getMastershipTerm(deviceId);
@@ -745,7 +745,7 @@
}
if (!myId.equals(master)) {
- log.info("{} has control of {}, forwarding remove request",
+ log.debug("{} has control of {}, forwarding remove request",
master, deviceId);
ClusterMessage message = new ClusterMessage(
@@ -768,7 +768,7 @@
Timestamp timestamp = deviceClockService.getTimestamp(deviceId);
DeviceEvent event = removeDeviceInternal(deviceId, timestamp);
if (event != null) {
- log.info("Notifying peers of a device removed topology event for deviceId: {}",
+ log.debug("Notifying peers of a device removed topology event for deviceId: {}",
deviceId);
try {
notifyPeers(new InternalDeviceRemovedEvent(deviceId, timestamp));
@@ -778,7 +778,7 @@
}
}
if (relinquishAtEnd) {
- log.info("Relinquishing temporary role acquired for {}", deviceId);
+ log.debug("Relinquishing temporary role acquired for {}", deviceId);
mastershipService.relinquishMastership(deviceId);
}
return event;
@@ -1180,7 +1180,7 @@
return;
}
- log.info("Need to sync {} {}", reqDevices, reqPorts);
+ log.debug("Need to sync {} {}", reqDevices, reqPorts);
// 2-way Anti-Entropy for now
try {
@@ -1215,7 +1215,7 @@
@Override
public void run() {
if (Thread.currentThread().isInterrupted()) {
- log.info("Interrupted, quitting");
+ log.debug("Interrupted, quitting");
return;
}
@@ -1241,7 +1241,7 @@
DeviceAntiEntropyAdvertisement ad = createAdvertisement();
if (Thread.currentThread().isInterrupted()) {
- log.info("Interrupted, quitting");
+ log.debug("Interrupted, quitting");
return;
}
@@ -1323,7 +1323,7 @@
Timestamped<List<PortDescription>> portDescriptions = event.portDescriptions();
if (getDevice(deviceId) == null) {
- log.info("{} not found on this node yet, ignoring.", deviceId);
+ log.debug("{} not found on this node yet, ignoring.", deviceId);
// Note: dropped information will be recovered by anti-entropy
return;
}
@@ -1344,7 +1344,7 @@
Timestamped<PortDescription> portDescription = event.portDescription();
if (getDevice(deviceId) == null) {
- log.info("{} not found on this node yet, ignoring.", deviceId);
+ log.debug("{} not found on this node yet, ignoring.", deviceId);
// Note: dropped information will be recovered by anti-entropy
return;
}
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java
index fb64435..e1be932 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/host/impl/GossipHostStore.java
@@ -185,7 +185,7 @@
Timestamp timestamp = hostClockService.getTimestamp(hostId);
HostEvent event = createOrUpdateHostInternal(providerId, hostId, hostDescription, timestamp);
if (event != null) {
- log.info("Notifying peers of a host topology event for providerId: "
+ log.debug("Notifying peers of a host topology event for providerId: "
+ "{}; hostId: {}; hostDescription: {}", providerId, hostId, hostDescription);
try {
notifyPeers(new InternalHostEvent(providerId, hostId, hostDescription, timestamp));
@@ -266,7 +266,7 @@
Timestamp timestamp = hostClockService.getTimestamp(hostId);
HostEvent event = removeHostInternal(hostId, timestamp);
if (event != null) {
- log.info("Notifying peers of a host removed topology event for hostId: {}", hostId);
+ log.debug("Notifying peers of a host removed topology event for hostId: {}", hostId);
try {
notifyPeers(new InternalHostRemovedEvent(hostId, timestamp));
} catch (IOException e) {
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java
index 2ae6cd8..97d1ce7 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/link/impl/GossipLinkStore.java
@@ -270,7 +270,7 @@
try {
notifyPeers(new InternalLinkEvent(providerId, mergedDesc));
} catch (IOException e) {
- log.info("Failed to notify peers of a link update topology event from providerId: "
+ log.debug("Failed to notify peers of a link update topology event from providerId: "
+ "{} between src: {} and dst: {}",
providerId, linkDescription.src(), linkDescription.dst());
}
@@ -625,7 +625,7 @@
@Override
public void run() {
if (Thread.currentThread().isInterrupted()) {
- log.info("Interrupted, quitting");
+ log.debug("Interrupted, quitting");
return;
}
@@ -651,7 +651,7 @@
LinkAntiEntropyAdvertisement ad = createAdvertisement();
if (Thread.currentThread().isInterrupted()) {
- log.info("Interrupted, quitting");
+ log.debug("Interrupted, quitting");
return;
}