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

Support double data config

Browse Source
This commit is contained in:
LINxiansheng
2022-03-16 14:37:44 +08:00
committed by LINxiansheng
parent 10d6b3b9ea
commit 5d8300bebf
1 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/share/config/ob_config_helper.cpp
View File

@ -336,38 +336,41 @@ int64_t ObConfigIntParser::get(const char* str, bool& valid)
int64_t ObConfigCapacityParser::get(const char* str, bool& valid) int64_t ObConfigCapacityParser::get(const char* str, bool& valid)
{ {
char* p_unit = NULL; char* p_unit = NULL;
double split_num = 0.0;
int64_t value = 0; int64_t value = 0;
if (OB_ISNULL(str) || '\0' == str[0]) { if (OB_ISNULL(str) || '\0' == str[0]) {
valid = false; valid = false;
} else { } else {
valid = true; valid = true;
value = strtol(str, &p_unit, 0); split_num = strtod(str, &p_unit);
if (OB_ISNULL(p_unit)) { if (OB_ISNULL(p_unit)) {
valid = false; valid = false;
} else if (value < 0) { } else if (split_num < 0) {
valid = false;
} else if ('.' == p_unit[0]){
valid = false; valid = false;
} else if ('\0' == *p_unit) { } else if ('\0' == *p_unit) {
value <<= CAP_MB; // default split_num *= (int64_t)1<<CAP_MB; // default
} else if (0 == STRCASECMP("b", p_unit) || 0 == STRCASECMP("byte", p_unit)) { } else if (0 == STRCASECMP("b", p_unit) || 0 == STRCASECMP("byte", p_unit)) {
// do nothing // do nothing
} else if (0 == STRCASECMP("kb", p_unit) || 0 == STRCASECMP("k", p_unit)) { } else if (0 == STRCASECMP("kb", p_unit) || 0 == STRCASECMP("k", p_unit)) {
value <<= CAP_KB; split_num *= (int64_t)1<<CAP_KB;
} else if (0 == STRCASECMP("mb", p_unit) || 0 == STRCASECMP("m", p_unit)) { } else if (0 == STRCASECMP("mb", p_unit) || 0 == STRCASECMP("m", p_unit)) {
value <<= CAP_MB; split_num *= (int64_t)1<<CAP_MB;
} else if (0 == STRCASECMP("gb", p_unit) || 0 == STRCASECMP("g", p_unit)) { } else if (0 == STRCASECMP("gb", p_unit) || 0 == STRCASECMP("g", p_unit)) {
value <<= CAP_GB; split_num *= (int64_t)1<<CAP_GB;
} else if (0 == STRCASECMP("tb", p_unit) || 0 == STRCASECMP("t", p_unit)) { } else if (0 == STRCASECMP("tb", p_unit) || 0 == STRCASECMP("t", p_unit)) {
value <<= CAP_TB; split_num *= (int64_t)1<<CAP_TB;
} else if (0 == STRCASECMP("pb", p_unit) || 0 == STRCASECMP("p", p_unit)) { } else if (0 == STRCASECMP("pb", p_unit) || 0 == STRCASECMP("p", p_unit)) {
value <<= CAP_PB; split_num *= (int64_t)1<<CAP_PB;
} else { } else {
valid = false; valid = false;
OB_LOG(ERROR, "set capacity error", K(str), K(p_unit)); OB_LOG(ERROR, "set capacity error", K(str), K(p_unit));
} }
} }
// 0.xxx bit is insignificant, lose the data after point
value = floor(split_num);
return value; return value;
} }