From: Samuel Just <sam.just@inktank.com>
Date: Thu, 21 Mar 2013 20:18:41 +0000 (-0700)
Subject: PG: add helper for rejecting backfill reservation
X-Git-Tag: v0.62~184^2~5
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=cd7353938e1f611fd0e8ae46d34a29ea7a519cc2;p=ceph.git

PG: add helper for rejecting backfill reservation

Signed-off-by: Samuel Just <sam.just@inktank.com>
---

diff --git a/src/osd/PG.cc b/src/osd/PG.cc
index 1c6450eadae..ab5d3158e1f 100644
--- a/src/osd/PG.cc
+++ b/src/osd/PG.cc
@@ -3294,6 +3294,17 @@ void PG::sub_op_scrub_stop(OpRequestRef op)
   osd->send_message_osd_cluster(reply, m->get_connection());
 }
 
+void PG::reject_reservation()
+{
+  osd->send_message_osd_cluster(
+    acting[0],
+    new MBackfillReserve(
+      MBackfillReserve::REJECT,
+      info.pgid,
+      get_osdmap()->get_epoch()),
+    get_osdmap()->get_epoch());
+}
+
 void PG::clear_scrub_reserved()
 {
   osd->scrub_wq.dequeue(this);
@@ -6102,13 +6113,7 @@ boost::statechart::result
 PG::RecoveryState::RepWaitBackfillReserved::react(const RemoteReservationRejected &evt)
 {
   PG *pg = context< RecoveryMachine >().pg;
-  pg->osd->send_message_osd_cluster(
-    pg->acting[0],
-    new MBackfillReserve(
-      MBackfillReserve::REJECT,
-      pg->info.pgid,
-      pg->get_osdmap()->get_epoch()),
-    pg->get_osdmap()->get_epoch());
+  pg->reject_reservation();
   return transit<RepNotRecovering>();
 }
 
diff --git a/src/osd/PG.h b/src/osd/PG.h
index b24c74f8bf5..60c13fc1407 100644
--- a/src/osd/PG.h
+++ b/src/osd/PG.h
@@ -1050,6 +1050,7 @@ public:
   void sub_op_scrub_unreserve(OpRequestRef op);
   void sub_op_scrub_stop(OpRequestRef op);
 
+  void reject_reservation();
 
   // -- recovery state --