return *_dout << pgb->get_parent()->gen_dbg_prefix();
}
+struct ReplicatedBackend::C_OSD_RepModifyApply : public Context {
+ ReplicatedBackend *pg;
+ RepModifyRef rm;
+ C_OSD_RepModifyApply(ReplicatedBackend *pg, RepModifyRef r)
+ : pg(pg), rm(r) {}
+ void finish(int r) {
+ pg->sub_op_modify_applied(rm);
+ }
+};
+
+struct ReplicatedBackend::C_OSD_RepModifyCommit : public Context {
+ ReplicatedBackend *pg;
+ RepModifyRef rm;
+ C_OSD_RepModifyCommit(ReplicatedBackend *pg, RepModifyRef r)
+ : pg(pg), rm(r) {}
+ void finish(int r) {
+ pg->sub_op_modify_commit(rm);
+ }
+};
+
static void log_subop_stats(
PerfCounters *logger,
OpRequestRef op, int subop)
};
typedef ceph::shared_ptr<RepModify> RepModifyRef;
- struct C_OSD_RepModifyApply : public Context {
- ReplicatedBackend *pg;
- RepModifyRef rm;
- C_OSD_RepModifyApply(ReplicatedBackend *pg, RepModifyRef r)
- : pg(pg), rm(r) {}
- void finish(int r) {
- pg->sub_op_modify_applied(rm);
- }
- };
- struct C_OSD_RepModifyCommit : public Context {
- ReplicatedBackend *pg;
- RepModifyRef rm;
- C_OSD_RepModifyCommit(ReplicatedBackend *pg, RepModifyRef r)
- : pg(pg), rm(r) {}
- void finish(int r) {
- pg->sub_op_modify_commit(rm);
- }
- };
+ struct C_OSD_RepModifyApply;
+ struct C_OSD_RepModifyCommit;
+
void sub_op_modify_applied(RepModifyRef rm);
void sub_op_modify_commit(RepModifyRef rm);
bool scrub_supported() { return true; }