hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

get config value clog_usage_limit_size for local store total disk space

Browse Source
This commit is contained in:
obdev
2021-07-19 16:12:13 +08:00
committed by wangzelin.wzl
parent 0557600717
commit af7df013e6
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/share/redolog/ob_log_file_store.cpp
View File

@ -16,6 +16,7 @@
#include "ob_log_file_store.h" #include "ob_log_file_store.h"
#include "lib/file/file_directory_utils.h" #include "lib/file/file_directory_utils.h"
#include "storage/blocksstable/ob_store_file_system.h" #include "storage/blocksstable/ob_store_file_system.h"
#include "share/config/ob_server_config.h"
namespace oceanbase { namespace oceanbase {
using namespace clog; using namespace clog;
@ -869,11 +870,17 @@ const char* ObLogFileStore::get_dir_name() const
int ObLogFileStore::get_total_disk_space(int64_t& total_space) const int ObLogFileStore::get_total_disk_space(int64_t& total_space) const
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
int64_t config_size = 0;
int64_t disk_size = 0;
if (IS_NOT_INIT) { if (IS_NOT_INIT) {
ret = OB_NOT_INIT; ret = OB_NOT_INIT;
COMMON_LOG(WARN, "not inited", K(ret)); COMMON_LOG(WARN, "not inited", K(ret));
} else if (OB_FAIL(disk_mgr_->get_total_disk_space(total_space))) { } else if (FALSE_IT(config_size = ObServerConfig::get_instance().clog_usage_limit_size)) {
// do nothing
} else if (OB_FAIL(disk_mgr_->get_total_disk_space(disk_size))) {
COMMON_LOG(ERROR, "get total disk space fail", K(ret)); COMMON_LOG(ERROR, "get total disk space fail", K(ret));
} else {
total_space = common::min(config_size, disk_size);
} }
return ret; return ret;
} }