crimson/osd: move PG::with_locked_obc() into .cc

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/crimson/osd/pg.cc b/src/crimson/osd/pg.cc
index eab8452b8d5e8af898059afdd09262305aa90771..f05d6f4d6979efd3c211a66043863ccfc5e89320 100644 (file)
--- a/src/crimson/osd/pg.cc
+++ b/src/crimson/osd/pg.cc
@@ -865,6 +865,23 @@ PG::load_head_obc(ObjectContextRef obc)
   });
 }
 
+PG::load_obc_ertr::future<>
+PG::with_locked_obc(Ref<MOSDOp> &m, const OpInfo &op_info,
+                   Operation *op, PG::with_obc_func_t &&f)
+{
+  if (__builtin_expect(stopping, false)) {
+    throw crimson::common::system_shutdown_exception();
+  }
+  RWState::State type = get_lock_type(op_info);
+  return get_locked_obc(op, get_oid(*m), type)
+    .safe_then([f=std::move(f), type=type](auto obc) {
+    return f(obc).finally([obc, type=type] {
+      obc->put_lock_type(type);
+      return load_obc_ertr::now();
+    });
+  });
+}
+
 PG::load_obc_ertr::future<crimson::osd::ObjectContextRef>
 PG::get_locked_obc(
   Operation *op, const hobject_t &oid, RWState::State type)

diff --git a/src/crimson/osd/pg.h b/src/crimson/osd/pg.h
index 930aa5e73d913cae3128b3c51e46fe8319c4a15e..9cd17c5054a267c5aed754fb6c1344de55897543 100644 (file)
--- a/src/crimson/osd/pg.h
+++ b/src/crimson/osd/pg.h
@@ -513,24 +513,12 @@ public:
     const hobject_t &oid,
     RWState::State type);
 public:
-  template <typename F>
-  auto with_locked_obc(
+  using with_obc_func_t = std::function<seastar::future<> (ObjectContextRef)>;
+  load_obc_ertr::future<> with_locked_obc(
     Ref<MOSDOp> &m,
     const OpInfo &op_info,
     Operation *op,
-    F &&f) {
-    if (__builtin_expect(stopping, false)) {
-      throw crimson::common::system_shutdown_exception();
-    }
-    RWState::State type = get_lock_type(op_info);
-    return get_locked_obc(op, get_oid(*m), type)
-      .safe_then([f=std::forward<F>(f), type=type](auto obc) {
-       return f(obc).finally([obc, type=type] {
-         obc->put_lock_type(type);
-         return load_obc_ertr::now();
-       });
-      });
-  }
+    with_obc_func_t&& f);
 
   seastar::future<> handle_rep_op(Ref<MOSDRepOp> m);
   void handle_rep_op_reply(crimson::net::Connection* conn,