crimson/osd: drop ShardServices::_sent_pg_temp()

there is no need to define a wrapper for moving pg_temp_wanted to
pg_temp_pending. and it hurts the readability.

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/crimson/osd/shard_services.cc b/src/crimson/osd/shard_services.cc
index e96a8e6ca888d64f41fe1d0b4d445a7af31a3fe9..4e393df8446186b3d289b20571dc285d90b87b8e 100644 (file)
--- a/src/crimson/osd/shard_services.cc
+++ b/src/crimson/osd/shard_services.cc
@@ -161,17 +161,12 @@ void ShardServices::remove_want_pg_temp(pg_t pgid)
   pg_temp_pending.erase(pgid);
 }
 
-void ShardServices::_sent_pg_temp()
-{
-  pg_temp_pending.merge(pg_temp_wanted);
-}
-
 void ShardServices::requeue_pg_temp()
 {
   unsigned old_wanted = pg_temp_wanted.size();
   unsigned old_pending = pg_temp_pending.size();
-  _sent_pg_temp();
-  pg_temp_wanted.swap(pg_temp_pending);
+  pg_temp_wanted.merge(pg_temp_pending);
+  pg_temp_pending.clear();
   logger().debug(
     "{}: {} + {} -> {}",
     __func__ ,
@@ -213,7 +208,8 @@ seastar::future<> ShardServices::send_pg_temp()
        return seastar::now();
       }
     }).then([this] {
-      _sent_pg_temp();
+      pg_temp_pending.merge(pg_temp_wanted);
+      pg_temp_wanted.clear();
     });
 }
 

diff --git a/src/crimson/osd/shard_services.h b/src/crimson/osd/shard_services.h
index 934e91437113aaae8158b5152f297ba38ee46cf9..2957639c6347139c69aecdba27215e2db4848c1b 100644 (file)
--- a/src/crimson/osd/shard_services.h
+++ b/src/crimson/osd/shard_services.h
@@ -142,7 +142,6 @@ private:
   };
   map<pg_t, pg_temp_t> pg_temp_wanted;
   map<pg_t, pg_temp_t> pg_temp_pending;
-  void _sent_pg_temp();
   friend std::ostream& operator<<(std::ostream&, const pg_temp_t&);
 public:
   void queue_want_pg_temp(pg_t pgid, const vector<int>& want,