Eclipse/jetty.project
1
0
Fork 0
mirror of https://github.com/jetty/jetty.project.git synced 2025-03-03 12:29:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

improved handling of RST

Browse Source
This commit is contained in:
Greg Wilkins 2011-11-09 15:07:47 +11:00
parent 70cd06f461
commit 71734400e9
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
jetty-io/src/main/java/org/eclipse/jetty/io/nio/ChannelEndPoint.java
View File

@ -114,10 +114,16 @@ public class ChannelEndPoint implements EndPoint
if (_channel instanceof SocketChannel)
{
Socket socket= ((SocketChannel)_channel).socket();
if (!socket.isInputShutdown())
socket.shutdownInput();
if(socket.isOutputShutdown())
close();
try
{
if (!socket.isInputShutdown())
socket.shutdownInput();
}
finally
{
if(socket.isOutputShutdown() && !socket.isClosed())
close();
}
}
else
close();
@ -139,17 +145,21 @@ public class ChannelEndPoint implements EndPoint
{
if (_channel instanceof SocketChannel)
{
Socket socket= ((SocketChannel)_channel).socket();
try
{
Socket socket= ((SocketChannel)_channel).socket();
if (!socket.isOutputShutdown())
socket.shutdownOutput();
if (socket.isInputShutdown())
close();
}
catch(SocketException e)
{
LOG.ignore(e);
LOG.warn(e.toString());
LOG.debug(e);
}
finally
{
if (socket.isInputShutdown() && !socket.isClosed())
close();
}
}
else