You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2009/04/02 22:14:43 UTC
svn commit: r761411 -
/incubator/cassandra/trunk/src/org/apache/cassandra/service/CassandraDaemon.java
Author: jbellis
Date: Thu Apr 2 20:14:43 2009
New Revision: 761411
URL: http://svn.apache.org/viewvc?rev=761411&view=rev
Log:
pass engine options to the constructor
Modified:
incubator/cassandra/trunk/src/org/apache/cassandra/service/CassandraDaemon.java
Modified: incubator/cassandra/trunk/src/org/apache/cassandra/service/CassandraDaemon.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/service/CassandraDaemon.java?rev=761411&r1=761410&r2=761411&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/service/CassandraDaemon.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/service/CassandraDaemon.java Thu Apr 2 20:14:43 2009
@@ -27,6 +27,8 @@
import com.facebook.thrift.server.TThreadPoolServer;
import com.facebook.thrift.transport.TServerSocket;
import com.facebook.thrift.transport.TTransportException;
+import com.facebook.thrift.transport.TTransportFactory;
+import com.facebook.thrift.TProcessorFactory;
import org.apache.cassandra.config.DatabaseDescriptor;
/**
@@ -71,7 +73,13 @@
// ThreadPool Server
TThreadPoolServer.Options options = new TThreadPoolServer.Options();
options.minWorkerThreads = 64;
- serverEngine = new TThreadPoolServer(processor, tServerSocket, tProtocolFactory);
+ serverEngine = new TThreadPoolServer(new TProcessorFactory(processor),
+ tServerSocket,
+ new TTransportFactory(),
+ new TTransportFactory(),
+ tProtocolFactory,
+ tProtocolFactory,
+ options);
}
/** hook for JSVC */