Author: cmccabe Date: Wed Nov 13 18:18:37 2013 New Revision: 1541647 URL: http://svn.apache.org/r1541647 Log: HDFS-5366. recaching improvements (cmccabe)
Modified: hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/nativeio/NativeIO.java Modified: hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/nativeio/NativeIO.java URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/nativeio/NativeIO.java?rev=1541647&r1=1541646&r2=1541647&view=diff ============================================================================== --- hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/nativeio/NativeIO.java (original) +++ hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/nativeio/NativeIO.java Wed Nov 13 18:18:37 2013 @@ -114,7 +114,17 @@ public class NativeIO { public static interface CacheTracker { public void fadvise(String identifier, long offset, long len, int flags); } - + + public static CacheManipulator cacheManipulator = new CacheManipulator(); + + @VisibleForTesting + public static class CacheManipulator { + public void mlock(String identifier, ByteBuffer buffer, + long len) throws IOException { + POSIX.mlock(buffer, len); + } + } + static { if (NativeCodeLoader.isNativeCodeLoaded()) { try { @@ -249,7 +259,7 @@ public class NativeIO { * * @throws NativeIOException */ - public static void mlock(ByteBuffer buffer, long len) + static void mlock(ByteBuffer buffer, long len) throws IOException { assertCodeLoaded(); if (!buffer.isDirect()) {