This will be used once we'll call complete_write from
ReplicatedBackend and not from PG as we do now.
Signed-off-by: Matan Breizman <mbreizma@redhat.com>
Signed-off-by: Xuehan Xu <xuxuehan@qianxin.com>
return peering_state.get_primary();
}
+ eversion_t get_last_complete() const {
+ return peering_state.get_info().last_complete;
+ }
+
+ void complete_write(eversion_t v, eversion_t lc) {
+ peering_state.complete_write(v, lc);
+ }
+
+ void update_peer_last_complete_ondisk(
+ pg_shard_t fromosd,
+ eversion_t lcod) {
+ peering_state.update_peer_last_complete_ondisk(fromosd, lcod);
+ }
+
/// initialize created PG
seastar::future<> init(
int role,