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

Better handling of InterruptedIOException in OIO Datagram

Browse Source
This commit is contained in:
Trustin Lee 2009-05-13 13:12:19 +00:00
parent 06586a6bfc
commit 64bfa6cfda
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java
View File

@ -24,6 +24,7 @@ package org.jboss.netty.channel.socket.oio;
import static org.jboss.netty.channel.Channels.*; import static org.jboss.netty.channel.Channels.*;
import java.io.InterruptedIOException;
import java.net.DatagramPacket; import java.net.DatagramPacket;
import java.net.MulticastSocket; import java.net.MulticastSocket;
import java.net.SocketAddress; import java.net.SocketAddress;
@ -76,6 +77,10 @@ class OioDatagramWorker implements Runnable {
DatagramPacket packet = new DatagramPacket(buf, buf.length); DatagramPacket packet = new DatagramPacket(buf, buf.length);
try { try {
socket.receive(packet); socket.receive(packet);
} catch (InterruptedIOException e) {
// Can happen on interruption.
// Keep receiving unless the channel is closed.
continue;
} catch (Throwable t) { } catch (Throwable t) {
if (!channel.socket.isClosed()) { if (!channel.socket.isClosed()) {
fireExceptionCaught(channel, t); fireExceptionCaught(channel, t);