From: Yan, Zheng Date: Wed, 25 May 2016 10:33:49 +0000 (+0800) Subject: MDSMonitor.cc: fix mdsmap. subscriptions X-Git-Tag: v11.0.0~420^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=8f09dd15cb07597c57d0a6ae981f15a47de11bb9;p=ceph.git MDSMonitor.cc: fix mdsmap. subscriptions Signed-off-by: Yan, Zheng --- diff --git a/src/mon/MDSMonitor.cc b/src/mon/MDSMonitor.cc index 504e3fb72b09..bdb48a27bc11 100644 --- a/src/mon/MDSMonitor.cc +++ b/src/mon/MDSMonitor.cc @@ -2411,22 +2411,22 @@ void MDSMonitor::check_subs() { std::list types; - // Subscriptions may be to "fsmap" (MDS and legacy clients), - // "fsmap.", or to "fsmap" for the full state of all + // Subscriptions may be to "mdsmap" (MDS and legacy clients), + // "mdsmap.", or to "fsmap" for the full state of all // filesystems. Build a list of all the types we service // subscriptions for. - types.push_back("mdsmap"); types.push_back("fsmap"); + types.push_back("mdsmap"); for (const auto &i : fsmap.filesystems) { auto fscid = i.first; std::ostringstream oss; - oss << "fsmap." << fscid; + oss << "mdsmap." << fscid; types.push_back(oss.str()); } for (const auto &type : types) { if (mon->session_map.subs.count(type) == 0) - return; + continue; xlist::iterator p = mon->session_map.subs[type]->begin(); while (!p.end()) { Subscription *sub = *p;