Add logs for session sync messages
Project: http://git-wip-us.apache.org/repos/asf/helix/repo Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/a1278e19 Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/a1278e19 Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/a1278e19 Branch: refs/heads/helix-0.6.x Commit: a1278e199b54f29fb37abda20c23262ebb1b9d28 Parents: 2981bbd Author: Boyan Li <b...@linkedin.com> Authored: Mon Aug 22 21:24:43 2016 -0700 Committer: Lei Xia <l...@linkedin.com> Committed: Sun Feb 5 19:17:29 2017 -0800 ---------------------------------------------------------------------- .../org/apache/helix/messaging/handling/HelixTaskExecutor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/helix/blob/a1278e19/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java ---------------------------------------------------------------------- diff --git a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java index 0431770..7a1210f 100644 --- a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java +++ b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java @@ -550,6 +550,7 @@ public class HelixTaskExecutor implements MessageListener, TaskExecutor { HelixDataAccessor accessor = manager.getHelixDataAccessor(); PropertyKey key = new Builder(manager.getClusterName()).controllerMessage(SESSION_SYNC); if (accessor.getProperty(key) == null) { + LOG.info(String.format("Participant %s syncs session with controller", manager.getInstanceName())); Message msg = new Message(MessageType.PARTICIPANT_SESSION_CHANGE, SESSION_SYNC); msg.setSrcName(manager.getInstanceName()); msg.setTgtSessionId("*"); @@ -651,6 +652,7 @@ public class HelixTaskExecutor implements MessageListener, TaskExecutor { if ((manager.getInstanceType() == InstanceType.CONTROLLER || manager.getInstanceType() == InstanceType.CONTROLLER_PARTICIPANT) && MessageType.PARTICIPANT_SESSION_CHANGE.name().equals(message.getMsgType())) { + LOG.info(String.format("Controller received PARTICIPANT_SESSION_CHANGE msg from src: %s", message.getMsgSrc())); PropertyKey key = new Builder(manager.getClusterName()).liveInstances(); List<LiveInstance> liveInstances = manager.getHelixDataAccessor().getChildValues(key); _controller.onLiveInstanceChange(liveInstances, changeContext);
