OSD: Adds handler for MOSDRepScrub

handle_rep_scrub enqueues the message in rep_scrub_wq.

Signed-off-by: Samuel Just <samuel.just@dreamhost.com>

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index c7e549b5031e0a0d73a188729660f0a8c3f5de65..0265467162d68cee6d2694737d0177aa5fd106b7 100644 (file)
--- 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 6d8f0826dc87e684f1c3940aaead0f88a345fac7..910beae5670836e59177943fc36f960ea752b9e9 100644 (file)
--- 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);