Author: jbellis
Date: Tue Sep 7 17:16:14 2010
New Revision: 993436
URL: http://svn.apache.org/viewvc?rev=993436&view=rev
Log:
add start() calls to OTC objects; fixes regression for CASSANDRA-1465
Modified:
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
Modified:
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java?rev=993436&r1=993435&r2=993436&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
(original)
+++
cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java
Tue Sep 7 17:16:14 2010
@@ -29,8 +29,10 @@ class OutboundTcpConnectionPool
OutboundTcpConnectionPool(InetAddress remoteEp)
{
- cmdCon = new OutboundTcpConnection(remoteEp);
- ackCon = new OutboundTcpConnection(remoteEp);
+ cmdCon = new OutboundTcpConnection(remoteEp);
+ cmdCon.start();
+ ackCon = new OutboundTcpConnection(remoteEp);
+ ackCon.start();
}
/**
