Repository: incubator-stratos Updated Branches: refs/heads/master 78d4c84dc -> 3fd80640b
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/8c2a0237 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/8c2a0237 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/8c2a0237 Branch: refs/heads/master Commit: 8c2a02374494d4eb017e2ecff09852341606d4d0 Parents: 78d4c84 Author: Nirmal Fernando <[email protected]> Authored: Mon Feb 17 16:17:47 2014 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Mon Feb 17 16:17:47 2014 +0530 ---------------------------------------------------------------------- .../message/receiver/health/stat/HealthStatReceiver.java | 7 ++++++- .../notifier/InstanceNotifierEventMessageReceiver.java | 7 ++++++- .../messaging/message/receiver/tenant/TenantReceiver.java | 7 ++++++- .../messaging/message/receiver/topology/TopologyReceiver.java | 7 ++++++- 4 files changed, 24 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/8c2a0237/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatReceiver.java index 728cd8a..59f1290 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatReceiver.java @@ -61,7 +61,12 @@ public class HealthStatReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated); + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } } catch (Exception e) { if (log.isErrorEnabled()) { log.error("Topology receiver failed", e); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/8c2a0237/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java index 2b803d3..88f11f3 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/instance/notifier/InstanceNotifierEventMessageReceiver.java @@ -61,7 +61,12 @@ public class InstanceNotifierEventMessageReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated); + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } } catch (Exception e) { if (log.isErrorEnabled()) { log.error("InstanceNotifier receiver failed", e); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/8c2a0237/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantReceiver.java index 7cebcb7..a6f2141 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/tenant/TenantReceiver.java @@ -62,7 +62,12 @@ public class TenantReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated); + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } } catch (Exception e) { if (log.isErrorEnabled()) { log.error("Tenant receiver failed", e); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/8c2a0237/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyReceiver.java index 8757f65..a9bc07e 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/topology/TopologyReceiver.java @@ -62,7 +62,12 @@ public class TopologyReceiver implements Runnable { } // Keep the thread live until terminated - while (!terminated); + while (!terminated) { + try { + Thread.sleep(1000); + } catch (InterruptedException ignore) { + } + } } catch (Exception e) { if (log.isErrorEnabled()) { log.error("Topology receiver failed", e);
