svn commit: r835711 - /incubator/cassandra/trunk/src/java/org/apache/cassandra/net/TcpConnection.java

[jbellis]

Author: jbellis
Date: Fri Nov 13 02:34:31 2009
New Revision: 835711

URL: http://svn.apache.org/viewvc?rev=835711&view=rev
Log:
force bind to correct address
patch by jbellis; reviewed by Ray Slakinski for CASSANDRA-546

Modified:
    
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/TcpConnection.java

Modified: 
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/TcpConnection.java
URL: 
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/TcpConnection.java?rev=835711&r1=835710&r2=835711&view=diff
==============================================================================
--- 
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/TcpConnection.java 
(original)
+++ 
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/TcpConnection.java 
Fri Nov 13 02:34:31 2009
@@ -31,6 +31,7 @@
 import java.util.concurrent.locks.ReentrantLock;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
+import java.net.SocketAddress;
 
 import org.apache.cassandra.config.DatabaseDescriptor;
 import org.apache.cassandra.net.io.FastSerializer;
@@ -70,7 +71,9 @@
 
     private TcpConnection(InetAddress from, InetAddress to, 
TcpConnectionManager pool, boolean streaming) throws IOException
     {
+        logger_.debug("creating connection from " + from + " to " + to);
         socketChannel_ = SocketChannel.open();
+        socketChannel_.socket().bind(new InetSocketAddress(from, 0));
         socketChannel_.configureBlocking(false);
 
         localEp_ = from;