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

check trans_expired_time_ validity in handle_timeout

Browse Source
This commit is contained in:
obdev 2022-11-24 10:05:41 +00:00 committed by wangzelin.wzl
parent 23ad5e6d1d
commit bad2aaf5e0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -434,7 +434,9 @@ int ObPartTransCtx::handle_timeout(const int64_t delay)
(void)unregister_timeout_task_();
update_trans_2pc_timeout_();
timeout_task_.set_running(true);
if (ObTxState::INIT == exec_info_.state_ && now >= (trans_expired_time_ + OB_TRANS_WARN_USE_TIME)) {
if (ObTxState::INIT == exec_info_.state_ &&
trans_expired_time_ > 0 && trans_expired_time_ < INT64_MAX &&
now >= (trans_expired_time_ + OB_TRANS_WARN_USE_TIME)) {
TRANS_LOG(ERROR, "transaction use too much time", KPC(this));
}
if (exec_info_.is_dup_tx_) {