You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/06/11 18:09:54 UTC
[22/50] [abbrv] git commit: STORM-297: fix flusher bug, dead loop
STORM-297: fix flusher bug, dead loop
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/0bca1733
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/0bca1733
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/0bca1733
Branch: refs/heads/security
Commit: 0bca1733d64a92d8ec411f5fdf41ebc90a1bddef
Parents: 426d143
Author: Sean Zhong <cl...@gmail.com>
Authored: Tue Jun 3 14:53:10 2014 +0800
Committer: Sean Zhong <cl...@gmail.com>
Committed: Tue Jun 3 14:53:10 2014 +0800
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/0bca1733/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
index 9765647..8d2d221 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -109,7 +109,7 @@ public class Client implements IConnection {
@Override
public void run() {
- while(!closing) {
+ if(!closing) {
long flushCheckTime = flushCheckTimer.get();
long now = System.currentTimeMillis();
if (now > flushCheckTime) {