You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2014/03/20 22:39:46 UTC
git commit: STORM-259
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 <pt...@gmail.com>
Authored: Thu Mar 20 17:36:18 2014 -0400
Committer: P. Taylor Goetz <pt...@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 )