[Amdatu-commits] SVN r631 - trunk/amdatu-cassandra/cassandra-application/src/main/java/org/amdatu/cassandra/application/service

[subvers...@amdatu.org]

Author: ivol37 at gmail.com
Date: Fri Jan 14 13:57:40 2011
New Revision: 631

Log:
[AMDATU-266] Increased Thrift timeout

Modified:
   
trunk/amdatu-cassandra/cassandra-application/src/main/java/org/amdatu/cassandra/application/service/CassandraDaemonServiceImpl.java

Modified: 
trunk/amdatu-cassandra/cassandra-application/src/main/java/org/amdatu/cassandra/application/service/CassandraDaemonServiceImpl.java
==============================================================================
--- 
trunk/amdatu-cassandra/cassandra-application/src/main/java/org/amdatu/cassandra/application/service/CassandraDaemonServiceImpl.java
 (original)
+++ 
trunk/amdatu-cassandra/cassandra-application/src/main/java/org/amdatu/cassandra/application/service/CassandraDaemonServiceImpl.java
 Fri Jan 14 13:57:40 2011
@@ -48,6 +48,9 @@
  * @author ivol
  */
 public class CassandraDaemonServiceImpl implements CassandraDaemonService {
+    // Timeout for the initial Thrift connection
+    private final int THRIFT_TIMEOUT = 120000;
+
     // The default placement strategy
     private final String DEFAULT_PLACEMENT_STRATEGY = 
"org.apache.cassandra.locator.SimpleStrategy";
 
@@ -293,7 +296,7 @@
     private void testThriftConnection() throws TTransportException {
         String thrift = m_configuration.getRPCAddress() + ":" + 
m_configuration.getRPCPort();
         m_logService.log(LogService.LOG_INFO, "Establishing Thrift connection 
to the Cassandra Daemon on " + thrift);
-        TTransport tr = new TSocket(m_configuration.getRPCAddress(), 
m_configuration.getRPCPort());
+        TTransport tr = new TSocket(m_configuration.getRPCAddress(), 
m_configuration.getRPCPort(), THRIFT_TIMEOUT);
         TProtocol proto = new TBinaryProtocol(tr);
         new Cassandra.Client(proto);
         tr.open();