Yuta HIGUCHI
Committed by Gerrit Code Review

Lower log level

Change-Id: I41c72ef6bba5bf59f76ab08c09fb44cf9a5bbae5
...@@ -438,7 +438,7 @@ public class GossipDeviceStore ...@@ -438,7 +438,7 @@ public class GossipDeviceStore
438 438
439 return Collections.emptyList(); 439 return Collections.emptyList();
440 } 440 }
441 - log.info("timestamp for {} {}", deviceId, newTimestamp); 441 + log.debug("timestamp for {} {}", deviceId, newTimestamp);
442 442
443 final Timestamped<List<PortDescription>> timestampedInput 443 final Timestamped<List<PortDescription>> timestampedInput
444 = new Timestamped<>(portDescriptions, newTimestamp); 444 = new Timestamped<>(portDescriptions, newTimestamp);
...@@ -461,7 +461,7 @@ public class GossipDeviceStore ...@@ -461,7 +461,7 @@ public class GossipDeviceStore
461 merged = new Timestamped<List<PortDescription>>(mergedList, newTimestamp); 461 merged = new Timestamped<List<PortDescription>>(mergedList, newTimestamp);
462 } 462 }
463 if (!events.isEmpty()) { 463 if (!events.isEmpty()) {
464 - log.info("Notifying peers of a port update topology event for providerId: {} and deviceId: {}", 464 + log.info("Notifying peers of a ports update topology event for providerId: {} and deviceId: {}",
465 providerId, deviceId); 465 providerId, deviceId);
466 try { 466 try {
467 notifyPeers(new InternalPortEvent(providerId, deviceId, merged)); 467 notifyPeers(new InternalPortEvent(providerId, deviceId, merged));
...@@ -735,7 +735,7 @@ public class GossipDeviceStore ...@@ -735,7 +735,7 @@ public class GossipDeviceStore
735 if (myRole != MastershipRole.NONE) { 735 if (myRole != MastershipRole.NONE) {
736 relinquishAtEnd = true; 736 relinquishAtEnd = true;
737 } 737 }
738 - log.info("Temporarlily requesting role for {} to remove", deviceId); 738 + log.debug("Temporarily requesting role for {} to remove", deviceId);
739 mastershipService.requestRoleFor(deviceId); 739 mastershipService.requestRoleFor(deviceId);
740 MastershipTermService termService = mastershipService.requestTermService(); 740 MastershipTermService termService = mastershipService.requestTermService();
741 MastershipTerm term = termService.getMastershipTerm(deviceId); 741 MastershipTerm term = termService.getMastershipTerm(deviceId);
...@@ -745,7 +745,7 @@ public class GossipDeviceStore ...@@ -745,7 +745,7 @@ public class GossipDeviceStore
745 } 745 }
746 746
747 if (!myId.equals(master)) { 747 if (!myId.equals(master)) {
748 - log.info("{} has control of {}, forwarding remove request", 748 + log.debug("{} has control of {}, forwarding remove request",
749 master, deviceId); 749 master, deviceId);
750 750
751 ClusterMessage message = new ClusterMessage( 751 ClusterMessage message = new ClusterMessage(
...@@ -768,7 +768,7 @@ public class GossipDeviceStore ...@@ -768,7 +768,7 @@ public class GossipDeviceStore
768 Timestamp timestamp = deviceClockService.getTimestamp(deviceId); 768 Timestamp timestamp = deviceClockService.getTimestamp(deviceId);
769 DeviceEvent event = removeDeviceInternal(deviceId, timestamp); 769 DeviceEvent event = removeDeviceInternal(deviceId, timestamp);
770 if (event != null) { 770 if (event != null) {
771 - log.info("Notifying peers of a device removed topology event for deviceId: {}", 771 + log.debug("Notifying peers of a device removed topology event for deviceId: {}",
772 deviceId); 772 deviceId);
773 try { 773 try {
774 notifyPeers(new InternalDeviceRemovedEvent(deviceId, timestamp)); 774 notifyPeers(new InternalDeviceRemovedEvent(deviceId, timestamp));
...@@ -778,7 +778,7 @@ public class GossipDeviceStore ...@@ -778,7 +778,7 @@ public class GossipDeviceStore
778 } 778 }
779 } 779 }
780 if (relinquishAtEnd) { 780 if (relinquishAtEnd) {
781 - log.info("Relinquishing temporary role acquired for {}", deviceId); 781 + log.debug("Relinquishing temporary role acquired for {}", deviceId);
782 mastershipService.relinquishMastership(deviceId); 782 mastershipService.relinquishMastership(deviceId);
783 } 783 }
784 return event; 784 return event;
...@@ -1180,7 +1180,7 @@ public class GossipDeviceStore ...@@ -1180,7 +1180,7 @@ public class GossipDeviceStore
1180 return; 1180 return;
1181 } 1181 }
1182 1182
1183 - log.info("Need to sync {} {}", reqDevices, reqPorts); 1183 + log.debug("Need to sync {} {}", reqDevices, reqPorts);
1184 1184
1185 // 2-way Anti-Entropy for now 1185 // 2-way Anti-Entropy for now
1186 try { 1186 try {
...@@ -1215,7 +1215,7 @@ public class GossipDeviceStore ...@@ -1215,7 +1215,7 @@ public class GossipDeviceStore
1215 @Override 1215 @Override
1216 public void run() { 1216 public void run() {
1217 if (Thread.currentThread().isInterrupted()) { 1217 if (Thread.currentThread().isInterrupted()) {
1218 - log.info("Interrupted, quitting"); 1218 + log.debug("Interrupted, quitting");
1219 return; 1219 return;
1220 } 1220 }
1221 1221
...@@ -1241,7 +1241,7 @@ public class GossipDeviceStore ...@@ -1241,7 +1241,7 @@ public class GossipDeviceStore
1241 DeviceAntiEntropyAdvertisement ad = createAdvertisement(); 1241 DeviceAntiEntropyAdvertisement ad = createAdvertisement();
1242 1242
1243 if (Thread.currentThread().isInterrupted()) { 1243 if (Thread.currentThread().isInterrupted()) {
1244 - log.info("Interrupted, quitting"); 1244 + log.debug("Interrupted, quitting");
1245 return; 1245 return;
1246 } 1246 }
1247 1247
...@@ -1323,7 +1323,7 @@ public class GossipDeviceStore ...@@ -1323,7 +1323,7 @@ public class GossipDeviceStore
1323 Timestamped<List<PortDescription>> portDescriptions = event.portDescriptions(); 1323 Timestamped<List<PortDescription>> portDescriptions = event.portDescriptions();
1324 1324
1325 if (getDevice(deviceId) == null) { 1325 if (getDevice(deviceId) == null) {
1326 - log.info("{} not found on this node yet, ignoring.", deviceId); 1326 + log.debug("{} not found on this node yet, ignoring.", deviceId);
1327 // Note: dropped information will be recovered by anti-entropy 1327 // Note: dropped information will be recovered by anti-entropy
1328 return; 1328 return;
1329 } 1329 }
...@@ -1344,7 +1344,7 @@ public class GossipDeviceStore ...@@ -1344,7 +1344,7 @@ public class GossipDeviceStore
1344 Timestamped<PortDescription> portDescription = event.portDescription(); 1344 Timestamped<PortDescription> portDescription = event.portDescription();
1345 1345
1346 if (getDevice(deviceId) == null) { 1346 if (getDevice(deviceId) == null) {
1347 - log.info("{} not found on this node yet, ignoring.", deviceId); 1347 + log.debug("{} not found on this node yet, ignoring.", deviceId);
1348 // Note: dropped information will be recovered by anti-entropy 1348 // Note: dropped information will be recovered by anti-entropy
1349 return; 1349 return;
1350 } 1350 }
......
...@@ -185,7 +185,7 @@ public class GossipHostStore ...@@ -185,7 +185,7 @@ public class GossipHostStore
185 Timestamp timestamp = hostClockService.getTimestamp(hostId); 185 Timestamp timestamp = hostClockService.getTimestamp(hostId);
186 HostEvent event = createOrUpdateHostInternal(providerId, hostId, hostDescription, timestamp); 186 HostEvent event = createOrUpdateHostInternal(providerId, hostId, hostDescription, timestamp);
187 if (event != null) { 187 if (event != null) {
188 - log.info("Notifying peers of a host topology event for providerId: " 188 + log.debug("Notifying peers of a host topology event for providerId: "
189 + "{}; hostId: {}; hostDescription: {}", providerId, hostId, hostDescription); 189 + "{}; hostId: {}; hostDescription: {}", providerId, hostId, hostDescription);
190 try { 190 try {
191 notifyPeers(new InternalHostEvent(providerId, hostId, hostDescription, timestamp)); 191 notifyPeers(new InternalHostEvent(providerId, hostId, hostDescription, timestamp));
...@@ -266,7 +266,7 @@ public class GossipHostStore ...@@ -266,7 +266,7 @@ public class GossipHostStore
266 Timestamp timestamp = hostClockService.getTimestamp(hostId); 266 Timestamp timestamp = hostClockService.getTimestamp(hostId);
267 HostEvent event = removeHostInternal(hostId, timestamp); 267 HostEvent event = removeHostInternal(hostId, timestamp);
268 if (event != null) { 268 if (event != null) {
269 - log.info("Notifying peers of a host removed topology event for hostId: {}", hostId); 269 + log.debug("Notifying peers of a host removed topology event for hostId: {}", hostId);
270 try { 270 try {
271 notifyPeers(new InternalHostRemovedEvent(hostId, timestamp)); 271 notifyPeers(new InternalHostRemovedEvent(hostId, timestamp));
272 } catch (IOException e) { 272 } catch (IOException e) {
......
...@@ -270,7 +270,7 @@ public class GossipLinkStore ...@@ -270,7 +270,7 @@ public class GossipLinkStore
270 try { 270 try {
271 notifyPeers(new InternalLinkEvent(providerId, mergedDesc)); 271 notifyPeers(new InternalLinkEvent(providerId, mergedDesc));
272 } catch (IOException e) { 272 } catch (IOException e) {
273 - log.info("Failed to notify peers of a link update topology event from providerId: " 273 + log.debug("Failed to notify peers of a link update topology event from providerId: "
274 + "{} between src: {} and dst: {}", 274 + "{} between src: {} and dst: {}",
275 providerId, linkDescription.src(), linkDescription.dst()); 275 providerId, linkDescription.src(), linkDescription.dst());
276 } 276 }
...@@ -625,7 +625,7 @@ public class GossipLinkStore ...@@ -625,7 +625,7 @@ public class GossipLinkStore
625 @Override 625 @Override
626 public void run() { 626 public void run() {
627 if (Thread.currentThread().isInterrupted()) { 627 if (Thread.currentThread().isInterrupted()) {
628 - log.info("Interrupted, quitting"); 628 + log.debug("Interrupted, quitting");
629 return; 629 return;
630 } 630 }
631 631
...@@ -651,7 +651,7 @@ public class GossipLinkStore ...@@ -651,7 +651,7 @@ public class GossipLinkStore
651 LinkAntiEntropyAdvertisement ad = createAdvertisement(); 651 LinkAntiEntropyAdvertisement ad = createAdvertisement();
652 652
653 if (Thread.currentThread().isInterrupted()) { 653 if (Thread.currentThread().isInterrupted()) {
654 - log.info("Interrupted, quitting"); 654 + log.debug("Interrupted, quitting");
655 return; 655 return;
656 } 656 }
657 657
......