Method handle_update

src/mgr/DaemonServer.cc:650–691

}

bool DaemonServer::handle_update(const ref_t<MMgrUpdate>& m)
{
  DaemonKey key;
  if (!m->service_name.empty()) {
    key.type = m->service_name;
  } else {
    key.type = ceph_entity_type_name(m->get_connection()->get_peer_type());
  }
  key.name = m->daemon_name;

  dout(10) << "from " << m->get_connection() << " " << key << dendl;

  if (m->get_connection()->get_peer_type() == entity_name_t::TYPE_CLIENT &&
      m->service_name.empty()) {
    // Clients should not be sending us update request
    dout(10) << "rejecting update request from non-daemon client " << m->daemon_name
	     << dendl;
    clog->warn() << "rejecting report from non-daemon client " << m->daemon_name
		 << " at " << m->get_connection()->get_peer_addrs();
    m->get_connection()->mark_down();
    return true;
  }


  {
    std::unique_lock locker(lock);

    DaemonStatePtr daemon;
    // Look up the DaemonState
    if (daemon_state.exists(key)) {
      dout(20) << "updating existing DaemonState for " << key << dendl;

      daemon = daemon_state.get(key);
      if (m->need_metadata_update &&
          !m->daemon_metadata.empty()) {
        daemon_state.update_metadata(daemon, m->daemon_metadata);
      }
    }
  }

  return true;
}

bool DaemonServer::handle_close(const ref_t<MMgrClose>& m)
{