RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-02 09:02:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

mds: drop replayed requests when seesion is closed

Browse Source 
Signed-off-by: Yan, Zheng <zyan@redhat.com>
This commit is contained in:
Yan, Zheng 2015-03-25 10:33:23 +08:00
parent 8f91547654
commit 2d6277683b
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mds/Server.cc
View File

@ -118,6 +118,12 @@ void Server::dispatch(Message *m)
if (m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
(mds->is_reconnect() || mds->get_want_state() == CEPH_MDS_STATE_RECONNECT)) {
MClientRequest *req = static_cast<MClientRequest*>(m);
Session *session = get_session(req);
if (!session || session->is_closed()) {
dout(5) << "session is closed, dropping " << req->get_reqid() << dendl;
req->put();
return;
}
bool queue_replay = false;
if (req->is_replay()) {
dout(3) << "queuing replayed op" << dendl;
@ -126,8 +132,7 @@ void Server::dispatch(Message *m)
// process completed request in clientreplay stage. The completed request
// might have created new file/directorie. This guarantees MDS sends a reply
// to client before other request modifies the new file/directorie.
Session *session = get_session(req);
if (session && session->have_completed_request(req->get_reqid().tid, NULL)) {
if (session->have_completed_request(req->get_reqid().tid, NULL)) {
dout(3) << "queuing completed op" << dendl;
queue_replay = true;
}