svn commit: r902220 - /incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java

[jbellis]

Author: jbellis
Date: Fri Jan 22 19:02:42 2010
New Revision: 902220

URL: http://svn.apache.org/viewvc?rev=902220&view=rev
Log:
move eofexception ST down to trace.  patch by jbellis for CASSANDRA-657

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

Modified: 
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
URL: 
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java?rev=902220&r1=902219&r2=902220&view=diff
==============================================================================
--- 
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
 (original)
+++ 
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
 Fri Jan 22 19:02:42 2010
@@ -1,9 +1,6 @@
 package org.apache.cassandra.net;
 
-import java.io.ByteArrayInputStream;
-import java.io.DataInputStream;
-import java.io.IOError;
-import java.io.IOException;
+import java.io.*;
 import java.net.Socket;
 import java.nio.ByteBuffer;
 
@@ -57,6 +54,12 @@
                     MessagingService.getDeserializationExecutor().submit(new 
MessageDeserializationTask(new ByteArrayInputStream(contentBytes)));
                 }
             }
+            catch (EOFException e)
+            {
+                if (logger.isTraceEnabled())
+                    logger.trace("error reading from socket; closing", e);
+                break;
+            }
             catch (IOException e)
             {
                 if (logger.isDebugEnabled())