svn commit: r1071060 - in /cassandra/branches/cassandra-0.6: CHANGES.txt src/java/org/apache/cassandra/db/HintedHandOffManager.java

[jb...@apache.org]

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;
     }