From: Kefu Chai Date: Tue, 14 Jan 2020 05:50:16 +0000 (+0800) Subject: crimson: move PG::prepare_write() to .cc file X-Git-Tag: v15.1.0~219^2~1 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=95f28bd4a6909aca9a19bd91dcbfaf07682bdfe5;p=ceph.git crimson: move PG::prepare_write() to .cc file less cluttered this way Signed-off-by: Kefu Chai --- diff --git a/src/crimson/osd/pg.cc b/src/crimson/osd/pg.cc index 28953c0bd03d..3955dd7765d2 100644 --- a/src/crimson/osd/pg.cc +++ b/src/crimson/osd/pg.cc @@ -233,6 +233,39 @@ void PG::on_activate_complete() } } +void PG::prepare_write(pg_info_t &info, + pg_info_t &last_written_info, + PastIntervals &past_intervals, + PGLog &pglog, + bool dirty_info, + bool dirty_big_info, + bool need_write_epoch, + ceph::os::Transaction &t) +{ + std::map km; + if (dirty_big_info || dirty_info) { + int ret = prepare_info_keymap( + shard_services.get_cct(), + &km, + get_osdmap_epoch(), + info, + last_written_info, + past_intervals, + dirty_big_info, + need_write_epoch, + true, + nullptr, + this); + ceph_assert(ret == 0); + } + pglog.write_log_and_missing( + t, &km, coll, pgmeta_oid, + peering_state.get_pool().info.require_rollback()); + if (!km.empty()) { + t.omap_setkeys(coll, pgmeta_oid, km); + } +} + void PG::log_state_enter(const char *state) { logger().info("Entering state: {}", state); } diff --git a/src/crimson/osd/pg.h b/src/crimson/osd/pg.h index 9374830c33a3..ad4aadde24ca 100644 --- a/src/crimson/osd/pg.h +++ b/src/crimson/osd/pg.h @@ -119,29 +119,7 @@ public: bool dirty_info, bool dirty_big_info, bool need_write_epoch, - ceph::os::Transaction &t) final { - std::map km; - if (dirty_big_info || dirty_info) { - int ret = prepare_info_keymap( - shard_services.get_cct(), - &km, - get_osdmap_epoch(), - info, - last_written_info, - past_intervals, - dirty_big_info, - need_write_epoch, - true, - nullptr, - this); - ceph_assert(ret == 0); - } - pglog.write_log_and_missing( - t, &km, coll, pgmeta_oid, - peering_state.get_pool().info.require_rollback()); - if (!km.empty()) - t.omap_setkeys(coll, pgmeta_oid, km); - } + ceph::os::Transaction &t) final; void on_info_history_change() final { // Not needed yet -- mainly for scrub scheduling