Skip to content

Commit

Permalink
Merge pull request #17060 from cyx1231st/fix_reqid_assignment_in_opre…
Browse files Browse the repository at this point in the history
…quest

osd: fix reqid assignment for reply messages in OpRequest

Reviewed-by: Jos Collin <jcollin@redhat.com>
Reviewed-by: Kefu Chai <kchai@redhat.com>
  • Loading branch information
tchaikov committed Aug 20, 2017
2 parents d81816f + 4186d9e commit e407049
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions src/osd/OpRequest.cc
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,9 @@
#include "msg/Message.h"
#include "messages/MOSDOp.h"
#include "messages/MOSDSubOp.h"
#include "messages/MOSDSubOpReply.h"
#include "messages/MOSDRepOp.h"
#include "messages/MOSDRepOpReply.h"
#include "include/assert.h"
#include "osd/osd_types.h"

Expand All @@ -36,8 +38,12 @@ OpRequest::OpRequest(Message *req, OpTracker *tracker) :
reqid = static_cast<MOSDOp*>(req)->get_reqid();
} else if (req->get_type() == MSG_OSD_SUBOP) {
reqid = static_cast<MOSDSubOp*>(req)->reqid;
} else if (req->get_type() == MSG_OSD_SUBOPREPLY) {
reqid = static_cast<MOSDSubOpReply*>(req)->reqid;
} else if (req->get_type() == MSG_OSD_REPOP) {
reqid = static_cast<MOSDRepOp*>(req)->reqid;
} else if (req->get_type() == MSG_OSD_REPOPREPLY) {
reqid = static_cast<MOSDRepOpReply*>(req)->reqid;
}
req_src_inst = req->get_source_inst();
mark_event("header_read", request->get_recv_stamp());
Expand Down

0 comments on commit e407049

Please sign in to comment.