Java 类org.apache.hadoop.io.nativeio.NativeIO.POSIX.CacheManipulator 实例源码

项目：hadoop 文件：TestEnhancedByteBufferAccess.java

@BeforeClass
public static void init() {
  sockDir = new TemporarySocketDirectory();
  DomainSocket.disableBindPathValidation();
  prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
  NativeIO.POSIX.setCacheManipulator(new CacheManipulator() {
    @Override
    public void mlock(String identifier,
        ByteBuffer mmap, long length) throws IOException {
      LOG.info("mlocking " + identifier);
    }
  });
}

项目：aliyun-oss-hadoop-fs 文件：TestEnhancedByteBufferAccess.java

@BeforeClass
public static void init() {
  sockDir = new TemporarySocketDirectory();
  DomainSocket.disableBindPathValidation();
  prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
  NativeIO.POSIX.setCacheManipulator(new CacheManipulator() {
    @Override
    public void mlock(String identifier,
        ByteBuffer mmap, long length) throws IOException {
      LOG.info("mlocking " + identifier);
    }
  });
}

项目：big-c 文件：TestEnhancedByteBufferAccess.java

@BeforeClass
public static void init() {
  sockDir = new TemporarySocketDirectory();
  DomainSocket.disableBindPathValidation();
  prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
  NativeIO.POSIX.setCacheManipulator(new CacheManipulator() {
    @Override
    public void mlock(String identifier,
        ByteBuffer mmap, long length) throws IOException {
      LOG.info("mlocking " + identifier);
    }
  });
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestEnhancedByteBufferAccess.java

@BeforeClass
public static void init() {
  sockDir = new TemporarySocketDirectory();
  DomainSocket.disableBindPathValidation();
  prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
  NativeIO.POSIX.setCacheManipulator(new CacheManipulator() {
    @Override
    public void mlock(String identifier,
        ByteBuffer mmap, long length) throws IOException {
      LOG.info("mlocking " + identifier);
    }
  });
}

项目：FlexMap 文件：TestEnhancedByteBufferAccess.java

@BeforeClass
public static void init() {
  sockDir = new TemporarySocketDirectory();
  DomainSocket.disableBindPathValidation();
  prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
  NativeIO.POSIX.setCacheManipulator(new CacheManipulator() {
    @Override
    public void mlock(String identifier,
        ByteBuffer mmap, long length) throws IOException {
      LOG.info("mlocking " + identifier);
    }
  });
}

项目：hadoop-on-lustre2 文件：TestEnhancedByteBufferAccess.java

@BeforeClass
public static void init() {
  sockDir = new TemporarySocketDirectory();
  DomainSocket.disableBindPathValidation();
  prevCacheManipulator = NativeIO.POSIX.getCacheManipulator();
  NativeIO.POSIX.setCacheManipulator(new CacheManipulator() {
    @Override
    public void mlock(String identifier,
        ByteBuffer mmap, long length) throws IOException {
      LOG.info("mlocking " + identifier);
    }
  });
}