Repository: incubator-stratos Updated Branches: refs/heads/master a9fcde9e0 -> 13998a217
temporarily fixing CPU spinning issue as a quick fix Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/6dfacbd8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/6dfacbd8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/6dfacbd8 Branch: refs/heads/master Commit: 6dfacbd8eb74c274ce3cee98135984312d69e19c Parents: 4f3f265 Author: Nirmal Fernando <[email protected]> Authored: Thu Feb 20 19:55:12 2014 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Thu Feb 20 19:55:12 2014 +0530 ---------------------------------------------------------------------- .../stratos/load/balancer/LoadBalancerTenantReceiver.java | 7 ++++++- .../stratos/load/balancer/LoadBalancerTopologyReceiver.java | 7 ++++++- 2 files changed, 12 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6dfacbd8/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTenantReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTenantReceiver.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTenantReceiver.java index 0941167..316542f 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTenantReceiver.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTenantReceiver.java @@ -189,7 +189,12 @@ public class LoadBalancerTenantReceiver implements Runnable { tenantReceiverThread.start(); // Keep the thread live until terminated - while (!terminated) ; + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } if (log.isInfoEnabled()) { log.info("Load balancer tenant receiver thread terminated"); } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6dfacbd8/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTopologyReceiver.java b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTopologyReceiver.java index 6128037..875cad6 100644 --- a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTopologyReceiver.java +++ b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/LoadBalancerTopologyReceiver.java @@ -64,7 +64,12 @@ public class LoadBalancerTopologyReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated) ; + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } if (log.isInfoEnabled()) { log.info("Load balancer topology receiver thread terminated"); }
