Skip to content

R
Rocketmq

s920243400 / Rocketmq
与 Fork 源项目一致

Fork自 Apache RocketMQ / Rocketmq

通知 1
Star 1
Fork 0
R
Rocketmq
提交 9176e057 编写于 作者: Q qqeasonchen
浏览文件
操作

unit test of isSpaceFull function

上级 dcb7c081
隐藏空白更改
内联 并排
Showing with 2 addition and 2 deletion
store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
浏览文件 @ 9176e057
...@@ -70,7 +70,7 @@ public class DefaultMessageStoreCleanFilesTest { ...@@ -70,7 +70,7 @@ public class DefaultMessageStoreCleanFilesTest {
String deleteWhen = "04"; String deleteWhen = "04";
// the min value of diskMaxUsedSpaceRatio. // the min value of diskMaxUsedSpaceRatio.
int diskMaxUsedSpaceRatio = 1; int diskMaxUsedSpaceRatio = 1;
// used to ensure set diskfull flag // used to set disk-full flag
double diskSpaceCleanForciblyRatio = 0.01D; double diskSpaceCleanForciblyRatio = 0.01D;
initMessageStore(deleteWhen, diskMaxUsedSpaceRatio, diskSpaceCleanForciblyRatio); initMessageStore(deleteWhen, diskMaxUsedSpaceRatio, diskSpaceCleanForciblyRatio);
// build and put 55 messages, exactly one message per CommitLog file. // build and put 55 messages, exactly one message per CommitLog file.
...@@ -92,7 +92,7 @@ public class DefaultMessageStoreCleanFilesTest { ...@@ -92,7 +92,7 @@ public class DefaultMessageStoreCleanFilesTest {
String deleteWhen = "04"; String deleteWhen = "04";
// the min value of diskMaxUsedSpaceRatio. // the min value of diskMaxUsedSpaceRatio.
int diskMaxUsedSpaceRatio = 1; int diskMaxUsedSpaceRatio = 1;
//use to reset diskfull flag //use to reset disk-full flag
double diskSpaceCleanForciblyRatio = 0.999D; double diskSpaceCleanForciblyRatio = 0.999D;
initMessageStore(deleteWhen, diskMaxUsedSpaceRatio, diskSpaceCleanForciblyRatio); initMessageStore(deleteWhen, diskMaxUsedSpaceRatio, diskSpaceCleanForciblyRatio);
//set disk full //set disk full
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或