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

[foreign key] fix a bug about not handle error code during posting conflict tx to deadlock detector

Browse Source
This commit is contained in:
obdev 2023-04-04 05:44:36 +00:00 committed by ob-robot
parent 354a2065af
commit cef1d4186f
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/memtable/ob_row_conflict_handler.cpp
View File

@ -118,12 +118,14 @@ int ObRowConflictHandler::post_row_read_conflict(ObMvccAccessCtx &acc_ctx,
int tmp_ret = OB_SUCCESS;
ObTransID tx_id = acc_ctx.get_tx_id();
ObAddr conflict_scheduler_addr;
// register to deadlock detector
if (OB_FAIL(ObTransDeadlockDetectorAdapter::
get_trans_scheduler_info_on_participant(conflict_tx_id, ls_id, conflict_scheduler_addr))) {
TRANS_LOG(WARN, "get transaction scheduler info fail", K(ret), K(conflict_tx_id), K(tx_id), K(ls_id));
} else {
ObTransIDAndAddr conflict_tx(conflict_tx_id, conflict_scheduler_addr);
tx_desc->add_conflict_tx(conflict_tx);
}
ObTransIDAndAddr conflict_tx(conflict_tx_id, conflict_scheduler_addr);
tx_desc->add_conflict_tx(conflict_tx);
// The addr in tx_desc is the scheduler_addr of current trans,
// and GCTX.self_addr() will retrun the addr where the row is stored
// (i.e. where the trans is executing)