This acquires a lock which is a no-no in the messenger.
Signed-off-by: Patrick Donnelly <pdonnell@ibm.com>
ClusterWatcher::~ClusterWatcher() {
}
-bool ClusterWatcher::ms_can_fast_dispatch2(const cref_t<Message> &m) const {
- return m->get_type() == CEPH_MSG_FS_MAP;
-}
-
-void ClusterWatcher::ms_fast_dispatch2(const ref_t<Message> &m) {
- bool handled = ms_dispatch2(m);
- ceph_assert(handled);
-}
-
bool ClusterWatcher::ms_dispatch2(const ref_t<Message> &m) {
if (m->get_type() == CEPH_MSG_FS_MAP) {
if (m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_MON) {
Listener &listener);
~ClusterWatcher();
- bool ms_can_fast_dispatch_any() const override {
- return true;
- }
- bool ms_can_fast_dispatch2(const cref_t<Message> &m) const override;
- void ms_fast_dispatch2(const ref_t<Message> &m) override;
bool ms_dispatch2(const ref_t<Message> &m) override;
void ms_handle_connect(Connection *c) override {