Merge pull request NVIDIA#1583 from ericniebler/fix-formatting

reformat everything with clang-format-21

Author: ericniebler

.git-blame-ignore-revs

@@ -27,3 +27,6 @@ aee392a046a26ae2340849fe98e38332d9537397
 
 # Tweak some clang-format settings and eformat everything with clang-format-21
 8a63d46aabca368c867c715e40ebc0a2f3c48e1c
+
+# Reformat everything with clang-format-21 again
+1957788ce7a55843c0bcf81e4c97a4027547dcb1

include/exec/__detail/__basic_sequence.hpp

@@ -91,11 +91,13 @@ namespace exec {
       apply(_Sender&& __sndr, _ApplyFn&& __fun) noexcept(stdexec::__nothrow_callable<
                                                          stdexec::__detail::__impl_of<_Sender>,
                                                          stdexec::__copy_cvref_fn<_Sender>,
-                                                         _ApplyFn>)
+                                                         _ApplyFn
+      >)
         -> stdexec::__call_result_t<
           stdexec::__detail::__impl_of<_Sender>,
           stdexec::__copy_cvref_fn<_Sender>,
-          _ApplyFn> {
+          _ApplyFn
+        > {
       return static_cast<_Sender&&>(__sndr)
         .__impl_(stdexec::__copy_cvref_fn<_Sender>(), static_cast<_ApplyFn&&>(__fun));
     }

include/exec/__detail/__system_context_default_impl.hpp

@@ -203,7 +203,7 @@ namespace exec::__system_context_default_impl {
       }
 
       uint32_t __end(uint32_t __chunk_index) const noexcept {
-        return (std::min)(__begin(__chunk_index + 1), __max_size_);
+        return (std::min) (__begin(__chunk_index + 1), __max_size_);
       }
     };
 
@@ -308,7 +308,8 @@ namespace exec::__system_context_default_impl {
   struct __instance_data {
     // work around for https://gcc.gnu.org/bugzilla/show_bug.cgi?id=119652
     constexpr __instance_data() noexcept // NOLINT(modernize-use-equals-default)
-    {}
+    {
+    }
 
     /// Gets the current instance; if there is no instance, uses the current factory to create one.
     auto __get_current_instance() -> std::shared_ptr<_Interface> {

include/exec/linux/io_uring_context.hpp

@@ -1082,8 +1082,9 @@ namespace exec {
       auto operator==(const __scheduler&) const -> bool = default;
 
       struct __schedule_env {
-        [[nodiscard]] auto
-          query(stdexec::get_completion_scheduler_t<stdexec::set_value_t>) const noexcept -> __scheduler {
+        [[nodiscard]]
+        auto query(stdexec::get_completion_scheduler_t<stdexec::set_value_t>) const noexcept
+          -> __scheduler {
           return __scheduler{__context_};
         }
 

include/exec/sequence/ignore_all_values.hpp

@@ -97,7 +97,8 @@ namespace exec {
                      _ResultVariant,
                      __decayed_std_tuple<set_error_t, _Error>,
                      set_error_t,
-                     _Error>
+                     _Error
+                   >
                 && __callable<stdexec::set_stopped_t, _ItemReceiver>
         void set_error(_Error&& __error) noexcept {
           // store error and signal stop
@@ -109,7 +110,8 @@ namespace exec {
           requires __variant_emplaceable<
                      _ResultVariant,
                      __decayed_std_tuple<set_stopped_t>,
-                     set_stopped_t>
+                     set_stopped_t
+                   >
                 && __callable<set_stopped_t, _ItemReceiver>
         {
           // stop without error
@@ -225,7 +227,8 @@ namespace exec {
       __mconst<__types<>>::__f,
       __mcompose_q<__types, __mbind_front_q<__decayed_std_tuple, set_error_t>::__f>::__f,
       __types<std::tuple<set_stopped_t>>,
-      __mconcat<__qq<__nullable_std_variant>>::__f>;
+      __mconcat<__qq<__nullable_std_variant>>::__f
+    >;
 
     template <class _Sender, class _Env>
     using __result_variant_t =
@@ -321,7 +324,8 @@ namespace exec {
         requires receiver_of<_Receiver, __completion_sigs<__child_of<_Sender>, env_of_t<_Receiver>>>
               && sequence_sender_to<
                    __child_of<_Sender>,
-                   __receiver_t<__child_of<_Sender>, _Receiver>>
+                   __receiver_t<__child_of<_Sender>, _Receiver>
+              >
       {
         static_assert(sender_expr_for<_Sender, ignore_all_values_t>);
         return __sexpr_apply(static_cast<_Sender&&>(__sndr), __connect_fn<_Receiver>{__rcvr});

include/exec/static_thread_pool.hpp

@@ -322,7 +322,7 @@ namespace exec {
             static_assert(
               __starts_on<Sender, static_thread_pool_::scheduler, Env>
                 || __completes_on<Sender, static_thread_pool_::scheduler>,
-              "No static_thread_pool_ instance can be found in the sender's or receiver's "
+              "No static_thread_pool instance can be found in the sender's or receiver's "
               "environment on which to schedule bulk work.");
             return not_a_sender<__name_of<Sender>>();
           }
@@ -1673,7 +1673,7 @@ namespace exec {
         }
 
         template <exec::sequence_receiver_of<item_types> Receiver>
-          requires __decay_copyable<Range const&>
+          requires __decay_copyable<Range const &>
         auto subscribe(Receiver rcvr) const & noexcept
           -> stdexec::__t<operation<Range, stdexec::__id<Receiver>>> {
           return {range_, *pool_, static_cast<Receiver&&>(rcvr)};

include/exec/system_context.hpp

@@ -708,8 +708,7 @@ namespace exec {
   };
 
   template <__bulk_chunked_or_unchunked _Sender>
-  auto __parallel_scheduler_domain::transform_sender(_Sender&& __sndr)
-    const noexcept {
+  auto __parallel_scheduler_domain::transform_sender(_Sender&& __sndr) const noexcept {
     if constexpr (stdexec::__completes_on<_Sender, parallel_scheduler>) {
       auto __sched = stdexec::get_completion_scheduler<stdexec::set_value_t>(
         stdexec::get_env(__sndr));
@@ -723,6 +722,7 @@ namespace exec {
       return __not_a_sender<stdexec::__name_of<_Sender>>();
     }
   }
+
   template <__bulk_chunked_or_unchunked _Sender, class _Env>
   auto __parallel_scheduler_domain::transform_sender(_Sender&& __sndr, const _Env& __env)
     const noexcept {

include/exec/task.hpp

@@ -188,7 +188,8 @@ namespace exec {
         static_assert(std::is_nothrow_constructible_v<
                       __stop_callback_t,
                       __stop_token_t,
-                      __forward_stop_request>);
+                      __forward_stop_request
+        >);
         __self.__stop_token_ = __stop_source_.get_token();
       }
 
@@ -442,9 +443,7 @@ namespace exec {
 
         auto await_resume() -> _Ty {
           __context_.reset();
-          scope_guard __on_exit{[this]() noexcept {
-            std::exchange(__coro_, {}).destroy();
-          }};
+          scope_guard __on_exit{[this]() noexcept { std::exchange(__coro_, {}).destroy(); }};
           if (__coro_.promise().__data_.index() == 1)
             std::rethrow_exception(std::move(__coro_.promise().__data_.template get<1>()));
           if constexpr (!std::is_void_v<_Ty>)
@@ -458,7 +457,8 @@ namespace exec {
         requires constructible_from<
           awaiter_context_t<__promise, _ParentPromise>,
           __promise_context_t&,
-          _ParentPromise&>
+          _ParentPromise&
+        >
       auto as_awaitable(_ParentPromise&) && noexcept -> __task_awaitable<_ParentPromise> {
         return __task_awaitable<_ParentPromise>{std::exchange(__coro_, {})};
       }

include/exec/timed_thread_scheduler.hpp

@@ -210,7 +210,8 @@ namespace exec {
       &task_type::when_,
       &task_type::prev_,
       &task_type::left_,
-      &task_type::right_>
+      &task_type::right_
+    >
       heap_;
     std::atomic<std::ptrdiff_t> n_submissions_in_flight_{0};
     std::mutex ready_mutex_;
@@ -291,7 +292,8 @@ namespace exec {
       };
 
       using callback_type = typename stdexec::stop_token_of_t<
-        stdexec::env_of_t<Receiver>>::template callback_type<on_stopped_t>;
+        stdexec::env_of_t<Receiver>
+      >::template callback_type<on_stopped_t>;
 
       void request_stop() noexcept {
         if (ref_count_.fetch_add(1, std::memory_order_relaxed) == 1) {