Author: jbellis
Date: Thu Dec 23 17:27:08 2010
New Revision: 1052335
URL: http://svn.apache.org/viewvc?rev=1052335&view=rev
Log:
upgrade to TFastFramedTransport
patch by tjake; reviewed by jbellis for CASSANDRA-1743
Modified:
cassandra/branches/cassandra-0.7/CHANGES.txt
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
Modified: cassandra/branches/cassandra-0.7/CHANGES.txt
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/CHANGES.txt?rev=1052335&r1=1052334&r2=1052335&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.7/CHANGES.txt Thu Dec 23 17:27:08 2010
@@ -4,6 +4,7 @@ dev
histograms in StorageProxyMBean (CASSANDRA-1893)
* check log4j configuration for changes every 10s (CASSANDRA-1525)
* More-efficient cross-DC replication (CASSANDRA-1530)
+ * upgrade to TFastFramedTransport (CASSANDRA-1743)
0.7.0-rc3
Modified:
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/thrift/CassandraDaemon.java?rev=1052335&r1=1052334&r2=1052335&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
(original)
+++
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/thrift/CassandraDaemon.java
Thu Dec 23 17:27:08 2010
@@ -25,13 +25,12 @@ import java.util.concurrent.ExecutorServ
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.cassandra.config.ConfigurationException;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.thrift.TProcessorFactory;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
import org.apache.thrift.server.TServer;
-import org.apache.thrift.transport.TFramedTransport;
+import org.apache.thrift.transport.TFastFramedTransport;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TTransportFactory;
@@ -86,9 +85,9 @@ public class CassandraDaemon extends org
if (DatabaseDescriptor.isThriftFramed())
{
int tFramedTransportSize =
DatabaseDescriptor.getThriftFramedTransportSize();
- inTransportFactory = new
TFramedTransport.Factory(tFramedTransportSize);
- outTransportFactory = new
TFramedTransport.Factory(tFramedTransportSize);
- logger.info("Using TFramedTransport with a max frame size of {}
bytes.", tFramedTransportSize);
+ inTransportFactory = new TFastFramedTransport.Factory(64 * 1024,
tFramedTransportSize);
+ outTransportFactory = new TFastFramedTransport.Factory(64 * 1024,
tFramedTransportSize);
+ logger.info("Using TFastFramedTransport with a max frame size of
{} bytes.", tFramedTransportSize);
}
else
{
