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

Specify the Tenant_id of allocator

Browse Source
This commit is contained in:
gaishun 2024-11-06 06:15:02 +00:00 committed by ob-robot
parent e1d368dd14
commit 799420c5a7
4 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/ls/ob_ls_tablet_service.cpp
View File

@ -1566,7 +1566,7 @@ int ObLSTabletService::update_tablet_snapshot_version(
const int64_t snapshot_version)
{
int ret = OB_SUCCESS;
common::ObArenaAllocator allocator;
common::ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "UTabletSnapVer"));
ObTabletHandle old_tablet_handle;
ObTimeGuard time_guard("ObLSTabletService::update_tablet_snapshot_version", 1_s);
ObBucketHashWLockGuard lock_guard(bucket_lock_, tablet_id.hash());
@ -6180,7 +6180,7 @@ int ObLSTabletService::get_multi_ranges_cost(
} else {
ObPartitionSplitQuery split_query;
ObSEArray<ObStoreRange, 16> new_ranges;
ObArenaAllocator allocator;
ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "GetMulRangeCost"));
const ObTabletHandle &tablet_handle = iter.get_tablet_handle();
bool is_splited_range = false;
if (OB_FAIL(split_query.split_multi_ranges_if_need(ranges, new_ranges,

6
src/storage/meta_store/ob_tenant_storage_meta_service.cpp
View File

@ -489,7 +489,7 @@ int ObTenantStorageMetaService::inner_get_gc_tablet_scn_arr_(
{
int ret = OB_SUCCESS;
gc_tablet_scn_arr.tablet_version_arr_.reuse();
ObArenaAllocator allocator;
ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "InnerGetGCScn"));
bool is_exist = false;
if (OB_FAIL(ObStorageMetaIOUtil::check_meta_existence(opt, 0/*do not need ls_epoch*/, is_exist))) {
@ -637,7 +637,7 @@ int ObTenantStorageMetaService::ss_write_gc_info_(
{
int ret = OB_SUCCESS;
blocksstable::ObStorageObjectOpt opt;
common::ObArenaAllocator allocator;
common::ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "WriteGCSCN"));
opt.set_ss_gc_info_object_opt(tablet_id.id());
if (OB_FAIL(ObStorageMetaIOUtil::write_storage_meta_object(
opt, gc_info_scn_arr, allocator, MTL_ID(), 0/*ls_epoch, unused*/))) {
@ -650,7 +650,7 @@ int ObTenantStorageMetaService::ss_write_meta_list_(
{
int ret = OB_SUCCESS;
blocksstable::ObStorageObjectOpt opt;
common::ObArenaAllocator allocator;
common::ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "WriteMetaList"));
opt.set_ss_meta_list_object_opt(tablet_id.id());
if (OB_FAIL(ObStorageMetaIOUtil::write_storage_meta_object(
opt, meta_list_scn_arr, allocator, MTL_ID(), 0/*ls_epoch, unused*/))) {

4
src/storage/tablet/ob_tablet.cpp
View File

@ -5899,7 +5899,7 @@ int ObTablet::get_kept_snapshot_info(
int64_t min_medium_snapshot = INT64_MAX;
if (!is_ls_inner_tablet()) {
common::ObArenaAllocator allocator;
common::ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "GetKeptShotInfo"));
SMART_VARS_2((ObTableScanParam, scan_param), (ObTabletMediumInfoReader, medium_info_reader)) {
if (OB_FAIL(ObMdsScanParamHelper::build_medium_info_scan_param(allocator, ls_id, tablet_id, scan_param))) {
LOG_WARN("fail to build scan param", K(ret), K(ls_id), K(tablet_id));
@ -8308,7 +8308,7 @@ int ObTablet::get_sstable_column_checksum(
}
} else {
ObStorageSchema *storage_schema = nullptr;
ObArenaAllocator allocator;
ObArenaAllocator allocator(common::ObMemAttr(MTL_ID(), "GetColChecksum"));
if (OB_FAIL(load_storage_schema(allocator, storage_schema))) {
LOG_WARN("fail to load storage schema", K(ret));
} else if (OB_FAIL(static_cast<const ObCOSSTableV2 *>(&sstable)->fill_column_ckm_array(*storage_schema, column_checksums))) {

4
src/storage/tablet/ob_tablet_macro_info_iterator.cpp
View File

@ -172,7 +172,7 @@ int ObMacroInfoIterator::get_next(ObTabletBlockInfo &block_info)
int ObMacroInfoIterator::read_from_memory()
{
int ret = OB_SUCCESS;
ObArenaAllocator allocator;
ObArenaAllocator allocator(ObMemAttr(MTL_ID(), "DiskMacroIter"));
if (OB_ISNULL(macro_info_) || OB_UNLIKELY(ObTabletMacroType::INVALID_TYPE == target_type_
|| ObTabletMacroType::INVALID_TYPE == cur_type_)) {
ret = OB_ERR_UNEXPECTED;
@ -252,7 +252,7 @@ int ObMacroInfoIterator::read_from_memory()
int ObMacroInfoIterator::read_from_disk()
{
int ret = OB_SUCCESS;
ObArenaAllocator allocator;
ObArenaAllocator allocator(ObMemAttr(MTL_ID(), "DiskMacroIter"));
char *buf = nullptr;
int64_t buf_len = 0;
ObMetaDiskAddr addr;