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

add guard_lock for deserialize session_info

Browse Source
This commit is contained in:
obdev
2021-07-12 17:14:00 +08:00
committed by wangzelin.wzl
parent e1a347ac63
commit 9c7663609e
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/executor/ob_task.cpp
View File

@ -681,6 +681,8 @@ OB_DEF_DESERIALIZE(ObRemoteTask)
LOG_WARN("create my session failed", K(ret), K(tenant_id)); LOG_WARN("create my session failed", K(ret), K(tenant_id));
} else { } else {
session_info_ = exec_ctx_->get_my_session(); session_info_ = exec_ctx_->get_my_session();
ObSQLSessionInfo::LockGuard query_guard(session_info_->get_query_lock());
ObSQLSessionInfo::LockGuard data_guard(session_info_->get_thread_data_lock());
OB_UNIS_DECODE(*session_info_); OB_UNIS_DECODE(*session_info_);
OB_UNIS_DECODE(remote_sql_info_->is_batched_stmt_); OB_UNIS_DECODE(remote_sql_info_->is_batched_stmt_);
} }