]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
mgr/DaemonState: pass const by reference
authorKefu Chai <kchai@redhat.com>
Mon, 15 Apr 2019 06:02:33 +0000 (14:02 +0800)
committerKefu Chai <kchai@redhat.com>
Wed, 17 Apr 2019 22:59:42 +0000 (06:59 +0800)
DaemonPerfCounters::update() does not change the `MMgrReport` message,
neither does it expect a nullptr. so pass by const reference.

Signed-off-by: Kefu Chai <kchai@redhat.com>
src/mgr/DaemonServer.cc
src/mgr/DaemonState.cc
src/mgr/DaemonState.h

index c8db6652e616ba7de37933fa3319dc51dfe654e2..e6976cb3891e0bc3036e48f617613cfd1cdc2412 100644 (file)
@@ -593,7 +593,7 @@ bool DaemonServer::handle_report(const ref_t<MMgrReport>& m)
   {
     std::lock_guard l(daemon->lock);
     auto &daemon_counters = daemon->perf_counters;
-    daemon_counters.update(m);
+    daemon_counters.update(*m.get());
 
     auto p = m->config_bl.cbegin();
     if (p != m->config_bl.end()) {
index b13685a1561b60adf415325a618dbd90a2170968..e0cc9f2e0b9a2b694800705ced0c8cca6fb29787 100644 (file)
@@ -264,31 +264,31 @@ void DaemonStateIndex::cull(const std::string& svc_name,
   }
 }
 
-void DaemonPerfCounters::update(MMgrReport *report)
+void DaemonPerfCounters::update(const MMgrReport& report)
 {
-  dout(20) << "loading " << report->declare_types.size() << " new types, "
-          << report->undeclare_types.size() << " old types, had "
+  dout(20) << "loading " << report.declare_types.size() << " new types, "
+          << report.undeclare_types.size() << " old types, had "
           << types.size() << " types, got "
-           << report->packed.length() << " bytes of data" << dendl;
+           << report.packed.length() << " bytes of data" << dendl;
 
   // Retrieve session state
-  auto priv = report->get_connection()->get_priv();
+  auto priv = report.get_connection()->get_priv();
   auto session = static_cast<MgrSession*>(priv.get());
 
   // Load any newly declared types
-  for (const auto &t : report->declare_types) {
+  for (const auto &t : report.declare_types) {
     types.insert(std::make_pair(t.path, t));
     session->declared_types.insert(t.path);
   }
   // Remove any old types
-  for (const auto &t : report->undeclare_types) {
+  for (const auto &t : report.undeclare_types) {
     session->declared_types.erase(t);
   }
 
   const auto now = ceph_clock_now();
 
   // Parse packed data according to declared set of types
-  auto p = report->packed.cbegin();
+  auto p = report.packed.cbegin();
   DECODE_START(1, p);
   for (const auto &t_path : session->declared_types) {
     const auto &t = types.at(t_path);
index 680d4a0cc2cf5112e13a1b322e67c92f7110ea9e..ce29e9cd9030a5ab10c0c1f7c8638c557494f7fb 100644 (file)
@@ -114,7 +114,7 @@ class DaemonPerfCounters
 
   std::map<std::string, PerfCounterInstance> instances;
 
-  void update(MMgrReport *report);
+  void update(const MMgrReport& report);
 
   void clear()
   {