]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd: pass `const PushOp&` to _handle_pull_response()
authorKefu Chai <kchai@redhat.com>
Sat, 19 Dec 2020 11:39:48 +0000 (19:39 +0800)
committerKefu Chai <kchai@redhat.com>
Sat, 19 Dec 2020 12:02:06 +0000 (20:02 +0800)
more constness, better readability

Signed-off-by: Kefu Chai <kchai@redhat.com>
src/crimson/osd/replicated_recovery_backend.cc
src/crimson/osd/replicated_recovery_backend.h

index 40cd06fc79bfa4a7195676af376e2dbcf446a361..79b4d1a69af3d3c28b861c3c01211ca3f2845e2a 100644 (file)
@@ -581,7 +581,7 @@ seastar::future<> ReplicatedRecoveryBackend::handle_pull(Ref<MOSDPGPull> m)
 
 seastar::future<bool> ReplicatedRecoveryBackend::_handle_pull_response(
   pg_shard_t from,
-  PushOp& pop,
+  const PushOp& pop,
   PullOp* response,
   ceph::os::Transaction* t)
 {
@@ -607,7 +607,7 @@ seastar::future<bool> ReplicatedRecoveryBackend::_handle_pull_response(
       pi.recovery_info.soid, [&pi, &recovery_waiter, &pop](auto obc) {
         pi.obc = obc;
         recovery_waiter.obc = obc;
-        obc->obs.oi.decode(pop.attrset[OI_ATTR]);
+        obc->obs.oi.decode(pop.attrset.at(OI_ATTR));
         pi.recovery_info.oi = obc->obs.oi;
         return crimson::osd::PG::load_obc_ertr::now();
       }).handle_error(crimson::ct_error::assert_all{});
index 33650f3331dbe6620950e3510cd3d76f8495d4ca..98f63ca73ad2c5f9a69e1d583d1ac3faf027ce79 100644 (file)
@@ -59,9 +59,11 @@ protected:
     const ObjectRecoveryInfo& recovery_info,
     const ObjectRecoveryProgress& progress,
     object_stat_sum_t* stat);
+  /// @returns true if this push op is the last push op for
+  ///          recovery @c pop.soid
   seastar::future<bool> _handle_pull_response(
     pg_shard_t from,
-    PushOp& pop,
+    const PushOp& pop,
     PullOp* response,
     ceph::os::Transaction* t);
   std::pair<interval_set<uint64_t>, ceph::bufferlist> trim_pushed_data(