Author: jbellis
Date: Thu Oct 6 18:42:52 2011
New Revision: 1179757
URL: http://svn.apache.org/viewvc?rev=1179757&view=rev
Log:
run compaction and hinted handoff threads at MIN_PRIORITY
patch by jbellis; reviewed by brandonwilliams for CASSANDRA-3308
Modified:
cassandra/branches/cassandra-1.0.0/CHANGES.txt
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/HintedHandOffManager.java
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
Modified: cassandra/branches/cassandra-1.0.0/CHANGES.txt
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0.0/CHANGES.txt?rev=1179757&r1=1179756&r2=1179757&view=diff
==============================================================================
--- cassandra/branches/cassandra-1.0.0/CHANGES.txt (original)
+++ cassandra/branches/cassandra-1.0.0/CHANGES.txt Thu Oct 6 18:42:52 2011
@@ -9,6 +9,7 @@
* (CQL) fix type information returned for wildcard queries (CASSANDRA-3311)
* add estimated tasks to LeveledCompactionStrategy (CASSANDRA-3322)
* avoid including compaction cache-warming in keycache stats (CASSANDRA-3325)
+ * run compaction and hinted handoff threads at MIN_PRIORITY (CASSANDRA-3308)
Fixes merged from 0.8 below:
* Fix tool .bat files when CASSANDRA_HOME contains spaces (CASSANDRA-3258)
* Force flush of status table when removing/updating token (CASSANDRA-3243)
Modified:
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/HintedHandOffManager.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/HintedHandOffManager.java?rev=1179757&r1=1179756&r2=1179757&view=diff
==============================================================================
---
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/HintedHandOffManager.java
(original)
+++
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/HintedHandOffManager.java
Thu Oct 6 18:42:52 2011
@@ -90,7 +90,7 @@ public class HintedHandOffManager implem
private final NonBlockingHashSet<InetAddress> queuedDeliveries = new
NonBlockingHashSet<InetAddress>();
- private final ExecutorService executor_ = new
JMXEnabledThreadPoolExecutor("HintedHandoff");
+ private final ExecutorService executor_ = new
JMXEnabledThreadPoolExecutor("HintedHandoff", Thread.MIN_PRIORITY);
public HintedHandOffManager()
{
Modified:
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/compaction/CompactionManager.java?rev=1179757&r1=1179756&r2=1179757&view=diff
==============================================================================
---
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
(original)
+++
cassandra/branches/cassandra-1.0.0/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
Thu Oct 6 18:42:52 2011
@@ -969,7 +969,7 @@ public class CompactionManager implement
protected CompactionExecutor(int minThreads, int maxThreads, String
name, BlockingQueue<Runnable> queue)
{
- super(minThreads, maxThreads, 60, TimeUnit.SECONDS, queue, new
NamedThreadFactory(name));
+ super(minThreads, maxThreads, 60, TimeUnit.SECONDS, queue, new
NamedThreadFactory(name, Thread.MIN_PRIORITY));
}
private CompactionExecutor(int threadCount, String name)
