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 <brandonwilli...@apache.org> Authored: Fri Jan 24 17:01:19 2014 -0600 Committer: Brandon Williams <brandonwilli...@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()
