Home
last modified time | relevance | path

Searched refs:set_stopped (Results 1 – 25 of 25) sorted by relevance

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__receivers.hpp112 -> decltype(static_cast<_Receiver&&>(__rcvr).set_stopped()) in tag_invoke()
114 static_assert(noexcept(static_cast<_Receiver&&>(__rcvr).set_stopped()), in tag_invoke()
117 __same_as<decltype(static_cast<_Receiver&&>(__rcvr).set_stopped()), in tag_invoke()
120 static_cast<_Receiver&&>(__rcvr).set_stopped(); in tag_invoke()
140 inline constexpr set_stopped_t set_stopped{}; variable
H A D__receiver_adaptor.hpp40 void set_stopped() noexcept;
174 void set_stopped() && noexcept in set_stopped() function
176 return stdexec::set_stopped(__get_base(static_cast<_Self&&>(*this))); in set_stopped()
H A D__submit.hpp93 void set_stopped() noexcept in set_stopped() function
95 stdexec::set_stopped(__opref_().__rcvr_); in set_stopped()
H A D__shared.hpp143 stdexec::set_stopped(static_cast<_Receiver&&>(this->__receiver())); in operator ()()
210 void set_stopped() noexcept in set_stopped() function
539 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr));
H A D__execute.hpp56 void set_stopped() noexcept {} in set_stopped() function
H A D__schedule_from.hpp164 void set_stopped() noexcept in set_stopped() function
166 stdexec::set_stopped(static_cast<_Receiver&&>(__state_->__receiver())); in set_stopped()
H A D__start_detached.hpp56 void set_stopped() noexcept {} in set_stopped() function
H A D__receiver_ref.hpp124 void set_stopped() noexcept in set_stopped() function in stdexec::__any_::__receiver_ref
H A D__execution_fwd.hpp43 extern const set_stopped_t set_stopped;
H A D__connect_awaitable.hpp124 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in unhandled_stopped()
H A D__debug.hpp101 void set_stopped() noexcept in set_stopped() function
H A D__run_loop.hpp78 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
H A D__when_all.hpp239 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __complete()
347 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr));
H A D__as_awaitable.hpp99 void set_stopped() noexcept in set_stopped() function
H A D__let.hpp128 void set_stopped() noexcept in set_stopped() function
130 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
H A D__basic_sender.hpp208 void set_stopped() noexcept in set_stopped() function
210 __op_->__complete(_Idx(), stdexec::set_stopped); in set_stopped()
H A D__sync_wait.hpp138 void set_stopped() noexcept in set_stopped() function
H A D__p2300.hpp145 inline constexpr stdexec::set_stopped_t set_stopped{}; variable
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dasync_scope.hpp221 void set_stopped() noexcept in set_stopped() function
225 stdexec::set_stopped(std::move(__op_->__rcvr_)); in set_stopped()
388 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in __complete_()
680 void set_stopped() noexcept in set_stopped() function
844 void set_stopped() noexcept in set_stopped() function
H A Dsequence_senders.hpp114 void set_stopped() noexcept in set_stopped() function
129 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
531 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __set_value_unless_stopped()
H A Dany_sender_of.hpp847 void set_stopped() noexcept in set_stopped() function
936 void set_stopped() noexcept in set_stopped() function
1041 void set_stopped() noexcept in set_stopped() function
1045 stdexec::set_stopped(static_cast<_Receiver&&>(__op_->__rcvr_)); in set_stopped()
1430 void set_stopped() noexcept in set_stopped() function in exec::any_receiver_ref
1433 stdexec::tag_invoke(stdexec::set_stopped, in set_stopped()
H A Dat_coroutine_exit.hpp67 [[noreturn]] void set_stopped() noexcept in set_stopped() function
/openbmc/sdbusplus/include/sdbusplus/async/
H A Dfdio.hpp95 execution::set_stopped(std::move(receiver)); in stop()
H A Dmatch.hpp118 execution::set_stopped(std::move(receiver)); in stop()
/openbmc/pldm/requester/
H A Dhandler.hpp507 return stdexec::set_stopped(std::move(op.receiver)); in tag_invoke()
537 return stdexec::set_stopped(std::move(receiver)); in onStop()