cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [2/3] git commit: Ensure native transport is running before setting isRunning Patch by Ravi Prasad, reviewed by brandonwilliams for CASSANDRA-6618
Date Fri, 24 Jan 2014 23:03:52 GMT
Ensure native transport is running before setting isRunning
Patch by Ravi Prasad, reviewed by brandonwilliams for CASSANDRA-6618


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1b858be4
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1b858be4
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1b858be4

Branch: refs/heads/trunk
Commit: 1b858be482114e6038a555bf0937a5e10c9ae7e7
Parents: a169863
Author: Brandon Williams <brandonwilliams@apache.org>
Authored: Fri Jan 24 17:01:19 2014 -0600
Committer: Brandon Williams <brandonwilliams@apache.org>
Committed: Fri Jan 24 17:01:19 2014 -0600

----------------------------------------------------------------------
 src/java/org/apache/cassandra/transport/Server.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/1b858be4/src/java/org/apache/cassandra/transport/Server.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/transport/Server.java b/src/java/org/apache/cassandra/transport/Server.java
index bd403fe..4f46614 100644
--- a/src/java/org/apache/cassandra/transport/Server.java
+++ b/src/java/org/apache/cassandra/transport/Server.java
@@ -106,7 +106,6 @@ public class Server implements CassandraDaemon.Server
 	    if(!isRunning())
 	    {
                 run();
-                isRunning.set(true);
 	    }
     }
 
@@ -156,6 +155,7 @@ public class Server implements CassandraDaemon.Server
         logger.info("Starting listening for CQL clients on {}...", socket);
         Channel channel = bootstrap.bind(socket);
         connectionTracker.allChannels.add(channel);
+        isRunning.set(true);
     }
 
     private void registerMetrics()


Mime
View raw message