|
|
@ -72,6 +72,7 @@ public class DfsBlockCacheTest { |
|
|
|
resetCache(); |
|
|
|
resetCache(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@SuppressWarnings("resource") |
|
|
|
@Test |
|
|
|
@Test |
|
|
|
public void streamKeyReusesBlocks() throws Exception { |
|
|
|
public void streamKeyReusesBlocks() throws Exception { |
|
|
|
DfsRepositoryDescription repo = new DfsRepositoryDescription("test"); |
|
|
|
DfsRepositoryDescription repo = new DfsRepositoryDescription("test"); |
|
|
@ -98,6 +99,7 @@ public class DfsBlockCacheTest { |
|
|
|
assertEquals(oldSize, cache.getCurrentSize()); |
|
|
|
assertEquals(oldSize, cache.getCurrentSize()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@SuppressWarnings("resource") |
|
|
|
@Test |
|
|
|
@Test |
|
|
|
public void weirdBlockSize() throws Exception { |
|
|
|
public void weirdBlockSize() throws Exception { |
|
|
|
DfsRepositoryDescription repo = new DfsRepositoryDescription("test"); |
|
|
|
DfsRepositoryDescription repo = new DfsRepositoryDescription("test"); |
|
|
|