From dbbd2d32f3abfa22023eed3e29d12cdf1e2b64cd Mon Sep 17 00:00:00 2001 From: Kefu Chai Date: Sun, 1 Nov 2020 11:14:48 +0800 Subject: [PATCH] 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 --- src/crimson/osd/shard_services.cc | 12 ++++-------- src/crimson/osd/shard_services.h | 1 - 2 files changed, 4 insertions(+), 9 deletions(-) diff --git a/src/crimson/osd/shard_services.cc b/src/crimson/osd/shard_services.cc index e96a8e6ca888..4e393df84461 100644 --- 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 934e91437113..2957639c6347 100644 --- a/src/crimson/osd/shard_services.h +++ b/src/crimson/osd/shard_services.h @@ -142,7 +142,6 @@ private: }; map pg_temp_wanted; map 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& want, -- 2.47.3