stan/jdk-24
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

7034155: (ch) NullPointerException in sun.io.ch.IOUtil when OOM is thrown

Browse Source 
Reviewed-by: forax
This commit is contained in:
Alan Bateman 2011-04-06 20:51:55 +01:00
parent fad93836a2
commit 4926951ba8
2 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
jdk/src/share/classes/sun/nio/ch/DatagramChannelImpl.java
View File

@ -388,9 +388,8 @@ class DatagramChannelImpl
// we must instead use a nonempty buffer, otherwise the call
// will not block waiting for a datagram on some platforms.
int newSize = Math.max(rem, 1);
ByteBuffer bb = null;
ByteBuffer bb = Util.getTemporaryDirectBuffer(newSize);
try {
bb = Util.getTemporaryDirectBuffer(newSize);
int n = receiveIntoNativeBuffer(fd, bb, newSize, 0);
bb.flip();
if (n > 0 && rem > 0)
@ -482,9 +481,8 @@ class DatagramChannelImpl
assert (pos <= lim);
int rem = (pos <= lim ? lim - pos : 0);
ByteBuffer bb = null;
ByteBuffer bb = Util.getTemporaryDirectBuffer(rem);
try {
bb = Util.getTemporaryDirectBuffer(rem);
bb.put(src);
bb.flip();
// Do not update src until we see how many bytes were written
@ -766,10 +764,10 @@ class DatagramChannelImpl
// check multicast address is compatible with this socket
if (group instanceof Inet4Address) {
if (family == StandardProtocolFamily.INET6 && !Net.canIPv6SocketJoinIPv4Group())
throw new IllegalArgumentException("Group is not IPv4 multicast address");
throw new IllegalArgumentException("IPv6 socket cannot join IPv4 multicast group");
} else if (group instanceof Inet6Address) {
if (family != StandardProtocolFamily.INET6)
throw new IllegalArgumentException("Group is not IPv6 multicast address");
throw new IllegalArgumentException("Only IPv6 sockets can join IPv6 multicast group");
} else {
throw new IllegalArgumentException("Address type not supported");
}

6
jdk/src/share/classes/sun/nio/ch/IOUtil.java
View File

@ -50,9 +50,8 @@ class IOUtil {
int lim = src.limit();
assert (pos <= lim);
int rem = (pos <= lim ? lim - pos : 0);
ByteBuffer bb = null;
ByteBuffer bb = Util.getTemporaryDirectBuffer(rem);
try {
bb = Util.getTemporaryDirectBuffer(rem);
bb.put(src);
bb.flip();
// Do not update src until we see how many bytes were written
@ -187,9 +186,8 @@ class IOUtil {
return readIntoNativeBuffer(fd, dst, position, nd, lock);
// Substitute a native buffer
ByteBuffer bb = null;
ByteBuffer bb = Util.getTemporaryDirectBuffer(dst.remaining());
try {
bb = Util.getTemporaryDirectBuffer(dst.remaining());
int n = readIntoNativeBuffer(fd, bb, position, nd, lock);
bb.flip();
if (n > 0)