You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2011/06/20 11:00:24 UTC
svn commit: r1137550 - in /cassandra/branches/cassandra-0.8: CHANGES.txt
src/java/org/apache/cassandra/service/StorageService.java
Author: slebresne
Date: Mon Jun 20 09:00:24 2011
New Revision: 1137550
URL: http://svn.apache.org/viewvc?rev=1137550&view=rev
Log:
Add startup flag to renew count node id
patch by slebresne; reviewed by jbellis for CASSANDRA-2788
Modified:
cassandra/branches/cassandra-0.8/CHANGES.txt
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
Modified: cassandra/branches/cassandra-0.8/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1137550&r1=1137549&r2=1137550&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.8/CHANGES.txt Mon Jun 20 09:00:24 2011
@@ -1,6 +1,7 @@
0.8.2
* fix cache mbean getSize (CASSANDRA-2781)
* Add Date, Float, Double, and Boolean types
+ * Add startup flag to renew counter node id (CASSANDRA-2788)
0.8.1
Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java?rev=1137550&r1=1137549&r2=1137550&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java (original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java Mon Jun 20 09:00:24 2011
@@ -389,6 +389,12 @@ public class StorageService implements I
}
}
+ if (Boolean.parseBoolean(System.getProperty("cassandra.renew_counter_id", "false")))
+ {
+ logger_.info("Renewing local node id (as requested)");
+ NodeId.renewLocalId();
+ }
+
// daemon threads, like our executors', continue to run while shutdown hooks are invoked
Thread drainOnShutdown = new Thread(new WrappedRunnable()
{