Madan Jampani

Dropping log level to debug on some LeadershipManager messages

Change-Id: Id3faea66a09a4ce8ca7a7e5b521c05b21d1a37e4
...@@ -275,7 +275,7 @@ public class DistributedLeadershipManager implements LeadershipService { ...@@ -275,7 +275,7 @@ public class DistributedLeadershipManager implements LeadershipService {
275 Versioned<NodeId> leader = leaderMap.get(path); 275 Versioned<NodeId> leader = leaderMap.get(path);
276 if (leader != null && Objects.equals(leader.value(), localNodeId)) { 276 if (leader != null && Objects.equals(leader.value(), localNodeId)) {
277 if (leaderMap.remove(path, leader.version())) { 277 if (leaderMap.remove(path, leader.version())) {
278 - log.info("Gave up leadership for {}", path); 278 + log.debug("Gave up leadership for {}", path);
279 future.complete(null); 279 future.complete(null);
280 publish(new LeadershipEvent( 280 publish(new LeadershipEvent(
281 LeadershipEvent.Type.LEADER_BOOTED, 281 LeadershipEvent.Type.LEADER_BOOTED,
...@@ -323,7 +323,7 @@ public class DistributedLeadershipManager implements LeadershipService { ...@@ -323,7 +323,7 @@ public class DistributedLeadershipManager implements LeadershipService {
323 Versioned<NodeId> leader = leaderMap.get(path); 323 Versioned<NodeId> leader = leaderMap.get(path);
324 if (leader != null && Objects.equals(leader.value(), localNodeId)) { 324 if (leader != null && Objects.equals(leader.value(), localNodeId)) {
325 if (leaderMap.remove(path, leader.version())) { 325 if (leaderMap.remove(path, leader.version())) {
326 - log.info("Stepped down from leadership for {}", path); 326 + log.debug("Stepped down from leadership for {}", path);
327 publish(new LeadershipEvent( 327 publish(new LeadershipEvent(
328 LeadershipEvent.Type.LEADER_BOOTED, 328 LeadershipEvent.Type.LEADER_BOOTED,
329 new Leadership(path, 329 new Leadership(path,
...@@ -406,7 +406,7 @@ public class DistributedLeadershipManager implements LeadershipService { ...@@ -406,7 +406,7 @@ public class DistributedLeadershipManager implements LeadershipService {
406 Versioned<NodeId> currentLeader = leaderMap.get(path); 406 Versioned<NodeId> currentLeader = leaderMap.get(path);
407 if (currentLeader != null) { 407 if (currentLeader != null) {
408 if (localNodeId.equals(currentLeader.value())) { 408 if (localNodeId.equals(currentLeader.value())) {
409 - log.info("Already has leadership for {}", path); 409 + log.debug("Already has leadership for {}", path);
410 // FIXME: candidates can get out of sync. 410 // FIXME: candidates can get out of sync.
411 Leadership leadership = new Leadership(path, 411 Leadership leadership = new Leadership(path,
412 localNodeId, 412 localNodeId,
...@@ -422,7 +422,7 @@ public class DistributedLeadershipManager implements LeadershipService { ...@@ -422,7 +422,7 @@ public class DistributedLeadershipManager implements LeadershipService {
422 } 422 }
423 } else { 423 } else {
424 if (leaderMap.putIfAbsent(path, localNodeId) == null) { 424 if (leaderMap.putIfAbsent(path, localNodeId) == null) {
425 - log.info("Assumed leadership for {}", path); 425 + log.debug("Assumed leadership for {}", path);
426 // do a get again to get the version (epoch) 426 // do a get again to get the version (epoch)
427 Versioned<NodeId> newLeader = leaderMap.get(path); 427 Versioned<NodeId> newLeader = leaderMap.get(path);
428 // FIXME: candidates can get out of sync 428 // FIXME: candidates can get out of sync
...@@ -540,7 +540,7 @@ public class DistributedLeadershipManager implements LeadershipService { ...@@ -540,7 +540,7 @@ public class DistributedLeadershipManager implements LeadershipService {
540 long creationTime = entry.getValue().creationTime(); 540 long creationTime = entry.getValue().creationTime();
541 try { 541 try {
542 if (leaderMap.remove(path, epoch)) { 542 if (leaderMap.remove(path, epoch)) {
543 - log.info("Purged stale lock held by {} for {}", nodeId, path); 543 + log.debug("Purged stale lock held by {} for {}", nodeId, path);
544 publish(new LeadershipEvent( 544 publish(new LeadershipEvent(
545 LeadershipEvent.Type.LEADER_BOOTED, 545 LeadershipEvent.Type.LEADER_BOOTED,
546 new Leadership(path, nodeId, epoch, creationTime))); 546 new Leadership(path, nodeId, epoch, creationTime)));
......