Author: jbellis Date: Tue Feb 15 21:07:34 2011 New Revision: 1071060 URL: http://svn.apache.org/viewvc?rev=1071060&view=rev Log: add -Dhinted_handoff_throttle option patch by jbellis; reviewed by brandonwilliams for CASSANDRA-2161
Modified: cassandra/branches/cassandra-0.6/CHANGES.txt cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/HintedHandOffManager.java Modified: cassandra/branches/cassandra-0.6/CHANGES.txt URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/CHANGES.txt?rev=1071060&r1=1071059&r2=1071060&view=diff ============================================================================== --- cassandra/branches/cassandra-0.6/CHANGES.txt (original) +++ cassandra/branches/cassandra-0.6/CHANGES.txt Tue Feb 15 21:07:34 2011 @@ -3,6 +3,7 @@ * fix range slice ConsistencyLevel > ONE (CASSANDRA-2081) * update commitlog replay to catch bogus RowMutation lengths caused by unclean shutdown (CASSANDRA-2128) + * add -Dhinted_handoff_throttle option (CASSANDRA-2161) 0.6.11 Modified: cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/HintedHandOffManager.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/HintedHandOffManager.java?rev=1071060&r1=1071059&r2=1071060&view=diff ============================================================================== --- cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/HintedHandOffManager.java (original) +++ cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/db/HintedHandOffManager.java Tue Feb 15 21:07:34 2011 @@ -140,6 +140,17 @@ public class HintedHandOffManager return false; } } + + String throttleRaw = System.getProperty("hinted_handoff_throttle"); + Integer throttle = throttleRaw == null ? null : Integer.valueOf(throttleRaw); + try + { + Thread.sleep(throttle == null ? 0 : throttle); + } + catch (InterruptedException e) + { + throw new AssertionError(e); + } } return true; }