You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2013/06/19 23:31:18 UTC
[2/3] git commit: simplify initClient gossip loop patch by Adrian
Nistor and jbellis for CASSANDRA-5662
simplify initClient gossip loop
patch by Adrian Nistor and jbellis for CASSANDRA-5662
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9ba0ff03
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9ba0ff03
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9ba0ff03
Branch: refs/heads/trunk
Commit: 9ba0ff03e211554df6b01fd860159cc74bf95026
Parents: fc5044f
Author: Jonathan Ellis <jb...@apache.org>
Authored: Wed Jun 19 16:30:02 2013 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Wed Jun 19 16:30:08 2013 -0500
----------------------------------------------------------------------
src/java/org/apache/cassandra/service/StorageService.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/9ba0ff03/src/java/org/apache/cassandra/service/StorageService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
index e73aa2e..34ecec8 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -395,16 +395,14 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
try
{
// sleep a while to allow gossip to warm up (the other nodes need to know about this one before they can reply).
- boolean isUp = false;
- while (!isUp)
+ outer:
+ while (true)
{
Thread.sleep(1000);
for (InetAddress address : Gossiper.instance.getLiveMembers())
{
if (!Gossiper.instance.isFatClient(address))
- {
- isUp = true;
- }
+ break outer;
}
}