C_OSD_RepModifyApply(ReplicatedBackend *pg, RepModifyRef r)
: pg(pg), rm(r) {}
void finish(int r) override {
- pg->sub_op_modify_applied(rm);
+ pg->repop_applied(rm);
}
};
C_OSD_RepModifyCommit(ReplicatedBackend *pg, RepModifyRef r)
: pg(pg), rm(r) {}
void finish(int r) override {
- pg->sub_op_modify_commit(rm);
+ pg->repop_commit(rm);
}
};
}
case MSG_OSD_REPOP: {
- sub_op_modify(op);
+ do_repop(op);
return true;
}
case MSG_OSD_REPOPREPLY: {
- sub_op_modify_reply(op);
+ do_repop_reply(op);
return true;
}
}
}
-void ReplicatedBackend::sub_op_modify_reply(OpRequestRef op)
+void ReplicatedBackend::do_repop_reply(OpRequestRef op)
{
static_cast<MOSDRepOpReply*>(op->get_nonconst_req())->finish_decode();
const MOSDRepOpReply *r = static_cast<const MOSDRepOpReply *>(op->get_req());
}
// sub op modify
-void ReplicatedBackend::sub_op_modify(OpRequestRef op)
+void ReplicatedBackend::do_repop(OpRequestRef op)
{
static_cast<MOSDRepOp*>(op->get_nonconst_req())->finish_decode();
const MOSDRepOp *m = static_cast<const MOSDRepOp *>(op->get_req());
// op is cleaned up by oncommit/onapply when both are executed
}
-void ReplicatedBackend::sub_op_modify_applied(RepModifyRef rm)
+void ReplicatedBackend::repop_applied(RepModifyRef rm)
{
rm->op->mark_event("sub_op_applied");
rm->applied = true;
parent->op_applied(version);
}
-void ReplicatedBackend::sub_op_modify_commit(RepModifyRef rm)
+void ReplicatedBackend::repop_commit(RepModifyRef rm)
{
rm->op->mark_commit_sent();
rm->committed = true;
ObjectStore::Transaction &op_t);
void op_applied(InProgressOp *op);
void op_commit(InProgressOp *op);
- void sub_op_modify_reply(OpRequestRef op);
- void sub_op_modify(OpRequestRef op);
+ void do_repop_reply(OpRequestRef op);
+ void do_repop(OpRequestRef op);
struct RepModify {
OpRequestRef op;
struct C_OSD_RepModifyApply;
struct C_OSD_RepModifyCommit;
- void sub_op_modify_applied(RepModifyRef rm);
- void sub_op_modify_commit(RepModifyRef rm);
+ void repop_applied(RepModifyRef rm);
+ void repop_commit(RepModifyRef rm);
bool scrub_supported() override { return true; }
bool auto_repair_supported() const override { return false; }