You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@helix.apache.org by ka...@apache.org on 2014/03/06 22:29:18 UTC
git commit: [HELIX-394] Make cluster event thread a daemon thread
Repository: helix
Updated Branches:
refs/heads/master eb9d69772 -> 6a2a5f67c
[HELIX-394] Make cluster event thread a daemon thread
Project: http://git-wip-us.apache.org/repos/asf/helix/repo
Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/6a2a5f67
Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/6a2a5f67
Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/6a2a5f67
Branch: refs/heads/master
Commit: 6a2a5f67cd2b1791f74a2439822647470740274b
Parents: eb9d697
Author: Kanak Biscuitwala <ka...@apache.org>
Authored: Thu Mar 6 11:19:09 2014 -0800
Committer: Kanak Biscuitwala <ka...@apache.org>
Committed: Thu Mar 6 11:19:09 2014 -0800
----------------------------------------------------------------------
.../org/apache/helix/controller/GenericHelixController.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/helix/blob/6a2a5f67/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java
----------------------------------------------------------------------
diff --git a/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java b/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java
index b11ab9c..c8b033e 100644
--- a/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java
+++ b/helix-core/src/main/java/org/apache/helix/controller/GenericHelixController.java
@@ -91,7 +91,7 @@ import org.apache.log4j.Logger;
public class GenericHelixController implements ConfigChangeListener, IdealStateChangeListener,
LiveInstanceChangeListener, MessageListener, CurrentStateChangeListener,
ExternalViewChangeListener, ControllerChangeListener, HealthStateChangeListener,
- InstanceConfigChangeListener{
+ InstanceConfigChangeListener {
private static final Logger logger = Logger.getLogger(GenericHelixController.class.getName());
volatile boolean init = false;
private final PipelineRegistry _registry;
@@ -238,6 +238,7 @@ public class GenericHelixController implements ConfigChangeListener, IdealStateC
_cache = new ClusterDataCache();
_eventQueue = new ClusterEventBlockingQueue();
_eventThread = new ClusterEventProcessor();
+ _eventThread.setDaemon(true);
_eventThread.start();
}
@@ -468,7 +469,7 @@ public class GenericHelixController implements ConfigChangeListener, IdealStateC
@Override
public void onInstanceConfigChange(List<InstanceConfig> instanceConfigs,
- NotificationContext changeContext){
+ NotificationContext changeContext) {
logger.info("START: GenericClusterController.onInstanceConfigChange()");
onConfigChange(instanceConfigs, changeContext);
logger.info("END: GenericClusterController.onInstanceConfigChange()");