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

[CP] Add a sync rollback stmt process, when ending first stmt.

Browse Source
This commit is contained in:
felix-w15 2023-10-23 11:39:52 +00:00 committed by ob-robot
parent e9af7f1b1e
commit 98d35eeeb0
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/storage/tx/ob_tx_api.cpp
View File

@ -1089,6 +1089,11 @@ int ObTransService::rollback_to_global_implicit_savepoint_(ObTxDesc &tx,
&& tx.active_scn_ >= savepoint // rollback all dirty state
&& !tx.has_extra_state_()) { // hasn't explicit savepoint or serializable snapshot
reset_tx = true;
/*
* Avoid lock conflicts between first stmt retry and tx async abort(end first stmt caused)
* Add a sync rollback process before async abort tx.
*/
normal_rollback = true;
} else {
normal_rollback = true;
}
@ -1115,7 +1120,9 @@ int ObTransService::rollback_to_global_implicit_savepoint_(ObTxDesc &tx,
expire_ts))) {
TRANS_LOG(WARN, "do savepoint rollback fail", K(ret));
}
if (OB_FAIL(ret)) {
// reset tx ignore rollback ret
if (reset_tx) {
} else if (OB_FAIL(ret)) {
TRANS_LOG(WARN, "rollback savepoint fail, abort tx",
K(ret), K(savepoint), KP(extra_touched_ls), K(parts), K(tx));
// advance op_sequence to reject further rollback resp messsages