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

BUGFIX: ddl lock table using lock thread group

Browse Source
This commit is contained in:
obdev
2024-01-08 04:47:19 +00:00
committed by ob-robot
parent 796ec9f7c7
commit b42b2e6245
14 changed files with 432 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/share/transfer/ob_transfer_info.cpp
View File

@ -828,14 +828,13 @@ int ObTransferLockUtil::unlock_tablet_on_src_ls_for_table_lock(
return ret;
}
template<typename LockArg>
int ObTransferLockUtil::process_table_lock_on_tablets_(
ObMySQLTransaction &trans,
const uint64_t tenant_id,
const ObLSID &ls_id,
const transaction::tablelock::ObTableLockOwnerID &lock_owner_id,
const ObDisplayTabletList &table_lock_tablet_list,
LockArg &lock_arg)
ObLockAloneTabletRequest &lock_arg)
{
int ret = OB_SUCCESS;
lock_arg.tablet_ids_.reset();
@ -872,7 +871,7 @@ int ObTransferLockUtil::process_table_lock_on_tablets_(
LOG_WARN("lock tablet failed", KR(ret), K(tenant_id), K(lock_arg));
}
} else if (OUT_TRANS_UNLOCK == lock_arg.op_type_) {
if (OB_FAIL(ObInnerConnectionLockUtil::unlock_tablet(tenant_id, lock_arg, conn))) {
if (OB_FAIL(ObInnerConnectionLockUtil::unlock_tablet(tenant_id, static_cast<ObUnLockAloneTabletRequest &>(lock_arg), conn))) {
LOG_WARN("unock tablet failed", KR(ret), K(tenant_id), K(lock_arg));
}
} else {