Java 类org.apache.hadoop.hbase.io.hfile.CacheTestUtils 实例源码

@Test
public void testMemoryLeak() throws Exception {
  final BlockCacheKey cacheKey = new BlockCacheKey("dummy", 1L);
  cacheAndWaitUntilFlushedToBucket(cache, cacheKey, new CacheTestUtils.ByteArrayCacheable(
      new byte[10]));
  long lockId = cache.backingMap.get(cacheKey).offset();
  ReentrantReadWriteLock lock = cache.offsetLock.getLock(lockId);
  lock.writeLock().lock();
  Thread evictThread = new Thread("evict-block") {

    @Override
    public void run() {
      cache.evictBlock(cacheKey);
    }

  };
  evictThread.start();
  cache.offsetLock.waitForWaiters(lockId, 1);
  cache.blockEvicted(cacheKey, cache.backingMap.remove(cacheKey), true);
  cacheAndWaitUntilFlushedToBucket(cache, cacheKey, new CacheTestUtils.ByteArrayCacheable(
      new byte[10]));
  lock.writeLock().unlock();
  evictThread.join();
  assertEquals(1L, cache.getBlockCount());
  assertTrue(cache.getCurrentSize() > 0L);
  assertTrue("We should have a block!", cache.iterator().hasNext());
}

@Test
public void testMemoryLeak() throws Exception {
  final BlockCacheKey cacheKey = new BlockCacheKey("dummy", 1L);
  cacheAndWaitUntilFlushedToBucket(cache, cacheKey, new CacheTestUtils.ByteArrayCacheable(
      new byte[10]));
  long lockId = cache.backingMap.get(cacheKey).offset();
  ReentrantReadWriteLock lock = cache.offsetLock.getLock(lockId);
  lock.writeLock().lock();
  Thread evictThread = new Thread("evict-block") {

    @Override
    public void run() {
      cache.evictBlock(cacheKey);
    }

  };
  evictThread.start();
  cache.offsetLock.waitForWaiters(lockId, 1);
  cache.blockEvicted(cacheKey, cache.backingMap.remove(cacheKey), true);
  cacheAndWaitUntilFlushedToBucket(cache, cacheKey, new CacheTestUtils.ByteArrayCacheable(
      new byte[10]));
  lock.writeLock().unlock();
  evictThread.join();
  assertEquals(1L, cache.getBlockCount());
  assertTrue(cache.getCurrentSize() > 0L);
  assertTrue("We should have a block!", cache.iterator().hasNext());
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, 2 * NUM_THREADS, 2 * NUM_QUERIES);
}

@Test
public void testHeapSizeChanges() throws Exception {
  cache.stopWriterThreads();
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreaded() throws Exception {
  CacheTestUtils.testCacheMultiThreaded(cache, BLOCK_SIZE, NUM_THREADS,
      NUM_QUERIES, 0.80);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedEviction() throws Exception {
  CacheTestUtils.hammerEviction(cache, BLOCK_SIZE, 10, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges(){
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreaded() throws Exception {
  CacheTestUtils.testCacheMultiThreaded(cache, BLOCK_SIZE,
      NUM_THREADS, NUM_QUERIES, 0.80);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedEviction() throws Exception {
  CacheTestUtils.hammerEviction(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges(){
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges() throws Exception {
  cache.stopWriterThreads();
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges() throws Exception {
  cache.stopWriterThreads();
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreaded() throws Exception {
  CacheTestUtils.testCacheMultiThreaded(cache, BLOCK_SIZE, NUM_THREADS,
      NUM_QUERIES, 0.80);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedEviction() throws Exception {
  CacheTestUtils.hammerEviction(cache, BLOCK_SIZE, 10, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges(){
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreaded() throws Exception {
  CacheTestUtils.testCacheMultiThreaded(cache, BLOCK_SIZE,
      NUM_THREADS, NUM_QUERIES, 0.80);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedEviction() throws Exception {
  CacheTestUtils.hammerEviction(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges(){
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreaded() throws Exception {
  CacheTestUtils.testCacheMultiThreaded(cache, BLOCK_SIZE, NUM_THREADS,
      NUM_QUERIES, 0.80);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedEviction() throws Exception {
  CacheTestUtils.hammerEviction(cache, BLOCK_SIZE, 10, NUM_QUERIES);
}

@Test
public void testHeapSizeChanges(){
  CacheTestUtils.testHeapSizeChanges(cache, BLOCK_SIZE);
}

@Test
public void testCacheSimple() throws Exception {
  CacheTestUtils.testCacheSimple(cache, BLOCK_SIZE, NUM_QUERIES);
}

@Test
public void testCacheMultiThreaded() throws Exception {
  CacheTestUtils.testCacheMultiThreaded(cache, BLOCK_SIZE,
      NUM_THREADS, NUM_QUERIES, 0.80);
}

@Test
public void testCacheMultiThreadedSingleKey() throws Exception {
  CacheTestUtils.hammerSingleKey(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}

@Test
public void testCacheMultiThreadedEviction() throws Exception {
  CacheTestUtils.hammerEviction(cache, BLOCK_SIZE, NUM_THREADS, NUM_QUERIES);
}