archive/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2025-08-27 23:04:50 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

8204233: Add configurable option for enhanced socket IOException messages

Browse source 
Reviewed-by: alanb, chegar
This commit is contained in:
Michael McMahon 2018-06-22 18:10:20 +01:00
parent 7d4135b630
commit 1d79d38007
7 changed files with 269 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/java.base/windows/classes/sun/nio/ch/WindowsAsynchronousSocketChannelImpl.java
View file

@ -35,6 +35,7 @@ import java.security.AccessController;
import java.security.PrivilegedActionException;
import java.security.PrivilegedExceptionAction;
import jdk.internal.misc.Unsafe;
import sun.net.util.SocketExceptions;
/**
* Windows implementation of AsynchronousSocketChannel using overlapped I/O.
@ -253,7 +254,8 @@ class WindowsAsynchronousSocketChannelImpl
if (exc != null) {
closeChannel();
result.setFailure(toIOException(exc));
exc = SocketExceptions.of(toIOException(exc), remote);
result.setFailure(exc);
}
Invoker.invoke(result);
}
@ -278,7 +280,9 @@ class WindowsAsynchronousSocketChannelImpl
// can't close channel while in begin/end block
if (exc != null) {
closeChannel();
result.setFailure(toIOException(exc));
IOException ee = toIOException(exc);
ee = SocketExceptions.of(ee, remote);
result.setFailure(ee);
}
if (canInvokeDirect) {
@ -293,11 +297,13 @@ class WindowsAsynchronousSocketChannelImpl
*/
@Override
public void failed(int error, IOException x) {
x = SocketExceptions.of(x, remote);
if (isOpen()) {
closeChannel();
result.setFailure(x);
} else {
result.setFailure(new AsynchronousCloseException());
x = SocketExceptions.of(new AsynchronousCloseException(), remote);
result.setFailure(x);
}
Invoker.invoke(result);
}