Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-11642. Block Storage: fix TestCBlockCLI and TestCBlockServerPersistence cleanup. Contributed by Xiaoyu Yao.

This commit is contained in:
Chen Liang 2017-04-12 12:09:10 -07:00
parent f4dec00896
commit cedacf12c9
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/cblock/TestCBlockServer.java
View File

@ -46,6 +46,7 @@ public class TestCBlockServer {
ScmClient storageClient = new MockStorageClient(); ScmClient storageClient = new MockStorageClient();
conf = new OzoneConfiguration(); conf = new OzoneConfiguration();
cBlockManager = new CBlockManager(conf, storageClient); cBlockManager = new CBlockManager(conf, storageClient);
cBlockManager.start();
} }
@AfterClass @AfterClass

5
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/cblock/TestCBlockServerPersistence.java
View File

@ -66,6 +66,7 @@ public class TestCBlockServerPersistence {
try { try {
ScmClient storageClient = new MockStorageClient(); ScmClient storageClient = new MockStorageClient();
cBlockManager = new CBlockManager(conf, storageClient); cBlockManager = new CBlockManager(conf, storageClient);
cBlockManager.start();
cBlockManager.createVolume(userName, volumeName1, volumeSize1, blockSize); cBlockManager.createVolume(userName, volumeName1, volumeSize1, blockSize);
cBlockManager.createVolume(userName, volumeName2, volumeSize2, blockSize); cBlockManager.createVolume(userName, volumeName2, volumeSize2, blockSize);
List<VolumeDescriptor> allVolumes = cBlockManager.getAllVolumes(); List<VolumeDescriptor> allVolumes = cBlockManager.getAllVolumes();
@ -86,6 +87,7 @@ public class TestCBlockServerPersistence {
conf1.set(DFS_CBLOCK_SERVICE_LEVELDB_PATH_KEY, path.concat( conf1.set(DFS_CBLOCK_SERVICE_LEVELDB_PATH_KEY, path.concat(
"/testCblockPersistence.dat")); "/testCblockPersistence.dat"));
cBlockManager1 = new CBlockManager(conf1, storageClient1); cBlockManager1 = new CBlockManager(conf1, storageClient1);
cBlockManager1.start();
List<VolumeDescriptor> allVolumes1 = cBlockManager1.getAllVolumes(); List<VolumeDescriptor> allVolumes1 = cBlockManager1.getAllVolumes();
assertEquals(2, allVolumes1.size()); assertEquals(2, allVolumes1.size());
VolumeDescriptor newvolumeDescriptor1 = allVolumes1.get(0); VolumeDescriptor newvolumeDescriptor1 = allVolumes1.get(0);
@ -113,6 +115,9 @@ public class TestCBlockServerPersistence {
cBlockManager.clean(); cBlockManager.clean();
} }
if (cBlockManager1 != null) { if (cBlockManager1 != null) {
cBlockManager1.close();
cBlockManager1.stop();
cBlockManager1.join();
cBlockManager1.clean(); cBlockManager1.clean();
} }
} }