For order checking.
Signed-off-by: Patrick Donnelly <pdonnell@redhat.com>
bool Beacon::ms_dispatch2(const ref_t<Message>& m)
{
+ dout(25) << __func__ << ": processing " << m << dendl;
if (m->get_type() == MSG_MDS_BEACON) {
if (m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_MON) {
handle_mds_beacon(ref_cast<MMDSBeacon>(m));
bool MDSDaemon::ms_dispatch2(const ref_t<Message> &m)
{
+ dout(25) << __func__ << ": processing " << m << dendl;
std::lock_guard l(mds_lock);
if (stopping) {
return false;
}
bool MetricAggregator::ms_dispatch2(const ref_t<Message> &m) {
+ dout(25) << " processing " << m << dendl;
if (m->get_type() == MSG_MDS_METRICS &&
m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_MDS) {
const Message *msg = m.get();
bool MonClient::ms_dispatch(Message *m)
{
+ ldout(cct, 25) << __func__ << " processing " << m << dendl;
// we only care about these message types
switch (m->get_type()) {
case CEPH_MSG_MON_MAP: