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

fix tx_ctx recover from tx_op no need put lock_op to mt_ctx

Browse Source
This commit is contained in:
obdev
2024-05-23 05:58:32 +00:00
committed by ob-robot
parent a222a2b040
commit 00299ae0ca
1 changed files with 0 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -8305,19 +8305,6 @@ int ObPartTransCtx::recover_tx_ctx_from_tx_op_(ObTxOpVector &tx_op_list, const S
const ObTxBufferNode &node = node_wrapper.get_node();
if (OB_FAIL(mds_array.push_back(node))) {
TRANS_LOG(WARN, "failed to push node to array", KR(ret), KPC(this));
} else if (node.type_ == ObTxDataSourceType::TABLE_LOCK) {
// to recover table_lock
ObTableLockOp lock_op;
int64_t pos = 0;
const char *buf = node.data_.ptr();
const int64_t len = node.data_.length();
if (OB_FAIL(lock_op.deserialize(buf, node.get_data_size(), pos))) {
TRANS_LOG(WARN, "deserialize fail", KR(ret), KPC(this));
} else if (OB_FAIL(mt_ctx_.replay_lock(lock_op, tx_op.get_op_scn()))) {
TRANS_LOG(WARN, "recover lock_op failed", KR(ret), KPC(this));
} else {
TRANS_LOG(INFO, "recover lock_op from tx_op", KPC(this), K(lock_op), K(node_wrapper));
}
}
} else {
ret = OB_ERR_UNEXPECTED;