Searched refs:get_stop_token (Results 1 – 12 of 12) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | task.hpp | 52 get_stop_token(t);
207 __stop_callback_{get_stop_token(get_env(__parent)), in __default_awaiter_context()
232 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
274 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
276 else if (auto __token = get_stop_token(get_env(__parent)); in __default_awaiter_context()
|
| H A D | async_scope.hpp | 235 stdexec::prop{get_stop_token, in get_env()
385 else if (get_stop_token(get_env(__rcvr_)).stop_requested()) in __complete_()
458 __forward_consumer_(get_stop_token(get_env(__rcvr_)),
565 stdexec::prop{get_stop_token, __scope->__stop_source_.get_token()}))
952 auto get_stop_token() const noexcept -> inplace_stop_token in get_stop_token() function
|
| H A D | sequence_senders.hpp | 126 stdexec::get_stop_token(stdexec::get_env(__rcvr_)); in set_stopped()
524 auto token = stdexec::get_stop_token(stdexec::get_env(__rcvr)); in __set_value_unless_stopped()
|
| H A D | any_sender_of.hpp | 826 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
1051 prop{get_stop_token, __op_->__stop_source_.get_token()}, in get_env()
1079 stdexec::get_stop_token(stdexec::get_env(this->__rcvr_)), in start()
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __shared.hpp | 259 __env_(__env::__join(prop{get_stop_token, __stop_source_.get_token()}, in __shared_state()
516 const auto __stok = stdexec::get_stop_token(stdexec::get_env(__rcvr));
|
| H A D | __read_env.hpp | 164 return read_env(get_stop_token); in operator ()()
|
| H A D | __execution_fwd.hpp | 118 extern const get_stop_token_t get_stop_token;
|
| H A D | __run_loop.hpp | 75 if (stdexec::get_stop_token(stdexec::get_env(__rcvr)) in __execute_impl()
|
| H A D | __when_all.hpp | 70 return __env::__join(prop{get_stop_token, __stop_source.get_token()}, in __mkenv()
341 __state.__on_stop_.emplace(get_stop_token(stdexec::get_env(__rcvr)),
|
| H A D | __p2300.hpp | 96 inline constexpr stdexec::get_stop_token_t get_stop_token{}; variable
|
| H A D | __env.hpp | 380 inline constexpr get_stop_token_t get_stop_token{}; variable
|
| /openbmc/pldm/requester/ |
| H A D | handler.hpp | 502 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
|