9 * by Oracle in the LICENSE file that accompanied this code. 10 * 11 * This code is distributed in the hope that it will be useful, but WITHOUT 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 14 * version 2 for more details (a copy is included in the LICENSE file that 15 * accompanied this code). 16 * 17 * You should have received a copy of the GNU General Public License version 18 * 2 along with this work; if not, write to the Free Software Foundation, 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 20 * 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 22 * or visit www.oracle.com if you need additional information or have any 23 * questions. 24 */ 25 26 package sun.nio.fs; 27 28 import jdk.internal.misc.Unsafe; 29 import jdk.internal.ref.CleanerFactory; 30 31 import java.lang.ref.Cleaner; 32 33 /** 34 * A light-weight buffer in native memory. 35 */ 36 37 class NativeBuffer { 38 private static final Unsafe unsafe = Unsafe.getUnsafe(); 39 40 private final long address; 41 private final int size; 42 private final Cleaner.Cleanable cleanable; 43 44 // optional "owner" to avoid copying 45 // (only safe for use by thread-local caches) 46 private Object owner; 47 48 private static class Deallocator implements Runnable { 49 private final long address; 50 Deallocator(long address) { 51 this.address = address; 52 } 53 public void run() { 54 unsafe.freeMemory(address); 55 } 56 } 57 58 NativeBuffer(int size) { 59 this.address = unsafe.allocateMemory(size); 60 this.size = size; 61 this.cleanable = CleanerFactory.cleaner().register(this, new Deallocator(address)); 62 } 63 64 void release() { 65 NativeBuffers.releaseNativeBuffer(this); 66 } 67 68 long address() { 69 return address; 70 } 71 72 int size() { 73 return size; 74 } 75 76 void free() { 77 cleanable.clean(); 78 } 79 80 // not synchronized; only safe for use by thread-local caches 81 void setOwner(Object owner) { 82 this.owner = owner; 83 } 84 85 // not synchronized; only safe for use by thread-local caches 86 Object owner() { 87 return owner; 88 } 89 } | 9 * by Oracle in the LICENSE file that accompanied this code. 10 * 11 * This code is distributed in the hope that it will be useful, but WITHOUT 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 14 * version 2 for more details (a copy is included in the LICENSE file that 15 * accompanied this code). 16 * 17 * You should have received a copy of the GNU General Public License version 18 * 2 along with this work; if not, write to the Free Software Foundation, 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 20 * 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 22 * or visit www.oracle.com if you need additional information or have any 23 * questions. 24 */ 25 26 package sun.nio.fs; 27 28 import jdk.internal.misc.Unsafe; 29 import jdk.internal.ref.Cleaner; 30 31 /** 32 * A light-weight buffer in native memory. 33 */ 34 35 class NativeBuffer { 36 private static final Unsafe unsafe = Unsafe.getUnsafe(); 37 38 private final long address; 39 private final int size; 40 private final Cleaner cleaner; 41 42 // optional "owner" to avoid copying 43 // (only safe for use by thread-local caches) 44 private Object owner; 45 46 private static class Deallocator implements Runnable { 47 private final long address; 48 Deallocator(long address) { 49 this.address = address; 50 } 51 public void run() { 52 unsafe.freeMemory(address); 53 } 54 } 55 56 NativeBuffer(int size) { 57 this.address = unsafe.allocateMemory(size); 58 this.size = size; 59 this.cleaner = Cleaner.create(this, new Deallocator(address)); 60 } 61 62 void release() { 63 NativeBuffers.releaseNativeBuffer(this); 64 } 65 66 long address() { 67 return address; 68 } 69 70 int size() { 71 return size; 72 } 73 74 void free() { 75 cleaner.clean(); 76 } 77 78 // not synchronized; only safe for use by thread-local caches 79 void setOwner(Object owner) { 80 this.owner = owner; 81 } 82 83 // not synchronized; only safe for use by thread-local caches 84 Object owner() { 85 return owner; 86 } 87 } |