[this, pg]() mutable -> PG::load_obc_iertr::future<> {
logger().debug("{}: got obc lock", *this);
op_info.set_from_op(&*m, *pg->get_osdmap());
- return pg->with_locked_obc(m, op_info, this, [this, pg](auto obc) mutable {
+ return pg->with_locked_obc(m, op_info, [this, pg](auto obc) mutable {
return with_blocking_future_interruptible<IOInterruptCondition>(
- handle.enter(pp(*pg).process)).then_interruptible(
- [this, pg, obc]() mutable {
+ handle.enter(pp(*pg).process)
+ ).then_interruptible([this, pg, obc]() mutable {
return do_process(pg, obc);
});
});
PG::load_obc_iertr::future<>
PG::with_locked_obc(Ref<MOSDOp> &m, const OpInfo &op_info,
- Operation *op, with_obc_func_t &&f)
+ with_obc_func_t &&f)
{
if (__builtin_expect(stopping, false)) {
throw crimson::common::system_shutdown_exception();