andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Converted 'SocketException: Socket closed' to ClosedChannelException (OIO sucks)

Browse Source
This commit is contained in:
Trustin Lee 2009-04-15 22:59:37 +00:00
parent a6fb8708ca
commit fb8e337293
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/org/jboss/netty/channel/socket/oio/OioWorker.java
View File

@ -26,6 +26,9 @@ import static org.jboss.netty.channel.Channels.*;
import java.io.OutputStream;
import java.io.PushbackInputStream;
import java.net.SocketException;
import java.nio.channels.ClosedChannelException;
import java.util.regex.Pattern;
import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBuffers;
@ -42,6 +45,9 @@ import org.jboss.netty.channel.ChannelFuture;
*/
class OioWorker implements Runnable {
private static final Pattern SOCKET_CLOSED_MESSAGE = Pattern.compile(
"^.*(?:Socket\\s*closed).*$", Pattern.CASE_INSENSITIVE);
private final OioSocketChannel channel;
OioWorker(OioSocketChannel channel) {
@ -121,6 +127,13 @@ class OioWorker implements Runnable {
fireWriteComplete(channel, bytes);
future.setSuccess();
} catch (Throwable t) {
// Convert 'SocketException: Socket closed' to
// ClosedChannelException.
if (t instanceof SocketException &&
SOCKET_CLOSED_MESSAGE.matcher(
String.valueOf(t.getMessage())).matches()) {
t = new ClosedChannelException();
}
future.setFailure(t);
fireExceptionCaught(channel, t);
}