From cd7353938e1f611fd0e8ae46d34a29ea7a519cc2 Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Thu, 21 Mar 2013 13:18:41 -0700 Subject: [PATCH] PG: add helper for rejecting backfill reservation Signed-off-by: Samuel Just --- src/osd/PG.cc | 19 ++++++++++++------- src/osd/PG.h | 1 + 2 files changed, 13 insertions(+), 7 deletions(-) diff --git a/src/osd/PG.cc b/src/osd/PG.cc index 1c6450eadaeb4..ab5d3158e1f26 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(); } diff --git a/src/osd/PG.h b/src/osd/PG.h index b24c74f8bf590..60c13fc1407e5 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 -- -- 2.39.5