diff --git a/build.xml b/build.xml index 8650e2d1f5..025f9b7194 100644 --- a/build.xml +++ b/build.xml @@ -336,7 +336,7 @@ - + diff --git a/lib/snappy-java-1.0.4.1.jar b/lib/snappy-java-1.0.4.1.jar deleted file mode 100644 index 4f2b757d7f..0000000000 Binary files a/lib/snappy-java-1.0.4.1.jar and /dev/null differ diff --git a/lib/snappy-java-1.0.5.jar b/lib/snappy-java-1.0.5.jar new file mode 100644 index 0000000000..6dc413df20 Binary files /dev/null and b/lib/snappy-java-1.0.5.jar differ diff --git a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java index 83c7c29661..faae28f7d6 100644 --- a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java +++ b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java @@ -17,7 +17,7 @@ */ package org.apache.cassandra.transport; -import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; import org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor; @@ -33,7 +33,7 @@ public class RequestThreadPoolExecutor extends DebuggableThreadPoolExecutor super(DatabaseDescriptor.getNativeTransportMinThreads(), DatabaseDescriptor.getNativeTransportMaxThreads(), CORE_THREAD_TIMEOUT_SEC, TimeUnit.SECONDS, - new ArrayBlockingQueue(32), // Seems to help smooth latency compared to SynchronousQueue. + new LinkedBlockingQueue(32), // Seems to help smooth latency compared to SynchronousQueue. new NamedThreadFactory("Native-Transport-Requests")); } }