From ff8dccda951db39fd9b669e167b4366fb26323c0 Mon Sep 17 00:00:00 2001 From: Radoslaw Zarzynski Date: Mon, 11 Jul 2022 16:39:59 +0000 Subject: [PATCH] osd: write_log_and_missing variants of PGLog take DoutPrefixProvider Signed-off-by: Radoslaw Zarzynski --- src/osd/PGLog.cc | 19 ++++++++++++------- src/osd/PGLog.h | 12 ++++++++---- 2 files changed, 20 insertions(+), 11 deletions(-) diff --git a/src/osd/PGLog.cc b/src/osd/PGLog.cc index c61e819f908..2a4b1d1513a 100644 --- a/src/osd/PGLog.cc +++ b/src/osd/PGLog.cc @@ -649,7 +649,8 @@ void PGLog::write_log_and_missing( dirty_from_dups, write_from_dups, &may_include_deletes_in_missing_dirty, - (pg_log_debug ? &log_keys_debug : nullptr)); + (pg_log_debug ? &log_keys_debug : nullptr), + this); undirty(); } else { dout(10) << "log is not dirty" << dendl; @@ -663,14 +664,15 @@ void PGLog::write_log_and_missing_wo_missing( pg_log_t &log, const coll_t& coll, const ghobject_t &log_oid, map &divergent_priors, - bool require_rollback + bool require_rollback, + const DoutPrefixProvider *dpp ) { _write_log_and_missing_wo_missing( t, km, log, coll, log_oid, divergent_priors, eversion_t::max(), eversion_t(), eversion_t(), true, true, require_rollback, - eversion_t::max(), eversion_t(), eversion_t(), nullptr); + eversion_t::max(), eversion_t(), eversion_t(), nullptr, dpp); } // static @@ -682,7 +684,8 @@ void PGLog::write_log_and_missing( const ghobject_t &log_oid, const pg_missing_tracker_t &missing, bool require_rollback, - bool *may_include_deletes_in_missing_dirty) + bool *may_include_deletes_in_missing_dirty, + const DoutPrefixProvider *dpp) { _write_log_and_missing( t, km, log, coll, log_oid, @@ -696,7 +699,7 @@ void PGLog::write_log_and_missing( eversion_t::max(), eversion_t(), eversion_t(), - may_include_deletes_in_missing_dirty, nullptr); + may_include_deletes_in_missing_dirty, nullptr, dpp); } // static @@ -715,7 +718,8 @@ void PGLog::_write_log_and_missing_wo_missing( eversion_t dirty_to_dups, eversion_t dirty_from_dups, eversion_t write_from_dups, - set *log_keys_debug + set *log_keys_debug, + const DoutPrefixProvider *dpp ) { // dout(10) << "write_log_and_missing, clearing up to " << dirty_to << dendl; @@ -833,7 +837,8 @@ void PGLog::_write_log_and_missing( eversion_t dirty_from_dups, eversion_t write_from_dups, bool *may_include_deletes_in_missing_dirty, // in/out param - set *log_keys_debug + set *log_keys_debug, + const DoutPrefixProvider *dpp ) { set to_remove; to_remove.swap(trimmed_dups); diff --git a/src/osd/PGLog.h b/src/osd/PGLog.h index a3f14c59f6b..15951c4412b 100644 --- a/src/osd/PGLog.h +++ b/src/osd/PGLog.h @@ -1334,7 +1334,8 @@ public: pg_log_t &log, const coll_t& coll, const ghobject_t &log_oid, std::map &divergent_priors, - bool require_rollback); + bool require_rollback, + const DoutPrefixProvider *dpp = nullptr); static void write_log_and_missing( ObjectStore::Transaction& t, @@ -1344,7 +1345,8 @@ public: const ghobject_t &log_oid, const pg_missing_tracker_t &missing, bool require_rollback, - bool *rebuilt_missing_set_with_deletes); + bool *rebuilt_missing_set_with_deletes, + const DoutPrefixProvider *dpp = nullptr); static void _write_log_and_missing_wo_missing( ObjectStore::Transaction& t, @@ -1361,7 +1363,8 @@ public: eversion_t dirty_to_dups, eversion_t dirty_from_dups, eversion_t write_from_dups, - std::set *log_keys_debug + std::set *log_keys_debug, + const DoutPrefixProvider *dpp = nullptr ); static void _write_log_and_missing( @@ -1382,7 +1385,8 @@ public: eversion_t dirty_from_dups, eversion_t write_from_dups, bool *may_include_deletes_in_missing_dirty, - std::set *log_keys_debug + std::set *log_keys_debug, + const DoutPrefixProvider *dpp = nullptr ); void read_log_and_missing( -- 2.39.5