const eversion_t &at_version,
PGTransactionUPtr &&t,
const eversion_t &trim_to,
- const eversion_t &roll_forward_to,
+ const eversion_t &min_last_complete_ondisk,
const vector<pg_log_entry_t> &log_entries,
std::optional<pg_hit_set_history_t> &hset_history,
Context *on_all_commit,
op->delta_stats = delta_stats;
op->version = at_version;
op->trim_to = trim_to;
- op->roll_forward_to = std::max(roll_forward_to, committed_to);
+ op->roll_forward_to = std::max(min_last_complete_ondisk, committed_to);
op->log_entries = log_entries;
std::swap(op->updated_hit_set_history, hset_history);
op->on_all_commit = on_all_commit;
const eversion_t &at_version,
PGTransactionUPtr &&t,
const eversion_t &trim_to,
- const eversion_t &roll_forward_to,
+ const eversion_t &min_last_complete_ondisk,
const vector<pg_log_entry_t> &log_entries,
std::optional<pg_hit_set_history_t> &hset_history,
Context *on_all_commit,
const eversion_t &at_version, ///< [in] version
PGTransactionUPtr &&t, ///< [in] trans to execute (move)
const eversion_t &trim_to, ///< [in] trim log to here
- const eversion_t &roll_forward_to, ///< [in] trim rollback info to here
+ const eversion_t &min_last_complete_ondisk, ///< [in] lower bound on
+ /// committed version
const vector<pg_log_entry_t> &log_entries, ///< [in] log entries for t
/// [in] hitset history (if updated with this transaction)
std::optional<pg_hit_set_history_t> &hset_history,
const eversion_t &at_version,
PGTransactionUPtr &&t,
const eversion_t &trim_to,
- const eversion_t &roll_forward_to,
+ const eversion_t &min_last_complete_ondisk,
const vector<pg_log_entry_t> &log_entries,
std::optional<pg_hit_set_history_t> &hset_history,
Context *on_all_commit,