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

fix tx desc reuse concurrent bug

Browse Source
This commit is contained in:
obdev
2024-02-09 21:11:00 +00:00
committed by ob-robot
parent 7f7e972299
commit 30f3322b5b
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/tx/ob_trans_define_v4.cpp
View File

@ -932,7 +932,7 @@ bool ObTxDesc::execute_commit_cb()
#ifdef ENABLE_DEBUG_LOG #ifdef ENABLE_DEBUG_LOG
ob_abort(); ob_abort();
#endif #endif
TRANS_LOG(WARN, "unexpected error happen, cb_tid_ should smaller than 0", TRANS_LOG(ERROR, "unexpected error happen, cb_tid_ should smaller than 0",
KP(this), K(tx_id), KP(cb_tid_)); KP(this), K(tx_id), KP(cb_tid_));
} }
ATOMIC_STORE_REL(&cb_tid_, GETTID()); ATOMIC_STORE_REL(&cb_tid_, GETTID());
@ -944,7 +944,6 @@ bool ObTxDesc::execute_commit_cb()
OB_ID(thread_id), GETTID()); OB_ID(thread_id), GETTID());
commit_cb_lock_.unlock(); commit_cb_lock_.unlock();
cb->callback(commit_out_); cb->callback(commit_out_);
ATOMIC_STORE_REL(&cb_tid_, -GETTID());
} else { } else {
commit_cb_lock_.unlock(); commit_cb_lock_.unlock();
} }