auto core_shard_iter = primary_mapping.core_shard_to_num_pgs.find(find_iter->second.first);
auto shard_iter = core_shard_iter->second.find(find_iter->second.second);
assert(shard_iter != core_shard_iter->second.end());
- assert(shard_iter->second > 0);
- --(shard_iter->second);
-
+ if (seastar::smp::count < primary_mapping.store_shard_nums ) {
+ assert(shard_iter->second > 0);
+ --(shard_iter->second);
+ }
primary_mapping.pg_to_core.erase(find_iter);
DEBUG("pg {} mapping erased (primary)", pgid);
return primary_mapping.container().invoke_on_others(