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

[CP] use default hashmap latch

Browse Source
This commit is contained in:
Minionyh 2024-12-17 13:15:47 +00:00 committed by ob-robot
parent 2111de389b
commit 3689721d99
3 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/rootserver/mview/ob_collect_mv_merge_info_task.h
View File

@ -34,8 +34,6 @@ namespace rootserver
int (obrpc::ObSrvRpcProxy::*)(const arg &, obrpc::ObSrvRpcProxy::AsyncCB<code> *, const obrpc::ObRpcOpts &), obrpc::ObSrvRpcProxy> name
RPC_MVIEW(obrpc::OB_COLLECT_MV_MERGE_INFO, obrpc::ObCollectMvMergeInfoArg, obrpc::ObCollectMvMergeInfoResult, ObCollectMvMergeInfoProxy);
typedef common::hash::ObHashSet<uint64_t, common::hash::NoPthreadDefendMode> NewMvBaseTabletSet;
class ObCollectMvMergeInfoTask : public ObMViewTimerTask
{
public:

3
src/rootserver/mview/ob_mview_maintenance_service.cpp
View File

@ -274,13 +274,14 @@ int ObMViewMaintenanceService::update_mview_refresh_info_cache(
int ret = OB_SUCCESS;
int update_cache_cnt = 0;
const int invalid_refresh_scn = 0;
int64_t now_ts = ObTimeUtility::fast_current_time();
ARRAY_FOREACH_X(mview_ids, idx, cnt, OB_SUCC(ret)) {
RefreshInfo new_refresh_info;
if (mview_refresh_scns.at(idx) == invalid_refresh_scn) {
// skip update invalid scn in cache
} else if (mview_refresh_modes.at(idx) == (uint64_t)ObMVRefreshMode::MAJOR_COMPACTION) {
new_refresh_info.refresh_scn_ = mview_refresh_scns.at(idx);
new_refresh_info.refresh_ts_ = ObTimeUtility::fast_current_time();
new_refresh_info.refresh_ts_ = now_ts;
new_refresh_info.expired_ts_ = new_refresh_info.refresh_ts_ +
ObMViewMaintenanceService::CacheValidInterval;
if (OB_FAIL(mview_refresh_info_map.set_refactored(mview_ids.at(idx), new_refresh_info, 1/*overwrite*/))) {

2
src/rootserver/mview/ob_mview_maintenance_service.h
View File

@ -43,7 +43,7 @@ struct RefreshInfo
};
typedef common::hash::
ObHashMap<uint64_t, RefreshInfo, common::hash::NoPthreadDefendMode>
ObHashMap<uint64_t, RefreshInfo>
ObMviewRefreshInfoMap;
class ObMViewMaintenanceService : public logservice::ObIReplaySubHandler,
public logservice::ObICheckpointSubHandler,