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

[master] fix tx free route MTL_SWITCH

Browse Source
This commit is contained in:
chinaxing
2023-02-08 15:11:41 +08:00
committed by ob-robot
parent c129aa89d0
commit b5de614a66
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/ob_sql_trans_control.cpp
View File

@ -1106,9 +1106,11 @@ int ObSqlTransControl::check_ls_readable(const uint64_t tenant_id,
int ObSqlTransControl::serialize_txn_##name##_state(ObSQLSessionInfo &session, char* buf, const int64_t len, int64_t &pos) \ int ObSqlTransControl::serialize_txn_##name##_state(ObSQLSessionInfo &session, char* buf, const int64_t len, int64_t &pos) \
{ \ { \
int ret = OB_SUCCESS; \ int ret = OB_SUCCESS; \
MTL_SWITCH(session.get_effective_tenant_id()) { \
transaction::ObTransService *txs = NULL; \ transaction::ObTransService *txs = NULL; \
OZ (get_tx_service(&session, txs)); \ OZ (get_tx_service(&session, txs)); \
OZ (txs->txn_free_route__serialize_##name##_state(session.get_sessid(), session.get_tx_desc(), session.get_txn_free_route_ctx(), buf, len, pos)); \ OZ (txs->txn_free_route__serialize_##name##_state(session.get_sessid(), session.get_tx_desc(), session.get_txn_free_route_ctx(), buf, len, pos)); \
} \
LOG_DEBUG("serialize-txn-state", K(session)); \ LOG_DEBUG("serialize-txn-state", K(session)); \
return ret; \ return ret; \
} \ } \
@ -1116,9 +1118,9 @@ int ObSqlTransControl::check_ls_readable(const uint64_t tenant_id,
{ \ { \
int ret = OB_SUCCESS; \ int ret = OB_SUCCESS; \
transaction::ObTransService *txs = NULL; \ transaction::ObTransService *txs = NULL; \
MTL_SWITCH(session.get_effective_tenant_id()) { \
OZ (get_tx_service(&session, txs)); \ OZ (get_tx_service(&session, txs)); \
if (OB_SUCC(ret)) { \ OZ (txs->txn_free_route__get_##name##_state_serialize_size(session.get_tx_desc(), session.get_txn_free_route_ctx())); \
return txs->txn_free_route__get_##name##_state_serialize_size(session.get_tx_desc(), session.get_txn_free_route_ctx()); \
} \ } \
LOG_DEBUG("get-serialize-size-txn-state", K(session)); \ LOG_DEBUG("get-serialize-size-txn-state", K(session)); \
return ret; \ return ret; \