f(SCRUB, __CEPH_OSD_OP1(SUB, 5), "scrub") \
f(SCRUB_RESERVE, __CEPH_OSD_OP1(SUB, 6), "scrub-reserve") \
f(SCRUB_UNRESERVE, __CEPH_OSD_OP1(SUB, 7), "scrub-unreserve") \
- f(SCRUB_STOP, __CEPH_OSD_OP1(SUB, 8), "scrub-stop") \
- f(SCRUB_MAP, __CEPH_OSD_OP1(SUB, 9), "scrub-map") \
+ f(SCRUB_MAP, __CEPH_OSD_OP1(SUB, 8), "scrub-map") \
\
/** exec **/ \
/* note: the RD bit here is wrong; see special-case below in helper */ \
clear_scrub_reserved();
}
-void PG::sub_op_scrub_stop(OpRequestRef op)
-{
- op->mark_started();
-
- MOSDSubOp *m = static_cast<MOSDSubOp*>(op->get_req());
- assert(m->get_type() == MSG_OSD_SUBOP);
- dout(7) << "sub_op_scrub_stop" << dendl;
-
- // see comment in sub_op_scrub_reserve
- scrubber.reserved = false;
-
- MOSDSubOpReply *reply = new MOSDSubOpReply(
- m, pg_whoami, 0, get_osdmap()->get_epoch(), CEPH_OSD_FLAG_ACK);
- osd->send_message_osd_cluster(reply, m->get_connection());
-}
-
void PG::reject_reservation()
{
osd->send_message_osd_cluster(
void sub_op_scrub_reserve(OpRequestRef op);
void sub_op_scrub_reserve_reply(OpRequestRef op);
void sub_op_scrub_unreserve(OpRequestRef op);
- void sub_op_scrub_stop(OpRequestRef op);
void reject_reservation();
void schedule_backfill_full_retry();
case CEPH_OSD_OP_SCRUB_UNRESERVE:
sub_op_scrub_unreserve(op);
return;
- case CEPH_OSD_OP_SCRUB_STOP:
- sub_op_scrub_stop(op);
- return;
case CEPH_OSD_OP_SCRUB_MAP:
sub_op_scrub_map(op);
return;