Skip to content

Commit 8ff8a4a

Browse files
authored
Merge pull request ceph#62914 from baum/ms_dispatch2_clean_up
src/nvmeof/NVMeofGwMonitorClient.cc: ms_dispatch2 clean up
2 parents a12f5b5 + 89c220c commit 8ff8a4a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/nvmeof/NVMeofGwMonitorClient.cc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -137,8 +137,7 @@ int NVMeofGwMonitorClient::init()
137137
}
138138

139139
monc.sub_want("NVMeofGw", 0, 0);
140-
monc.set_want_keys(CEPH_ENTITY_TYPE_MON|CEPH_ENTITY_TYPE_OSD
141-
|CEPH_ENTITY_TYPE_MDS|CEPH_ENTITY_TYPE_MGR);
140+
monc.set_want_keys(CEPH_ENTITY_TYPE_MON|CEPH_ENTITY_TYPE_OSD);
142141
monc.set_messenger(client_messenger.get());
143142

144143
// 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
427426

428427
if (m->get_type() == MSG_MNVMEOF_GW_MAP) {
429428
handle_nvmeof_gw_map(ref_cast<MNVMeofGwMap>(m));
429+
return Dispatcher::HANDLED();
430+
430431
}
431-
bool handled = false;
432-
return handled;
432+
return Dispatcher::ACKNOWLEDGED();
433433
}
434434

435435
int NVMeofGwMonitorClient::main(std::vector<const char *> args)

0 commit comments

Comments
 (0)