fixing while true loops which resulted in cpu spinning issues
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/ff962936 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/ff962936 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/ff962936 Branch: refs/heads/master Commit: ff962936a870590b8f1a722f1e56f4f05207770e Parents: 8c2a023 Author: Nirmal Fernando <[email protected]> Authored: Mon Feb 17 16:17:55 2014 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Mon Feb 17 16:17:55 2014 +0530 ---------------------------------------------------------------------- .../message/receiver/health/AutoscalerHealthStatReceiver.java | 7 ++++++- .../message/receiver/topology/AutoscalerTopologyReceiver.java | 7 ++++++- 2 files changed, 12 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/ff962936/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java index ac76899..81bc67e 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java @@ -71,7 +71,12 @@ public class AutoscalerHealthStatReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated); + while (!terminated){ + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } if(log.isInfoEnabled()) { log.info("Autoscaler health stat receiver thread terminated"); } http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/ff962936/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java index 0efa6e1..ffbbbb3 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/topology/AutoscalerTopologyReceiver.java @@ -81,7 +81,12 @@ public class AutoscalerTopologyReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated); + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } if(log.isInfoEnabled()) { log.info("Autoscaler topology receiver thread terminated"); }
