case CEPH_OSD_OP_SYNC_READ:
[[fallthrough]];
case CEPH_OSD_OP_READ:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.read(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_SPARSE_READ:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.sparse_read(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_CHECKSUM:
- return do_read_op([&osd_op] (auto& backend, const auto& os) {
+ return do_read_op([&osd_op](auto& backend, const auto& os) {
return backend.checksum(os, osd_op);
});
case CEPH_OSD_OP_CMPEXT:
- return do_read_op([&osd_op] (auto& backend, const auto& os) {
+ return do_read_op([&osd_op](auto& backend, const auto& os) {
return backend.cmp_ext(os, osd_op);
});
case CEPH_OSD_OP_GETXATTR:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.getxattr(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_GETXATTRS:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.get_xattrs(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_CMPXATTR:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.cmp_xattr(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_RMXATTR:
return do_write_op(
- [&osd_op] (auto& backend, auto& os, auto& txn) {
+ [&osd_op](auto& backend, auto& os, auto& txn) {
return backend.rm_xattr(os, osd_op, txn);
}, true);
case CEPH_OSD_OP_CREATE:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.create(os, osd_op, txn, delta_stats);
}, true);
case CEPH_OSD_OP_WRITE:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.write(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_WRITESAME:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.write_same(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_WRITEFULL:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.writefull(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_APPEND:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.append(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_TRUNCATE:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
// FIXME: rework needed. Move this out to do_write_op(), introduce
// do_write_op_no_user_modify()...
return backend.truncate(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_ZERO:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.zero(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_SETALLOCHINT:
return osd_op_errorator::now();
case CEPH_OSD_OP_SETXATTR:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.setxattr(os, osd_op, txn, delta_stats);
}, true);
case CEPH_OSD_OP_DELETE:
- return do_write_op([this] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this](auto& backend, auto& os, auto& txn) {
return backend.remove(os, txn, delta_stats);
}, true);
case CEPH_OSD_OP_CALL:
// OMAP
case CEPH_OSD_OP_OMAPGETKEYS:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.omap_get_keys(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_OMAPGETVALS:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.omap_get_vals(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_OMAP_CMP:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.omap_cmp(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_OMAPGETHEADER:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.omap_get_header(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_OMAPGETVALSBYKEYS:
- return do_read_op([this, &osd_op] (auto& backend, const auto& os) {
+ return do_read_op([this, &osd_op](auto& backend, const auto& os) {
return backend.omap_get_vals_by_keys(os, osd_op, delta_stats);
});
case CEPH_OSD_OP_OMAPSETVALS:
return crimson::ct_error::operation_not_supported::make();
}
#endif
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.omap_set_vals(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
case CEPH_OSD_OP_OMAPSETHEADER:
return crimson::ct_error::operation_not_supported::make();
}
#endif
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.omap_set_header(os, osd_op, txn, *osd_op_params,
delta_stats);
}, true);
return crimson::ct_error::operation_not_supported::make();
}
#endif
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.omap_remove_range(os, osd_op, txn, delta_stats);
}, true);
case CEPH_OSD_OP_OMAPRMKEYS:
if (!pg.get_pgpool().info.supports_omap()) {
return crimson::ct_error::operation_not_supported::make();
}*/
- return do_write_op([&osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([&osd_op](auto& backend, auto& os, auto& txn) {
return backend.omap_remove_key(os, osd_op, txn);
}, true);
case CEPH_OSD_OP_OMAPCLEAR:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return backend.omap_clear(os, osd_op, txn, *osd_op_params, delta_stats);
}, true);
// watch/notify
case CEPH_OSD_OP_WATCH:
- return do_write_op([this, &osd_op] (auto& backend, auto& os, auto& txn) {
+ return do_write_op([this, &osd_op](auto& backend, auto& os, auto& txn) {
return do_op_watch(osd_op, os, txn);
}, false);
case CEPH_OSD_OP_LIST_WATCHERS:
- return do_read_op([this, &osd_op] (auto&, const auto& os) {
+ return do_read_op([this, &osd_op](auto&, const auto& os) {
return do_op_list_watchers(osd_op, os);
});
case CEPH_OSD_OP_NOTIFY:
- return do_read_op([this, &osd_op] (auto&, const auto& os) {
+ return do_read_op([this, &osd_op](auto&, const auto& os) {
return do_op_notify(osd_op, os);
});
case CEPH_OSD_OP_NOTIFY_ACK:
- return do_read_op([this, &osd_op] (auto&, const auto& os) {
+ return do_read_op([this, &osd_op](auto&, const auto& os) {
return do_op_notify_ack(osd_op, os);
});
case CEPH_OSD_OP_ASSERT_VER:
- return do_read_op([this, &osd_op] (auto&, const auto& os) {
+ return do_read_op([this, &osd_op](auto&, const auto& os) {
return do_assert_ver(osd_op, os);
});