storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ptgo...@apache.org
Subject git commit: STORM-259
Date Thu, 20 Mar 2014 21:39:46 GMT
Repository: incubator-storm
Updated Branches:
  refs/heads/master 20b3496c2 -> d5dee0ef5


STORM-259


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/d5dee0ef
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/d5dee0ef
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/d5dee0ef

Branch: refs/heads/master
Commit: d5dee0ef5f8ad403d1eff05f569c8e9b1e44508c
Parents: 20b3496
Author: P. Taylor Goetz <ptgoetz@gmail.com>
Authored: Thu Mar 20 17:36:18 2014 -0400
Committer: P. Taylor Goetz <ptgoetz@gmail.com>
Committed: Thu Mar 20 17:36:18 2014 -0400

----------------------------------------------------------------------
 storm-core/src/jvm/backtype/storm/messaging/netty/Client.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/d5dee0ef/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 0e62302..f15cd1d 100644
--- a/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
+++ b/storm-core/src/jvm/backtype/storm/messaging/netty/Client.java
@@ -109,6 +109,9 @@ class Client implements IConnection {
      */
     private long getSleepTimeMs()
     {
+        if (retries.get() > 30) {
+           return max_sleep_ms;
+        }
         int backoff = 1 << retries.get();
         long sleepMs = base_sleep_ms * Math.max(1, random.nextInt(backoff));
         if ( sleepMs > max_sleep_ms )


Mime
View raw message