crimson/osd: send MOSDPGTemp on peering and map advance.

Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>

diff --git a/src/crimson/osd/osd_operations/peering_event.cc b/src/crimson/osd/osd_operations/peering_event.cc
index b9eb6ec7a559a884e7c5f35d8b0781cf5e60092a..a7255bbe7a98862939c6239e0d0120dee8f7cf97 100644 (file)
--- a/src/crimson/osd/osd_operations/peering_event.cc
+++ b/src/crimson/osd/osd_operations/peering_event.cc
@@ -85,6 +85,8 @@ seastar::future<> PeeringEvent::start()
                                : seastar::now();
       });
     }
+  }).then([this] {
+    return shard_services.send_pg_temp();
   }).then([this, ref=std::move(ref)] {
     logger().debug("{}: complete", *this);
   });

diff --git a/src/crimson/osd/osd_operations/pg_advance_map.cc b/src/crimson/osd/osd_operations/pg_advance_map.cc
index a1092e9b375f22c4c8d6b19d446a85a099ff81a9..ec30841a12f93fd4d98b84cc3be58c54d19cf8a2 100644 (file)
--- a/src/crimson/osd/osd_operations/pg_advance_map.cc
+++ b/src/crimson/osd/osd_operations/pg_advance_map.cc
@@ -86,7 +86,9 @@ seastar::future<> PGAdvanceMap::start()
            osd.shard_services.dispatch_context(
              pg->get_collection_ref(),
              std::move(rctx)));
-       });
+       }).then([this] {
+          return osd.shard_services.send_pg_temp();
+        });
     }).then([this, ref=std::move(ref)] {
       logger().debug("{}: complete", *this);
     });