未验证 提交 2f14aa50 编写于 作者: 张旭 提交者: GitHub

[ISSUE #2280] Disk ratio return -1.0 when cluster deployed on DLedger mode

上级 ba5e0e52
...@@ -804,13 +804,22 @@ public class DefaultMessageStore implements MessageStore { ...@@ -804,13 +804,22 @@ public class DefaultMessageStore implements MessageStore {
return this.storeStatsService.toString(); return this.storeStatsService.toString();
} }
private String getStorePathPhysic() {
String storePathPhysic = "";
if (DefaultMessageStore.this.getMessageStoreConfig().isEnableDLegerCommitLog()) {
storePathPhysic = ((DLedgerCommitLog)DefaultMessageStore.this.getCommitLog()).getdLedgerServer().getdLedgerConfig().getDataStorePath();
} else {
storePathPhysic = DefaultMessageStore.this.getMessageStoreConfig().getStorePathCommitLog();
}
return storePathPhysic;
}
@Override @Override
public HashMap<String, String> getRuntimeInfo() { public HashMap<String, String> getRuntimeInfo() {
HashMap<String, String> result = this.storeStatsService.getRuntimeInfo(); HashMap<String, String> result = this.storeStatsService.getRuntimeInfo();
{ {
String storePathPhysic = DefaultMessageStore.this.getMessageStoreConfig().getStorePathCommitLog(); double physicRatio = UtilAll.getDiskPartitionSpaceUsedPercent(getStorePathPhysic());
double physicRatio = UtilAll.getDiskPartitionSpaceUsedPercent(storePathPhysic);
result.put(RunningStats.commitLogDiskRatio.name(), String.valueOf(physicRatio)); result.put(RunningStats.commitLogDiskRatio.name(), String.valueOf(physicRatio));
} }
...@@ -1676,8 +1685,7 @@ public class DefaultMessageStore implements MessageStore { ...@@ -1676,8 +1685,7 @@ public class DefaultMessageStore implements MessageStore {
cleanImmediately = false; cleanImmediately = false;
{ {
String storePathPhysic = DefaultMessageStore.this.getMessageStoreConfig().getStorePathCommitLog(); double physicRatio = UtilAll.getDiskPartitionSpaceUsedPercent(getStorePathPhysic());
double physicRatio = UtilAll.getDiskPartitionSpaceUsedPercent(storePathPhysic);
if (physicRatio > diskSpaceWarningLevelRatio) { if (physicRatio > diskSpaceWarningLevelRatio) {
boolean diskok = DefaultMessageStore.this.runningFlags.getAndMakeDiskFull(); boolean diskok = DefaultMessageStore.this.runningFlags.getAndMakeDiskFull();
if (diskok) { if (diskok) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册