osd,crimson/osd: pg_committed_to rather than mlcod for submit_log_entries

This matches the behavior for normal IOs.

Signed-off-by: Samuel Just <sjust@redhat.com>

diff --git a/src/crimson/osd/pg.cc b/src/crimson/osd/pg.cc
index 0b5dcaa0eec411e609df953f838f589b6fffb431..7c88dbc4e8cc45b51da5b024bc1199b70a167313 100644 (file)
--- a/src/crimson/osd/pg.cc
+++ b/src/crimson/osd/pg.cc
@@ -1034,7 +1034,7 @@ PG::interruptible_future<eversion_t> PG::submit_error_log(
   ceph::os::Transaction t;
   peering_state.merge_new_log_entries(
     log_entries, t, peering_state.get_pg_trim_to(),
-    peering_state.get_min_last_complete_ondisk());
+    peering_state.get_pg_committed_to());
 
   return seastar::do_with(log_entries, set<pg_shard_t>{},
     [this, t=std::move(t), rep_tid](auto& log_entries, auto& waiting_on) mutable {
@@ -1055,7 +1055,7 @@ PG::interruptible_future<eversion_t> PG::submit_error_log(
                    get_last_peering_reset(),
                    rep_tid,
                    peering_state.get_pg_trim_to(),
-                   peering_state.get_min_last_complete_ondisk());
+                   peering_state.get_pg_committed_to());
       waiting_on.insert(peer);
       logger().debug("submit_error_log: sending log"
         "missing_request (rep_tid: {} entries: {})"

diff --git a/src/osd/PrimaryLogPG.cc b/src/osd/PrimaryLogPG.cc
index 563658464443fcfad75735d226770950d668de9d..17805fa6683d2c53e803aab828d6b64a87c491e6 100644 (file)
--- a/src/osd/PrimaryLogPG.cc
+++ b/src/osd/PrimaryLogPG.cc
@@ -11623,7 +11623,7 @@ void PrimaryLogPG::submit_log_entries(
       eversion_t old_last_update = info.last_update;
       recovery_state.merge_new_log_entries(
        entries, t, recovery_state.get_pg_trim_to(),
-       recovery_state.get_min_last_complete_ondisk());
+       recovery_state.get_pg_committed_to());
 
       set<pg_shard_t> waiting_on;
       for (set<pg_shard_t>::const_iterator i = get_acting_recovery_backfill().begin();
@@ -11643,7 +11643,7 @@ void PrimaryLogPG::submit_log_entries(
            get_last_peering_reset(),
            repop->rep_tid,
            recovery_state.get_pg_trim_to(),
-           recovery_state.get_min_last_complete_ondisk());
+           recovery_state.get_pg_committed_to());
          osd->send_message_osd_cluster(
            peer.osd, m, get_osdmap_epoch());
          waiting_on.insert(peer);