File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -341,7 +341,7 @@ class DumpMetricsHook : public AdminSocketHook {
341341 cmd_getval (cmdmap, " group" , prefix);
342342 fref->open_object_section (" metrics" );
343343 fref->open_array_section (" metrics" );
344- co_await crimson::reactor_map_seq ([f = fref.get (), &prefix] {
344+ co_await crimson::invoke_on_all_seq ([f = fref.get (), &prefix] {
345345 for (const auto & [full_name, metric_family]: seastar::scollectd::get_value_map ()) {
346346 if (!prefix.empty () && full_name.compare (0 , prefix.size (), prefix) != 0 ) {
347347 continue ;
Original file line number Diff line number Diff line change @@ -47,14 +47,14 @@ auto proxy_method_on_core(
4747}
4848
4949/* *
50- * reactor_map_seq
50+ * invoke_on_all_seq
5151 *
5252 * Invokes f on each reactor sequentially, Caller may assume that
5353 * f will not be invoked concurrently on multiple cores.
5454 * f is copied here and is kept alive due to coroutine parameter copying.
5555 */
5656template <typename F>
57- auto reactor_map_seq (F f) -> decltype(seastar::futurize_invoke(f)) {
57+ auto invoke_on_all_seq (F f) -> decltype(seastar::futurize_invoke(f)) {
5858 for (auto core: seastar::smp::all_cpus ()) {
5959 using ret_type = decltype (f ());
6060 if constexpr (is_errorated_future_v<ret_type>) {
@@ -73,7 +73,7 @@ auto reactor_map_seq(F f) -> decltype(seastar::futurize_invoke(f)) {
7373 */
7474template <typename T, typename F>
7575auto sharded_map_seq (T &t, F &&f) {
76- return reactor_map_seq (
76+ return invoke_on_all_seq (
7777 [&t, f=std::forward<F>(f)]() mutable {
7878 return std::invoke (f, t.local ());
7979 });
You can’t perform that action at this time.
0 commit comments