Repository: incubator-rocketmq Updated Branches: refs/heads/master 55d73e18a -> 9d76ea923
MASTER [ROCKETMQ-33] Resolve cpu occupy 100% issue in GroupCommitService/HAService, closes apache/incubator-rocketmq#31 Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/9d76ea92 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/9d76ea92 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/9d76ea92 Branch: refs/heads/master Commit: 9d76ea923159ff36d462b1809104164e270fce96 Parents: 55d73e1 Author: qinliujie <> Authored: Mon Jan 9 11:26:07 2017 +0800 Committer: yukon <[email protected]> Committed: Mon Jan 9 11:26:07 2017 +0800 ---------------------------------------------------------------------- store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +- store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/9d76ea92/store/src/main/java/org/apache/rocketmq/store/CommitLog.java ---------------------------------------------------------------------- diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java index 5ebab54..b4bf298 100644 --- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java @@ -1045,7 +1045,7 @@ public class CommitLog { while (!this.isStopped()) { try { - this.waitForRunning(0); + this.waitForRunning(10); this.doCommit(); } catch (Exception e) { CommitLog.log.warn(this.getServiceName() + " service has exception. ", e); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/9d76ea92/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java ---------------------------------------------------------------------- diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java index d2e8cd9..762bdb6 100644 --- a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java +++ b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java @@ -297,7 +297,7 @@ public class HAService { while (!this.isStopped()) { try { - this.waitForRunning(0); + this.waitForRunning(10); this.doWaitTransfer(); } catch (Exception e) { log.warn(this.getServiceName() + " service has exception. ", e);
