]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
PeeringState: switch remaining boost::optional users
authorSamuel Just <sjust@redhat.com>
Fri, 3 May 2019 19:14:09 +0000 (12:14 -0700)
committerSamuel Just <sjust@redhat.com>
Fri, 10 May 2019 00:22:26 +0000 (17:22 -0700)
Signed-off-by: Samuel Just <sjust@redhat.com>
src/osd/PeeringState.cc
src/osd/PeeringState.h

index 75f56677a67d24cf456426d81cc7042cc3906c69..3025c2aa776e398958d2a1f384b6e60066223a23 100644 (file)
@@ -161,7 +161,7 @@ void PeeringState::begin_block_outgoing() {
 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() {
@@ -171,7 +171,7 @@ 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() {
@@ -3436,8 +3436,8 @@ void PeeringState::update_stats(
 
 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);
@@ -3478,8 +3478,8 @@ bool PeeringState::append_log_entries_update_missing(
 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());
index c11dfa71be29954f2dfa05c2ee0816f9bd051c28..9d9a27cf05c7fa74f4431843e6b420c06131f5d1 100644 (file)
@@ -1212,7 +1212,7 @@ public:
   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
@@ -1619,8 +1619,8 @@ public:
   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.
@@ -1639,8 +1639,8 @@ public:
   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) {