From 30f3322b5b47625d2965018cdb70a3de6cae2b1e Mon Sep 17 00:00:00 2001 From: obdev Date: Fri, 9 Feb 2024 21:11:00 +0000 Subject: [PATCH] fix tx desc reuse concurrent bug --- src/storage/tx/ob_trans_define_v4.cpp | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/storage/tx/ob_trans_define_v4.cpp b/src/storage/tx/ob_trans_define_v4.cpp index 1c55cda12a..0e12770b95 100644 --- a/src/storage/tx/ob_trans_define_v4.cpp +++ b/src/storage/tx/ob_trans_define_v4.cpp @@ -932,7 +932,7 @@ bool ObTxDesc::execute_commit_cb() #ifdef ENABLE_DEBUG_LOG ob_abort(); #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_)); } ATOMIC_STORE_REL(&cb_tid_, GETTID()); @@ -944,7 +944,6 @@ bool ObTxDesc::execute_commit_cb() OB_ID(thread_id), GETTID()); commit_cb_lock_.unlock(); cb->callback(commit_out_); - ATOMIC_STORE_REL(&cb_tid_, -GETTID()); } else { commit_cb_lock_.unlock(); }