@@ -47,14 +47,16 @@ seastar::future<core_id_t> PGShardMapping::get_or_create_pg_mapping(
4747 DEBUG (" mapping pg {} to core: {} with num_pgs of: {}" ,
4848 pgid, insert_iter->second , core_iter->second );
4949 return primary_mapping.container ().invoke_on_others (
50- [pgid = insert_iter->first , core = insert_iter->second ]
50+ [pgid = insert_iter->first , core = insert_iter->second , FNAME ]
5151 (auto &other_mapping) {
5252 ceph_assert_always (core != NULL_CORE);
5353 auto [insert_iter, inserted] = other_mapping.pg_to_core .emplace (pgid, core);
5454 ceph_assert_always (inserted);
55+ DEBUG (" mapping pg {} to core: {}" , pgid, core);
5556 });
56- }).then ([this , pgid] {
57+ }).then ([this , pgid, FNAME ] {
5758 auto find_iter = pg_to_core.find (pgid);
59+ DEBUG (" returning pg {} mapping to core {}" , pgid, find_iter->second );
5860 return seastar::make_ready_future<core_id_t >(find_iter->second );
5961 });
6062 }
@@ -63,7 +65,7 @@ seastar::future<core_id_t> PGShardMapping::get_or_create_pg_mapping(
6365seastar::future<> PGShardMapping::remove_pg_mapping (spg_t pgid) {
6466 LOG_PREFIX (PGShardMapping::remove_pg_mapping);
6567 DEBUG (" {}" , pgid);
66- return container ().invoke_on (0 , [pgid](auto &primary_mapping) {
68+ return container ().invoke_on (0 , [pgid, FNAME ](auto &primary_mapping) {
6769 auto iter = primary_mapping.pg_to_core .find (pgid);
6870 ceph_assert_always (iter != primary_mapping.pg_to_core .end ());
6971 ceph_assert_always (iter->second != NULL_CORE);
@@ -72,12 +74,14 @@ seastar::future<> PGShardMapping::remove_pg_mapping(spg_t pgid) {
7274 ceph_assert_always (count_iter->second > 0 );
7375 --(count_iter->second );
7476 primary_mapping.pg_to_core .erase (iter);
77+ DEBUG (" pg {} mapping erased" , pgid);
7578 return primary_mapping.container ().invoke_on_others (
76- [pgid](auto &other_mapping) {
79+ [pgid, FNAME ](auto &other_mapping) {
7780 auto iter = other_mapping.pg_to_core .find (pgid);
7881 ceph_assert_always (iter != other_mapping.pg_to_core .end ());
7982 ceph_assert_always (iter->second != NULL_CORE);
8083 other_mapping.pg_to_core .erase (iter);
84+ DEBUG (" pg {} mapping erased" , pgid);
8185 });
8286 });
8387}
0 commit comments