{
switch (m->get_type()) {
case CEPH_MSG_CLIENT_RECONNECT:
- handle_client_reconnect((MClientReconnect*)m);
+ handle_client_reconnect(static_cast<MClientReconnect*>(m));
return;
}
!(mds->is_stopping() && m->get_source().is_mds())) {
if ((mds->is_reconnect() || mds->get_want_state() == CEPH_MDS_STATE_RECONNECT) &&
m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
- ((MClientRequest*)m)->is_replay()) {
+ (static_cast<MClientRequest*>(m))->is_replay()) {
dout(3) << "queuing replayed op" << dendl;
mds->enqueue_replay(new C_MDS_RetryMessage(mds, m));
return;
} else if (mds->is_clientreplay() &&
(m->get_type() == CEPH_MSG_CLIENT_SESSION ||
(m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
- ((MClientRequest*)m)->is_replay()))) {
+ (static_cast<MClientRequest*>(m))->is_replay()))) {
// replaying!
} else if (mds->is_clientreplay() && m->get_type() == MSG_MDS_SLAVE_REQUEST &&
- (((MMDSSlaveRequest*)m)->is_reply() ||
+ ((static_cast<MMDSSlaveRequest*>(m))->is_reply() ||
!mds->mdsmap->is_active(m->get_source().num()))) {
// slave reply or the master is also in the clientreplay stage
} else {
switch (m->get_type()) {
case CEPH_MSG_CLIENT_SESSION:
- handle_client_session((MClientSession*)m);
+ handle_client_session(static_cast<MClientSession*>(m));
return;
case CEPH_MSG_CLIENT_REQUEST:
- handle_client_request((MClientRequest*)m);
+ handle_client_request(static_cast<MClientRequest*>(m));
return;
case MSG_MDS_SLAVE_REQUEST:
- handle_slave_request((MMDSSlaveRequest*)m);
+ handle_slave_request(static_cast<MMDSSlaveRequest*>(m));
return;
}
Session *Server::get_session(Message *m)
{
- Session *session = (Session *)m->get_connection()->get_priv();
+ Session *session = static_cast<Session *>(m->get_connection()->get_priv());
if (session) {
dout(20) << "get_session have " << session << " " << session->info.inst
<< " state " << session->get_state_name() << dendl;
}
while (!session->leases.empty()) {
ClientLease *r = session->leases.front();
- CDentry *dn = (CDentry*)r->parent;
+ CDentry *dn = static_cast<CDentry*>(r->parent);
dout(20) << " killing client lease of " << *dn << dendl;
dn->remove_client_lease(r, mds->locker);
}
break;
}
if (need_issue)
- mds->locker->issue_caps((CInode*)lock->get_parent());
+ mds->locker->issue_caps(static_cast<CInode*>(lock->get_parent()));
// done. no ack necessary.
mdr->slave_request->put();
objects.push_back(object);
if (*p == mdr->slave_request->get_authpin_freeze())
- auth_pin_freeze = (CInode*)object;
+ auth_pin_freeze = static_cast<CInode*>(object);
}
// can we auth pin them?
if (!mdr->is_auth_pinned(object))
mdr->remote_auth_pins.insert(object);
if (*p == ack->get_authpin_freeze())
- mdr->set_remote_frozen_auth_pin((CInode *)object);
+ mdr->set_remote_frozen_auth_pin(static_cast<CInode *>(object));
pinned.insert(object);
}