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

[DeadLock] add request stat machine and meesage member occupy

Browse Source
This commit is contained in:
fengdeyiji
2024-06-24 05:40:47 +00:00
committed by ob-robot
parent 782576de45
commit e09b341e60
9 changed files with 119 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/ob_sql_trans_control.cpp
View File

@ -42,6 +42,7 @@
#include "sql/das/ob_das_dml_ctx_define.h"
#include "share/deadlock/ob_deadlock_detector_mgr.h"
#include "sql/engine/cmd/ob_table_direct_insert_ctx.h"
#include "storage/memtable/ob_lock_wait_mgr.h"
#ifdef CHECK_SESSION
#error "redefine macro CHECK_SESSION"
@ -526,6 +527,7 @@ int ObSqlTransControl::decide_trans_read_interface_specs(
int ObSqlTransControl::start_stmt(ObExecContext &exec_ctx)
{
int ret = OB_SUCCESS;
memtable::advance_tlocal_request_lock_wait_stat(rpc::RequestLockWaitStat::RequestStat::START);
DISABLE_SQL_MEMLEAK_GUARD;
ObSQLSessionInfo *session = GET_MY_SESSION(exec_ctx);
ObPhysicalPlanCtx *plan_ctx = GET_PHY_PLAN_CTX(exec_ctx);
@ -1261,6 +1263,7 @@ int ObSqlTransControl::end_stmt(ObExecContext &exec_ctx, const bool rollback)
if (OB_NOT_NULL(session)) {
session->get_trans_result().reset();
}
memtable::advance_tlocal_request_lock_wait_stat(rpc::RequestLockWaitStat::RequestStat::END);
return ret;
}