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

revert lock wait mgr miss wake up bug fix

Browse Source
This commit is contained in:
felix-w15
2024-03-12 07:20:18 +00:00
committed by ob-robot
parent dec494cf3f
commit c0fafd502d
2 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
deps/oblib/src/rpc/ob_lock_wait_node.cpp vendored
View File

@ -45,7 +45,6 @@ void ObLockWaitNode::set(void* addr,
total_update_cnt_ = total_trans_node_cnt;
run_ts_ = 0;
snprintf(key_, sizeof(key_), "%s", key);
reset_need_wait();
}
void ObLockWaitNode::change_hash(const int64_t hash, const int64_t lock_seq)

8
src/observer/mysql/ob_query_retry_ctrl.cpp
View File

@ -17,7 +17,6 @@
#include "sql/resolver/ob_stmt.h"
#include "pl/ob_pl.h"
#include "storage/tx/ob_trans_define.h"
#include "storage/memtable/ob_lock_wait_mgr.h"
#include "observer/mysql/ob_mysql_result_set.h"
#include "observer/ob_server_struct.h"
#include "observer/mysql/obmp_query.h"
@ -989,13 +988,6 @@ void ObQueryRetryCtrl::after_func(ObRetryParam &v)
if (OB_UNLIKELY(OB_SUCCESS == v.client_ret_)) {
LOG_ERROR_RET(OB_ERR_UNEXPECTED, "no matter need retry or not, v.client_ret_ should not be OB_SUCCESS", K(v));
}
// bug fix:
if (RETRY_TYPE_LOCAL == v.retry_type_) {
rpc::ObLockWaitNode* node = MTL(memtable::ObLockWaitMgr*)->get_thread_node();
if (NULL != node) {
node->reset_need_wait();
}
}
}
int ObQueryRetryCtrl::init()