cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r902220 - /incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
Date Fri, 22 Jan 2010 19:02:43 GMT
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())



Mime
View raw message