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

do not send rpc when holds a lock

Browse Source
This commit is contained in:
Charles0429 2024-02-10 08:10:32 +00:00 committed by ob-robot
parent fcf252d9cb
commit ad8ab72cee
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/ddl/ob_direct_insert_sstable_ctx_new.cpp
View File

@ -716,8 +716,6 @@ int ObTenantDirectLoadMgr::get_tablet_cache_interval(
ObTabletCacheInterval &interval)
{
int ret = OB_SUCCESS;
ObTabletDirectLoadMgrKey mgr_key(tablet_id, true/*full direct load*/); // only support in ddl, which is full direct load
ObBucketHashWLockGuard guard(bucket_lock_, mgr_key.hash());
ObTabletAutoincrementService &autoinc_service = ObTabletAutoincrementService::get_instance();
if (OB_UNLIKELY(!is_inited_)) {
ret = OB_NOT_INIT;
@ -728,6 +726,8 @@ int ObTenantDirectLoadMgr::get_tablet_cache_interval(
} else if (OB_FAIL(autoinc_service.get_tablet_cache_interval(MTL_ID(), interval))) {
LOG_WARN("failed to get tablet cache intervals", K(ret));
} else {
ObTabletDirectLoadMgrKey mgr_key(tablet_id, true/*full direct load*/); // only support in ddl, which is full direct load
ObBucketHashWLockGuard guard(bucket_lock_, mgr_key.hash());
ObTabletDirectLoadExecContext exec_context;
ObTabletDirectLoadExecContextId exec_id;
exec_id.tablet_id_ = tablet_id;