void PeeringState::clear_blocked_outgoing() {
ceph_assert(orig_ctx);
ceph_assert(rctx);
- messages_pending_flush = boost::optional<BufferedRecoveryMessages>();
+ messages_pending_flush = std::optional<BufferedRecoveryMessages>();
}
void PeeringState::end_block_outgoing() {
orig_ctx->accept_buffered_messages(*messages_pending_flush);
rctx.emplace(*orig_ctx);
- messages_pending_flush = boost::optional<BufferedRecoveryMessages>();
+ messages_pending_flush = std::optional<BufferedRecoveryMessages>();
}
void PeeringState::end_handle() {
bool PeeringState::append_log_entries_update_missing(
const mempool::osd_pglog::list<pg_log_entry_t> &entries,
- ObjectStore::Transaction &t, boost::optional<eversion_t> trim_to,
- boost::optional<eversion_t> roll_forward_to)
+ ObjectStore::Transaction &t, std::optional<eversion_t> trim_to,
+ std::optional<eversion_t> roll_forward_to)
{
ceph_assert(!entries.empty());
ceph_assert(entries.begin()->version > info.last_update);
void PeeringState::merge_new_log_entries(
const mempool::osd_pglog::list<pg_log_entry_t> &entries,
ObjectStore::Transaction &t,
- boost::optional<eversion_t> trim_to,
- boost::optional<eversion_t> roll_forward_to)
+ std::optional<eversion_t> trim_to,
+ std::optional<eversion_t> roll_forward_to)
{
psdout(10) << __func__ << " " << entries << dendl;
ceph_assert(is_primary());
PeeringCtx *orig_ctx;
/// populated if we are buffering messages pending a flush
- boost::optional<BufferedRecoveryMessages> messages_pending_flush;
+ std::optional<BufferedRecoveryMessages> messages_pending_flush;
/**
* populated between start_handle() and end_handle(), points into
bool append_log_entries_update_missing(
const mempool::osd_pglog::list<pg_log_entry_t> &entries,
ObjectStore::Transaction &t,
- boost::optional<eversion_t> trim_to,
- boost::optional<eversion_t> roll_forward_to);
+ std::optional<eversion_t> trim_to,
+ std::optional<eversion_t> roll_forward_to);
/**
* Updates local log to reflect new write from primary.
void merge_new_log_entries(
const mempool::osd_pglog::list<pg_log_entry_t> &entries,
ObjectStore::Transaction &t,
- boost::optional<eversion_t> trim_to,
- boost::optional<eversion_t> roll_forward_to);
+ std::optional<eversion_t> trim_to,
+ std::optional<eversion_t> roll_forward_to);
/// Update missing set to reflect e (TODOSAM: not sure why this is needed)
void add_local_next_event(const pg_log_entry_t& e) {