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

[4.1] fix handle timeout for one participant distributed trans

Browse Source
This commit is contained in:
obdev 2022-12-27 10:38:19 +00:00 committed by ob-robot
parent 509c446234
commit 6f5d889cdb
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/storage/tx/ob_two_phase_upstream_committer.cpp
View File

@ -239,6 +239,21 @@ int ObTxCycleTwoPhaseCommitter::handle_timeout()
TRANS_LOG(WARN, "retransmit upstream msg failed", KR(tmp_ret));
}
// if a distributed trans has one participant and its 2pc state (up and down) is prepare,
// then try enter into pre commit state.
// NOTE that if a distributed trans has at least two participants,
// the state can be drived by message.
if (is_root()) {
const int SINGLE_COUNT = 1;
if (SINGLE_COUNT == get_downstream_size()
&& ObTxState::PREPARE == get_downstream_state()
&& ObTxState::PREPARE == get_upstream_state()) {
if (OB_FAIL(try_enter_pre_commit_state())) {
TRANS_LOG(WARN, "try enter into pre commit state failed", K(ret));
}
}
}
return ret;
}