From: Matan Breizman <mbreizma@redhat.com>
Date: Mon, 29 Jan 2024 09:50:28 +0000 (+0000)
Subject: crimson/osd/pg_map: increase verbosity
X-Git-Tag: v19.3.0~110^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=d4d08047f77b16136a4c2e0f4a28c052b26a7224;p=ceph.git

crimson/osd/pg_map: increase verbosity

Signed-off-by: Matan Breizman <mbreizma@redhat.com>
---

diff --git a/src/crimson/osd/pg_map.cc b/src/crimson/osd/pg_map.cc
index 14f2b9f03e8..45f3bab2558 100644
--- a/src/crimson/osd/pg_map.cc
+++ b/src/crimson/osd/pg_map.cc
@@ -47,14 +47,16 @@ seastar::future<core_id_t> PGShardMapping::get_or_create_pg_mapping(
       DEBUG("mapping pg {} to core: {} with num_pgs of: {}",
             pgid, insert_iter->second, core_iter->second);
       return primary_mapping.container().invoke_on_others(
-        [pgid = insert_iter->first, core = insert_iter->second]
+        [pgid = insert_iter->first, core = insert_iter->second, FNAME]
         (auto &other_mapping) {
         ceph_assert_always(core != NULL_CORE);
         auto [insert_iter, inserted] = other_mapping.pg_to_core.emplace(pgid, core);
         ceph_assert_always(inserted);
+        DEBUG("mapping pg {} to core: {}", pgid, core);
       });
-    }).then([this, pgid] {
+    }).then([this, pgid, FNAME] {
       auto find_iter = pg_to_core.find(pgid);
+      DEBUG("returning pg {} mapping to core {}", pgid, find_iter->second);
       return seastar::make_ready_future<core_id_t>(find_iter->second);
     });
   }
@@ -63,7 +65,7 @@ seastar::future<core_id_t> PGShardMapping::get_or_create_pg_mapping(
 seastar::future<> PGShardMapping::remove_pg_mapping(spg_t pgid) {
   LOG_PREFIX(PGShardMapping::remove_pg_mapping);
   DEBUG("{}", pgid);
-  return container().invoke_on(0, [pgid](auto &primary_mapping) {
+  return container().invoke_on(0, [pgid, FNAME](auto &primary_mapping) {
     auto iter = primary_mapping.pg_to_core.find(pgid);
     ceph_assert_always(iter != primary_mapping.pg_to_core.end());
     ceph_assert_always(iter->second != NULL_CORE);
@@ -72,12 +74,14 @@ seastar::future<> PGShardMapping::remove_pg_mapping(spg_t pgid) {
     ceph_assert_always(count_iter->second > 0);
     --(count_iter->second);
     primary_mapping.pg_to_core.erase(iter);
+    DEBUG("pg {} mapping erased", pgid);
     return primary_mapping.container().invoke_on_others(
-      [pgid](auto &other_mapping) {
+      [pgid, FNAME](auto &other_mapping) {
       auto iter = other_mapping.pg_to_core.find(pgid);
       ceph_assert_always(iter != other_mapping.pg_to_core.end());
       ceph_assert_always(iter->second != NULL_CORE);
       other_mapping.pg_to_core.erase(iter);
+      DEBUG("pg {} mapping erased", pgid);
     });
   });
 }