crimson/common/smp_helpers: rename reactor_map_seq

Signed-off-by: Matan Breizman <mbreizma@redhat.com>

diff --git a/src/crimson/admin/osd_admin.cc b/src/crimson/admin/osd_admin.cc
index b19791c021c9b70585434c750832909e88fbaf7b..5a290c8b37426b74021005ee52ea07bb9106353a 100644 (file)
--- a/src/crimson/admin/osd_admin.cc
+++ b/src/crimson/admin/osd_admin.cc
@@ -341,7 +341,7 @@ public:
     cmd_getval(cmdmap, "group", prefix);
     fref->open_object_section("metrics");
     fref->open_array_section("metrics");
-    co_await crimson::reactor_map_seq([f = fref.get(), &prefix] {
+    co_await crimson::invoke_on_all_seq([f = fref.get(), &prefix] {
       for (const auto& [full_name, metric_family]: seastar::scollectd::get_value_map()) {
         if (!prefix.empty() && full_name.compare(0, prefix.size(), prefix) != 0) {
           continue;

diff --git a/src/crimson/common/smp_helpers.h b/src/crimson/common/smp_helpers.h
index 78ab118c185156759aa75efffea28826b197dd48..70ba701bcd22a389ff0aefd4bdb520036a9f9f33 100644 (file)
--- a/src/crimson/common/smp_helpers.h
+++ b/src/crimson/common/smp_helpers.h
@@ -47,14 +47,14 @@ auto proxy_method_on_core(
 }
 
 /**
- * reactor_map_seq
+ * invoke_on_all_seq
  *
  * Invokes f on each reactor sequentially, Caller may assume that
  * f will not be invoked concurrently on multiple cores.
  * f is copied here and is kept alive due to coroutine parameter copying.
  */
 template <typename F>
-auto reactor_map_seq(F f) -> decltype(seastar::futurize_invoke(f)) {
+auto invoke_on_all_seq(F f) -> decltype(seastar::futurize_invoke(f)) {
   for (auto core: seastar::smp::all_cpus()) {
     using ret_type = decltype(f());
     if constexpr (is_errorated_future_v<ret_type>) {
@@ -73,7 +73,7 @@ auto reactor_map_seq(F f) -> decltype(seastar::futurize_invoke(f)) {
  */
 template <typename T, typename F>
 auto sharded_map_seq(T &t, F &&f) {
-  return reactor_map_seq(
+  return invoke_on_all_seq(
     [&t, f=std::forward<F>(f)]() mutable {
       return std::invoke(f, t.local());
     });