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

[CP] to issue<52424040>:fix memory leak when executing open cursor for loop stmt much times in a loop

Browse Source
This commit is contained in:
hanr881
2023-11-21 03:44:52 +00:00
committed by ob-robot
parent 38f7d1e740
commit 028d590095
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/sql/ob_spi.cpp
View File

@ -4556,13 +4556,30 @@ int ObSPIService::spi_alloc_complex_var(pl::ObPLExecCtx *ctx,
UNUSEDx(ctx, type, id, var_idx, init_size, addr); UNUSEDx(ctx, type, id, var_idx, init_size, addr);
#else #else
void *ptr = NULL; void *ptr = NULL;
bool need_alloc = true;
CK (OB_NOT_NULL(ctx)); CK (OB_NOT_NULL(ctx));
CK (OB_NOT_NULL(ctx->allocator_)); CK (OB_NOT_NULL(ctx->allocator_));
CK (OB_NOT_NULL(ctx->params_)); CK (OB_NOT_NULL(ctx->params_));
CK (OB_NOT_NULL(ctx->result_)); CK (OB_NOT_NULL(ctx->result_));
CK ((var_idx >= 0 && var_idx < ctx->params_->count()) CK ((var_idx >= 0 && var_idx < ctx->params_->count())
|| OB_INVALID_INDEX == var_idx); // OB_INVALID_ID代表初始化函数返回值 || OB_INVALID_INDEX == var_idx); // OB_INVALID_ID代表初始化函数返回值
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (var_idx >= 0 && var_idx < ctx->params_->count()) {
if (ctx->params_->at(var_idx).is_pl_extend() &&
0 != ctx->params_->at(var_idx).get_ext() &&
PL_OPAQUE_TYPE != ctx->params_->at(var_idx).get_meta().get_extend_type()) {
need_alloc = false;
int tmp = OB_SUCCESS;
if (OB_SUCCESS != (tmp = ObUserDefinedType::destruct_obj(ctx->params_->at(var_idx),
ctx->exec_ctx_->get_my_session(),
false))) {
LOG_WARN("fail to destruct obj", K(tmp));
}
}
}
}
if (OB_SUCC(ret) && need_alloc) {
ptr = ctx->allocator_->alloc(init_size); ptr = ctx->allocator_->alloc(init_size);
LOG_DEBUG("debug for spi alloc complex var", LOG_DEBUG("debug for spi alloc complex var",
K(var_idx), K(init_size), K(var_idx), K(init_size),