jdk-sandbox: comparison jdk/src/share/classes/sun/nio/ch/IOUtil.java

equal deleted inserted replaced

-:115e09b7a004
+:3acf8e5e2ca0
 /*
-* Copyright 2000-2002 Sun Microsystems, Inc.  All Rights Reserved.
+* Copyright 2000-2009 Sun Microsystems, Inc.  All Rights Reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 * published by the Free Software Foundation.  Sun designates this
 package sun.nio.ch;
 import java.io.FileDescriptor;
 import java.io.IOException;
-import java.net.*;
 import java.nio.ByteBuffer;
-import java.nio.channels.*;
-import java.nio.channels.spi.*;
 /**
 * File-descriptor based I/O utilities that are shared by NIO classes.
 */
 * Returns the index of first buffer in bufs with remaining,
 * or -1 if there is nothing left
 */
 private static int remaining(ByteBuffer[] bufs) {
 int numBufs = bufs.length;
-boolean remaining = false;
 for (int i=0; i<numBufs; i++) {
 if (bufs[i].hasRemaining()) {
 return i;
 }
 }
 // If some bufs are empty we should skip them
 if (nextWithRemaining > 0)
 bufs = skipBufs(bufs, nextWithRemaining);
 int numBufs = bufs.length;
-int bytesReadyToWrite = 0;
 // Create shadow to ensure DirectByteBuffers are used
 ByteBuffer[] shadow = new ByteBuffer[numBufs];
-for (int i=0; i<numBufs; i++) {
+try {
-if (!(bufs[i] instanceof DirectBuffer)) {
+for (int i=0; i<numBufs; i++) {
-int pos = bufs[i].position();
+if (!(bufs[i] instanceof DirectBuffer)) {
-int lim = bufs[i].limit();
+int pos = bufs[i].position();
+int lim = bufs[i].limit();
+assert (pos <= lim);
+int rem = (pos <= lim ? lim - pos : 0);
+ByteBuffer bb = Util.getTemporaryDirectBuffer(rem);
+shadow[i] = bb;
+// Leave slow buffer position untouched; it will be updated
+// after we see how many bytes were really written out
+bb.put(bufs[i]);
+bufs[i].position(pos);
+bb.flip();
+} else {
+shadow[i] = bufs[i];
+}
+}
+IOVecWrapper vec = null;
+long bytesWritten = 0;
+try {
+// Create a native iovec array
+vec= new IOVecWrapper(numBufs);
+// Fill in the iovec array with appropriate data
+for (int i=0; i<numBufs; i++) {
+ByteBuffer nextBuffer = shadow[i];
+// put in the buffer addresses
+long pos = nextBuffer.position();
+long len = nextBuffer.limit() - pos;
+vec.putBase(i, ((DirectBuffer)nextBuffer).address() + pos);
+vec.putLen(i, len);
+}
+// Invoke native call to fill the buffers
+bytesWritten = nd.writev(fd, vec.address, numBufs);
+} finally {
+vec.free();
+}
+long returnVal = bytesWritten;
+// Notify the buffers how many bytes were taken
+for (int i=0; i<numBufs; i++) {
+ByteBuffer nextBuffer = bufs[i];
+int pos = nextBuffer.position();
+int lim = nextBuffer.limit();
 assert (pos <= lim);
-int rem = (pos <= lim ? lim - pos : 0);
+int len = (pos <= lim ? lim - pos : lim);
+if (bytesWritten >= len) {
-ByteBuffer bb = ByteBuffer.allocateDirect(rem);
+bytesWritten -= len;
-shadow[i] = bb;
+int newPosition = pos + len;
-// Leave slow buffer position untouched; it will be updated
+nextBuffer.position(newPosition);
-// after we see how many bytes were really written out
+} else { // Buffers not completely filled
-bb.put(bufs[i]);
+if (bytesWritten > 0) {
-bufs[i].position(pos);
+assert(pos + bytesWritten < (long)Integer.MAX_VALUE);
-bb.flip();
+int newPosition = (int)(pos + bytesWritten);
-} else {
+nextBuffer.position(newPosition);
-shadow[i] = bufs[i];
+}
-}
+break;
 }
+}
-IOVecWrapper vec = null;
+return returnVal;
-long bytesWritten = 0;
-try {
-// Create a native iovec array
-vec= new IOVecWrapper(numBufs);
-// Fill in the iovec array with appropriate data
-for (int i=0; i<numBufs; i++) {
-ByteBuffer nextBuffer = shadow[i];
-// put in the buffer addresses
-long pos = nextBuffer.position();
-long len = nextBuffer.limit() - pos;
-bytesReadyToWrite += len;
-vec.putBase(i, ((DirectBuffer)nextBuffer).address() + pos);
-vec.putLen(i, len);
-}
-// Invoke native call to fill the buffers
-bytesWritten = nd.writev(fd, vec.address, numBufs);
 } finally {
-vec.free();
+// return any substituted buffers to cache
-}
+for (int i=0; i<numBufs; i++) {
-long returnVal = bytesWritten;
+ByteBuffer bb = shadow[i];
+if (bb != null && bb != bufs[i]) {
-// Notify the buffers how many bytes were taken
+Util.releaseTemporaryDirectBuffer(bb);
-for (int i=0; i<numBufs; i++) {
+}
-ByteBuffer nextBuffer = bufs[i];
+}
-int pos = nextBuffer.position();
+}
-int lim = nextBuffer.limit();
-assert (pos <= lim);
-int len = (pos <= lim ? lim - pos : lim);
-if (bytesWritten >= len) {
-bytesWritten -= len;
-int newPosition = pos + len;
-nextBuffer.position(newPosition);
-} else { // Buffers not completely filled
-if (bytesWritten > 0) {
-assert(pos + bytesWritten < (long)Integer.MAX_VALUE);
-int newPosition = (int)(pos + bytesWritten);
-nextBuffer.position(newPosition);
-}
-break;
-}
-}
-return returnVal;
 }
 static int read(FileDescriptor fd, ByteBuffer dst, long position,
 NativeDispatcher nd, Object lock)
 throws IOException
 int numBufs = bufs.length;
 // Read into the shadow to ensure DirectByteBuffers are used
 ByteBuffer[] shadow = new ByteBuffer[numBufs];
-for (int i=0; i<numBufs; i++) {
+boolean usingSlowBuffers = false;
-if (bufs[i].isReadOnly())
-throw new IllegalArgumentException("Read-only buffer");
-if (!(bufs[i] instanceof DirectBuffer)) {
-shadow[i] = ByteBuffer.allocateDirect(bufs[i].remaining());
-} else {
-shadow[i] = bufs[i];
-}
-}
-IOVecWrapper vec = null;
-long bytesRead = 0;
 try {
-// Create a native iovec array
+for (int i=0; i<numBufs; i++) {
-vec = new IOVecWrapper(numBufs);
+if (bufs[i].isReadOnly())
+throw new IllegalArgumentException("Read-only buffer");
-// Fill in the iovec array with appropriate data
+if (!(bufs[i] instanceof DirectBuffer)) {
+shadow[i] = Util.getTemporaryDirectBuffer(bufs[i].remaining());
+usingSlowBuffers = true;
+} else {
+shadow[i] = bufs[i];
+}
+}
+IOVecWrapper vec = null;
+long bytesRead = 0;
+try {
+// Create a native iovec array
+vec = new IOVecWrapper(numBufs);
+// Fill in the iovec array with appropriate data
+for (int i=0; i<numBufs; i++) {
+ByteBuffer nextBuffer = shadow[i];
+// put in the buffer addresses
+long pos = nextBuffer.position();
+long len = nextBuffer.remaining();
+vec.putBase(i, ((DirectBuffer)nextBuffer).address() + pos);
+vec.putLen(i, len);
+}
+// Invoke native call to fill the buffers
+bytesRead = nd.readv(fd, vec.address, numBufs);
+} finally {
+vec.free();
+}
+long returnVal = bytesRead;
+// Notify the buffers how many bytes were read
 for (int i=0; i<numBufs; i++) {
 ByteBuffer nextBuffer = shadow[i];
-// put in the buffer addresses
+// Note: should this have been cached from above?
-long pos = nextBuffer.position();
+int pos = nextBuffer.position();
-long len = nextBuffer.remaining();
+int len = nextBuffer.remaining();
-vec.putBase(i, ((DirectBuffer)nextBuffer).address() + pos);
+if (bytesRead >= len) {
-vec.putLen(i, len);
+bytesRead -= len;
-}
+int newPosition = pos + len;
+nextBuffer.position(newPosition);
-// Invoke native call to fill the buffers
+} else { // Buffers not completely filled
-bytesRead = nd.readv(fd, vec.address, numBufs);
+if (bytesRead > 0) {
+assert(pos + bytesRead < (long)Integer.MAX_VALUE);
+int newPosition = (int)(pos + bytesRead);
+nextBuffer.position(newPosition);
+}
+break;
+}
+}
+// Put results from shadow into the slow buffers
+if (usingSlowBuffers) {
+for (int i=0; i<numBufs; i++) {
+if (!(bufs[i] instanceof DirectBuffer)) {
+shadow[i].flip();
+bufs[i].put(shadow[i]);
+}
+}
+}
+return returnVal;
 } finally {
-vec.free();
+// return any substituted buffers to cache
-}
+if (usingSlowBuffers) {
-long returnVal = bytesRead;
+for (int i=0; i<numBufs; i++) {
+ByteBuffer bb = shadow[i];
-// Notify the buffers how many bytes were read
+if (bb != null && bb != bufs[i]) {
-for (int i=0; i<numBufs; i++) {
+Util.releaseTemporaryDirectBuffer(bb);
-ByteBuffer nextBuffer = shadow[i];
+}
-// Note: should this have been cached from above?
+}
-int pos = nextBuffer.position();
+}
-int len = nextBuffer.remaining();
+}
-if (bytesRead >= len) {
-bytesRead -= len;
-int newPosition = pos + len;
-nextBuffer.position(newPosition);
-} else { // Buffers not completely filled
-if (bytesRead > 0) {
-assert(pos + bytesRead < (long)Integer.MAX_VALUE);
-int newPosition = (int)(pos + bytesRead);
-nextBuffer.position(newPosition);
-}
-break;
-}
-}
-// Put results from shadow into the slow buffers
-for (int i=0; i<numBufs; i++) {
-if (!(bufs[i] instanceof DirectBuffer)) {
-shadow[i].flip();
-bufs[i].put(shadow[i]);
-}
-}
-return returnVal;
 }
 static FileDescriptor newFD(int i) {
 FileDescriptor fd = new FileDescriptor();
 setfdVal(fd, i);

changeset 2057	3acf8e5e2ca0
parent 2	90ce3da70b43
child 5506	202f599c92aa