helix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From l...@apache.org
Subject [14/38] helix git commit: Add logs for session sync messages
Date Wed, 08 Feb 2017 17:59:49 GMT
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 <boli@linkedin.com>
Authored: Mon Aug 22 21:24:43 2016 -0700
Committer: Lei Xia <lxia@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);


Mime
View raw message