From 4186d9efa4c9b39cd74d360d0740c88200a11446 Mon Sep 17 00:00:00 2001 From: Yingxin Date: Thu, 17 Aug 2017 10:41:40 -0400 Subject: [PATCH] osd/OpRequest: fix reqid assignment for reply messages Signed-off-by: Yingxin Cheng --- src/osd/OpRequest.cc | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/osd/OpRequest.cc b/src/osd/OpRequest.cc index 4a85a2c5610b5..b6e20949624dc 100644 --- a/src/osd/OpRequest.cc +++ b/src/osd/OpRequest.cc @@ -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" @@ -36,8 +38,12 @@ OpRequest::OpRequest(Message *req, OpTracker *tracker) : reqid = static_cast(req)->get_reqid(); } else if (req->get_type() == MSG_OSD_SUBOP) { reqid = static_cast(req)->reqid; + } else if (req->get_type() == MSG_OSD_SUBOPREPLY) { + reqid = static_cast(req)->reqid; } else if (req->get_type() == MSG_OSD_REPOP) { reqid = static_cast(req)->reqid; + } else if (req->get_type() == MSG_OSD_REPOPREPLY) { + reqid = static_cast(req)->reqid; } req_src_inst = req->get_source_inst(); mark_event("header_read", request->get_recv_stamp()); -- 2.39.5