From 03c7b062d16388a9bee8a6354df8d12f5a2b11c6 Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Fri, 4 Feb 2011 17:00:58 -0800 Subject: [PATCH] OSD: Adds handler for MOSDRepScrub handle_rep_scrub enqueues the message in rep_scrub_wq. Signed-off-by: Samuel Just --- src/osd/OSD.cc | 10 ++++++++++ src/osd/OSD.h | 1 + 2 files changed, 11 insertions(+) diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc index c7e549b5031e0..0265467162d68 100644 --- a/src/osd/OSD.cc +++ b/src/osd/OSD.cc @@ -63,6 +63,7 @@ #include "messages/MOSDAlive.h" #include "messages/MOSDScrub.h" +#include "messages/MOSDRepScrub.h" #include "messages/MMonCommand.h" @@ -2215,6 +2216,10 @@ void OSD::_dispatch(Message *m) handle_scrub((MOSDScrub*)m); break; + case MSG_OSD_REP_SCRUB: + handle_rep_scrub((MOSDRepScrub*)m); + break; + case MSG_CLASS: handle_class((MClass*)m); break; @@ -2279,6 +2284,11 @@ void OSD::_dispatch(Message *m) } +void OSD::handle_rep_scrub(MOSDRepScrub *m) +{ + dout(10) << "queueing MOSDRepScrub " << *m << dendl; + rep_scrub_wq.queue(m); +} void OSD::handle_scrub(MOSDScrub *m) { diff --git a/src/osd/OSD.h b/src/osd/OSD.h index 6d8f0826dc87e..910beae567083 100644 --- a/src/osd/OSD.h +++ b/src/osd/OSD.h @@ -1012,6 +1012,7 @@ public: void reply_op_error(MOSDOp *op, int r); void handle_misdirected_op(PG *pg, MOSDOp *op); + void handle_rep_scrub(MOSDRepScrub *m); void handle_scrub(class MOSDScrub *m); void handle_osd_ping(class MOSDPing *m); void handle_op(class MOSDOp *m); -- 2.39.5