]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
src/nvmeof/NVMeofGwMonitorClient.cc: ms_dispatch2 clean up 62914/head
authorAlexander Indenbaum <aindenba@redhat.com>
Tue, 22 Apr 2025 10:20:02 +0000 (13:20 +0300)
committerAlexander Indenbaum <aindenba@redhat.com>
Tue, 22 Apr 2025 13:53:48 +0000 (16:53 +0300)
- return ACKNOWLEDGED/HANDLED
- remove registration for unwanted keys

Signed-off-by: Alexander Indenbaum <aindenba@redhat.com>
src/nvmeof/NVMeofGwMonitorClient.cc

index a48b85d960520dda886c3baab1cb2956bd516653..ae5562a0718b775def7c130edf7e363f32e8e7cc 100644 (file)
@@ -137,8 +137,7 @@ int NVMeofGwMonitorClient::init()
   }
 
   monc.sub_want("NVMeofGw", 0, 0);
-  monc.set_want_keys(CEPH_ENTITY_TYPE_MON|CEPH_ENTITY_TYPE_OSD
-      |CEPH_ENTITY_TYPE_MDS|CEPH_ENTITY_TYPE_MGR);
+  monc.set_want_keys(CEPH_ENTITY_TYPE_MON|CEPH_ENTITY_TYPE_OSD);
   monc.set_messenger(client_messenger.get());
 
   // We must register our config callback before calling init(), so
@@ -427,9 +426,10 @@ Dispatcher::dispatch_result_t NVMeofGwMonitorClient::ms_dispatch2(const ref_t<Me
 
   if (m->get_type() == MSG_MNVMEOF_GW_MAP) {
     handle_nvmeof_gw_map(ref_cast<MNVMeofGwMap>(m));
+    return Dispatcher::HANDLED();
+
   }
-  bool handled = false;
-  return handled;
+  return Dispatcher::ACKNOWLEDGED();
 }
 
 int NVMeofGwMonitorClient::main(std::vector<const char *> args)