提交 2526201d authored 作者: Thomas Mueller's avatar Thomas Mueller

Fix test case.

上级 1370b8c5
...@@ -51,7 +51,7 @@ public class TestConcurrent extends TestMVStore { ...@@ -51,7 +51,7 @@ public class TestConcurrent extends TestMVStore {
testConcurrentWrite(); testConcurrentWrite();
testConcurrentRead(); testConcurrentRead();
} }
private void testConcurrentStoreAndClose() throws InterruptedException { private void testConcurrentStoreAndClose() throws InterruptedException {
String fileName = getBaseDir() + "/testConcurrentStoreAndClose.h3"; String fileName = getBaseDir() + "/testConcurrentStoreAndClose.h3";
final MVStore s = openStore(fileName); final MVStore s = openStore(fileName);
...@@ -73,12 +73,12 @@ public class TestConcurrent extends TestMVStore { ...@@ -73,12 +73,12 @@ public class TestConcurrent extends TestMVStore {
// storing fails at some point // storing fails at some point
Thread.sleep(100); Thread.sleep(100);
Exception e = task.getException(); Exception e = task.getException();
assertEquals(DataUtils.ERROR_CLOSED, assertEquals(DataUtils.ERROR_CLOSED,
DataUtils.getErrorCode(e.getMessage())); DataUtils.getErrorCode(e.getMessage()));
} catch (IllegalStateException e) { } catch (IllegalStateException e) {
// sometimes storing works, in which case // sometimes storing works, in which case
// closing fails // closing fails
assertEquals(DataUtils.ERROR_WRITING_FAILED, assertEquals(DataUtils.ERROR_WRITING_FAILED,
DataUtils.getErrorCode(e.getMessage())); DataUtils.getErrorCode(e.getMessage()));
task.get(); task.get();
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论