You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/01/22 20:02:43 UTC
svn commit: r902220 -
/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
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())