From b0bf45c26fc092eb00195c001a0e18d0366879d6 Mon Sep 17 00:00:00 2001 From: Vitaliy Filippov Date: Sat, 9 Aug 2025 21:58:29 +0300 Subject: [PATCH] Change emhashes --- src/blockstore/blockstore_heap.cpp | 4 ++-- src/blockstore/blockstore_heap.h | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/blockstore/blockstore_heap.cpp b/src/blockstore/blockstore_heap.cpp index c772f7be..ae4fc9d7 100644 --- a/src/blockstore/blockstore_heap.cpp +++ b/src/blockstore/blockstore_heap.cpp @@ -819,7 +819,7 @@ void blockstore_heap_t::reshard(pool_id_t pool, uint32_t pg_count, uint32_t pg_s } uint32_t old_pg_count = !pool_settings.pg_count ? 1 : pool_settings.pg_count; uint64_t pool_id = (uint64_t)pool; - emhash7::HashMap>> new_shards; + emhash7::HashMap>> new_shards; for (uint32_t pg_num = 0; pg_num <= old_pg_count; pg_num++) { auto sh_it = block_index.find((pool_id << (64-POOL_ID_BITS)) | pg_num); @@ -905,7 +905,7 @@ heap_object_t *blockstore_heap_t::read_locked_entry(object_id oid, uint64_t copy return read_entry(oid, NULL); } -void blockstore_heap_t::free_mvcc(std::unordered_map::iterator mvcc_it) +void blockstore_heap_t::free_mvcc(emhash7::HashMap::iterator mvcc_it) { if (mvcc_it->second.entry_copy) { diff --git a/src/blockstore/blockstore_heap.h b/src/blockstore/blockstore_heap.h index e9dc3103..a769f19c 100644 --- a/src/blockstore/blockstore_heap.h +++ b/src/blockstore/blockstore_heap.h @@ -167,14 +167,14 @@ class blockstore_heap_t uint64_t next_lsn = 0; emhash7::HashMap pool_shard_settings; // PG => inode => stripe => block number - emhash7::HashMap>> block_index; + emhash7::HashMap>> block_index; std::vector block_info; allocator_t *data_alloc = NULL; multilist_index_t *meta_alloc = NULL; uint32_t meta_alloc_count = 0; uint64_t meta_used_space = 0; multilist_alloc_t *buffer_alloc = NULL; - std::unordered_map object_mvcc; + emhash7::HashMap object_mvcc; std::unordered_map mvcc_data_refs; std::unordered_map mvcc_buffer_refs; std::map inode_space_stats; @@ -209,7 +209,7 @@ class blockstore_heap_t void copy_full_object(uint8_t *dst, heap_object_t *obj); bool mvcc_save_copy(heap_object_t *obj); bool mvcc_check_tracking(object_id oid); - void free_mvcc(std::unordered_map::iterator mvcc_it); + void free_mvcc(emhash7::HashMap::iterator mvcc_it); void allocate_block(heap_block_info_t & inf); int add_object(object_id oid, heap_write_t *wr, uint32_t *modified_block); void mark_overwritten(uint64_t over_lsn, uint64_t inode, heap_write_t *wr, heap_write_t *end_wr, bool tracking_active);