OID_EVENT_TRACE_WITH_MSG(m, "MS_FAST_DISPATCH_END", false);
}
-void OSD::ms_fast_preprocess(Message *m)
-{
- if (m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_OSD) {
- if (m->get_type() == CEPH_MSG_OSD_MAP) {
- MOSDMap *mm = static_cast<MOSDMap*>(m);
- auto priv = m->get_connection()->get_priv();
- if (auto s = static_cast<Session*>(priv.get()); s) {
- s->received_map_lock.lock();
- s->received_map_epoch = mm->get_last();
- s->received_map_lock.unlock();
- }
- }
- }
-}
-
bool OSD::ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer)
{
dout(10) << "OSD::ms_get_authorizer type=" << ceph_entity_type_name(dest_type) << dendl;
}
}
void ms_fast_dispatch(Message *m) override;
- void ms_fast_preprocess(Message *m) override;
bool ms_dispatch(Message *m) override;
bool ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer) override;
void ms_handle_connect(Connection *con) override;
ceph::spinlock sent_epoch_lock;
epoch_t last_sent_epoch;
- ceph::spinlock received_map_lock;
- epoch_t received_map_epoch; // largest epoch seen in MOSDMap from here
/// protects backoffs; orders inside Backoff::lock *and* PG::backoff_lock
Mutex backoff_lock;
socket_addr(con_->get_peer_socket_addr()),
wstate(cct),
session_dispatch_lock("Session::session_dispatch_lock"),
- last_sent_epoch(0), received_map_epoch(0),
+ last_sent_epoch(0),
backoff_lock("Session::backoff_lock")
{}