Updated Branches: refs/heads/trunk cfd9399dc -> 9ad560d2f
Bootstrapping nodes never use the hibernation state. Patch by brandonwilliams, reviewed by vijay for CASSANDRA-3737 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/9ad560d2 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/9ad560d2 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/9ad560d2 Branch: refs/heads/trunk Commit: 9ad560d2fbb7f4a9a2cbac5741fe9301919b6319 Parents: cfd9399 Author: Brandon Williams <[email protected]> Authored: Fri Jan 13 18:33:16 2012 -0600 Committer: Brandon Williams <[email protected]> Committed: Fri Jan 13 18:33:16 2012 -0600 ---------------------------------------------------------------------- .../apache/cassandra/service/StorageService.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/9ad560d2/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 db95259..4b544bc 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -507,7 +507,8 @@ public class StorageService implements IEndpointStateChangeSubscriber, StorageSe Gossiper.instance.start(SystemTable.incrementAndGetGeneration()); // needed for node-ring gathering. // add rpc listening info Gossiper.instance.addLocalApplicationState(ApplicationState.RPC_ADDRESS, valueFactory.rpcaddress(DatabaseDescriptor.getRpcAddress())); - Gossiper.instance.addLocalApplicationState(ApplicationState.STATUS, valueFactory.hibernate(null != DatabaseDescriptor.getReplaceToken())); + if (null != DatabaseDescriptor.getReplaceToken()) + Gossiper.instance.addLocalApplicationState(ApplicationState.STATUS, valueFactory.hibernate(true)); MessagingService.instance().listen(FBUtilities.getLocalAddress()); LoadBroadcaster.instance.startBroadcasting();
