You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by lx...@apache.org on 2017/02/08 17:59:49 UTC
[14/38] helix git commit: Add logs for session sync messages
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 <bo...@linkedin.com>
Authored: Mon Aug 22 21:24:43 2016 -0700
Committer: Lei Xia <lx...@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);