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

Fix: There is a concurrency problem with on_get_session

Browse Source
This commit is contained in:
yaojing624
2023-12-06 09:13:04 +00:00
committed by ob-robot
parent 7a441764f3
commit d8ccc0fc9f
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/session/ob_basic_session_info.cpp
View File

@ -6471,6 +6471,7 @@ int ObExecEnv::store(ObBasicSessionInfo &session)
void ObBasicSessionInfo::on_get_session() void ObBasicSessionInfo::on_get_session()
{ {
LockGuard lock_guard(thread_data_mutex_);
const char *str = lbt(); const char *str = lbt();
int len = STRLEN(str); int len = STRLEN(str);
if (sess_bt_buff_pos_ + len + 2 < MAX_SESS_BT_BUFF_SIZE) { if (sess_bt_buff_pos_ + len + 2 < MAX_SESS_BT_BUFF_SIZE) {
@ -6488,6 +6489,7 @@ void ObBasicSessionInfo::on_get_session()
void ObBasicSessionInfo::on_revert_session() void ObBasicSessionInfo::on_revert_session()
{ {
LockGuard lock_guard(thread_data_mutex_);
int32_t v = ATOMIC_AAF(&sess_ref_cnt_, -1); int32_t v = ATOMIC_AAF(&sess_ref_cnt_, -1);
if (v <= 0) { if (v <= 0) {
sess_bt_buff_pos_ = 0; sess_bt_buff_pos_ = 0;