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

[MDS] fix buffer ctx memory leak in normal path

Browse Source
This commit is contained in:
obdev
2024-02-07 07:43:34 +00:00
committed by ob-robot
parent 4a9dcce37d
commit 047a660f99
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/storage/tx/ob_trans_part_ctx.cpp
View File

@ -1505,7 +1505,6 @@ int ObPartTransCtx::recover_tx_ctx_table_info(ObTxCtxTableInfo &ctx_info)
exec_info_.mds_buffer_ctx_array_.reset();
if (OB_FAIL(ret)) {
// do nothing
} else if (FALSE_IT(ctx_info.exec_info_.mrege_buffer_ctx_array_to_multi_data_source())) {
} else if (OB_FAIL(deep_copy_mds_array_(ctx_info.exec_info_.multi_data_source_, _unused_))) {
TRANS_LOG(WARN, "deep copy ctx_info mds_array failed", K(ret));
} else if (FALSE_IT(mt_ctx_.update_checksum(exec_info_.checksum_,

8
src/storage/tx_table/ob_tx_ctx_table.cpp
View File

@ -216,14 +216,16 @@ int ObTxCtxTableRecoverHelper::recover(const blocksstable::ObDatumRow &row,
if (OB_FAIL(ctx_info_.deserialize(deserialize_buf, deserialize_buf_length, pos, tx_data_table))) {
STORAGE_LOG(WARN, "failed to deserialize status_info", K(ret), K_(ctx_info));
} else if (FALSE_IT(ctx_info_.exec_info_.mrege_buffer_ctx_array_to_multi_data_source())) {
} else if (OB_FAIL(recover_one_tx_ctx_(ls_tx_ctx_mgr, ctx_info_))) {
// heap memory needed be freed, but can not do this in destruction, cause tx_buffer_node has no value sematics
ctx_info_.exec_info_.clear_buffer_ctx_in_multi_data_source();
STORAGE_LOG(WARN, "failed to recover_one_tx_ctx_", K(ret), K(ctx_info_));
} else {
// heap memory needed be freed, but can not do this in destruction, cause tx_buffer_node has no value sematics
ctx_info_.exec_info_.clear_buffer_ctx_in_multi_data_source();
finish_recover_one_tx_ctx_();
}
// clear it cause buffer ctx memory need released
// and ObString in buffer node no need released cause it's just part reference of deserialized buffer
ctx_info_.exec_info_.clear_buffer_ctx_in_multi_data_source();
}
if (OB_SUCC(ret)) {