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

sys var placeholder & session serialize placeholder

Browse Source
This commit is contained in:
obdev
2024-02-06 17:40:44 +00:00
committed by ob-robot
parent 47a7736874
commit c492fbfe51
8 changed files with 144 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
src/share/system_variable/ob_system_variable_factory.cpp
View File

@ -123,6 +123,7 @@ const char *ObSysVarParallelDegreePolicy::PARALLEL_DEGREE_POLICY_NAMES[] = {
};
const char *ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME[] = {
"_affected_rows",
"_aggregation_optimization_settings",
"_clear_last_archive_timestamp",
"_create_audit_purge_job",
@ -136,6 +137,7 @@ const char *ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME[] = {
"_force_parallel_ddl_dop",
"_force_parallel_dml_dop",
"_force_parallel_query_dop",
"_found_rows",
"_groupby_nopushdown_cut_ratio",
"_nlj_batching_enabled",
"_ob_ols_policy_session_labels",
@ -369,6 +371,7 @@ const char *ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_NAME[] = {
};
const ObSysVarClassType ObSysVarFactory::SYS_VAR_IDS_SORTED_BY_NAME[] = {
SYS_VAR__AFFECTED_ROWS,
SYS_VAR__AGGREGATION_OPTIMIZATION_SETTINGS,
SYS_VAR__CLEAR_LAST_ARCHIVE_TIMESTAMP,
SYS_VAR__CREATE_AUDIT_PURGE_JOB,
@ -382,6 +385,7 @@ const ObSysVarClassType ObSysVarFactory::SYS_VAR_IDS_SORTED_BY_NAME[] = {
SYS_VAR__FORCE_PARALLEL_DDL_DOP,
SYS_VAR__FORCE_PARALLEL_DML_DOP,
SYS_VAR__FORCE_PARALLEL_QUERY_DOP,
SYS_VAR__FOUND_ROWS,
SYS_VAR__GROUPBY_NOPUSHDOWN_CUT_RATIO,
SYS_VAR__NLJ_BATCHING_ENABLED,
SYS_VAR__OB_OLS_POLICY_SESSION_LABELS,
@ -857,7 +861,9 @@ const char *ObSysVarFactory::SYS_VAR_NAMES_SORTED_BY_ID[] = {
"ob_enable_pl_cache",
"ob_default_lob_inrow_threshold",
"_enable_storage_cardinality_estimation",
"lc_time_names"
"lc_time_names",
"_affected_rows",
"_found_rows"
};
bool ObSysVarFactory::sys_var_name_case_cmp(const char *name1, const ObString &name2)
@ -1269,6 +1275,8 @@ int ObSysVarFactory::create_all_sys_vars()
+ sizeof(ObSysVarObDefaultLobInrowThreshold)
+ sizeof(ObSysVarEnableStorageCardinalityEstimation)
+ sizeof(ObSysVarLcTimeNames)
+ sizeof(ObSysVarAffectedRows)
+ sizeof(ObSysVarFoundRows)
;
void *ptr = NULL;
if (OB_ISNULL(ptr = allocator_.alloc(total_mem_size))) {
@ -3464,6 +3472,24 @@ int ObSysVarFactory::create_all_sys_vars()
ptr = (void *)((char *)ptr + sizeof(ObSysVarLcTimeNames));
}
}
if (OB_SUCC(ret)) {
if (OB_ISNULL(sys_var_ptr = new (ptr)ObSysVarAffectedRows())) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_ERROR("fail to new ObSysVarAffectedRows", K(ret));
} else {
store_buf_[ObSysVarsToIdxMap::get_store_idx(static_cast<int64_t>(SYS_VAR__AFFECTED_ROWS))] = sys_var_ptr;
ptr = (void *)((char *)ptr + sizeof(ObSysVarAffectedRows));
}
}
if (OB_SUCC(ret)) {
if (OB_ISNULL(sys_var_ptr = new (ptr)ObSysVarFoundRows())) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_ERROR("fail to new ObSysVarFoundRows", K(ret));
} else {
store_buf_[ObSysVarsToIdxMap::get_store_idx(static_cast<int64_t>(SYS_VAR__FOUND_ROWS))] = sys_var_ptr;
ptr = (void *)((char *)ptr + sizeof(ObSysVarFoundRows));
}
}
}
return ret;
@ -6147,6 +6173,28 @@ int ObSysVarFactory::create_sys_var(ObIAllocator &allocator_, ObSysVarClassType
}
break;
}
case SYS_VAR__AFFECTED_ROWS: {
void *ptr = NULL;
if (OB_ISNULL(ptr = allocator_.alloc(sizeof(ObSysVarAffectedRows)))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_ERROR("fail to alloc memory", K(ret), K(sizeof(ObSysVarAffectedRows)));
} else if (OB_ISNULL(sys_var_ptr = new (ptr)ObSysVarAffectedRows())) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_ERROR("fail to new ObSysVarAffectedRows", K(ret));
}
break;
}
case SYS_VAR__FOUND_ROWS: {
void *ptr = NULL;
if (OB_ISNULL(ptr = allocator_.alloc(sizeof(ObSysVarFoundRows)))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_ERROR("fail to alloc memory", K(ret), K(sizeof(ObSysVarFoundRows)));
} else if (OB_ISNULL(sys_var_ptr = new (ptr)ObSysVarFoundRows())) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_ERROR("fail to new ObSysVarFoundRows", K(ret));
}
break;
}
default: {
ret = OB_ERR_UNEXPECTED;