Searched refs:__stop_source_ (Results 1 – 5 of 5) sorted by relevance
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | task.hpp | 78 inplace_stop_source& __stop_source_; member
82 __stop_source_.request_stop(); in operator ()()
207 __forward_stop_request{__stop_source_}} in __default_awaiter_context()
212 __self.__stop_token_ = __stop_source_.get_token();
215 inplace_stop_source __stop_source_{}; member
279 std::move(__token), __forward_stop_request{__stop_source_}); in __default_awaiter_context()
280 __self.__stop_token_ = __stop_source_.get_token(); in __default_awaiter_context()
284 inplace_stop_source __stop_source_{}; member
|
| H A D | async_scope.hpp | 57 inplace_stop_source __stop_source_{}; member
237 __op_->__scope_->__stop_source_.get_token()}); in get_env()
339 inplace_stop_source* __stop_source_; member
343 __stop_source_->request_stop(); in operator ()()
461 __forward_stopped{&__state_->__stop_source_})
563 __forward_scope_{std::in_place, __scope->__stop_source_.get_token(), in __future_state_base()
564 __forward_stopped{&__stop_source_}}, in __future_state_base()
567 stdexec::prop{get_stop_token, __scope->__stop_source_.get_token()}))
596 inplace_stop_source __stop_source_; member
871 __spawn_env_{__scope->__stop_source_.get_token()}), in __t()
[all …]
|
| H A D | any_sender_of.hpp | 992 stdexec::inplace_stop_source __stop_source_{}; member
1050 prop{get_stop_token, __op_->__stop_source_.get_token()}, in get_env()
1079 __on_stop_t{this->__stop_source_}); in start()
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __when_all.hpp | 59 inplace_stop_source& __stop_source_; member
63 __stop_source_.request_stop(); in operator ()()
246 inplace_stop_source __stop_source_{}; member
325 return __mkenv(stdexec::get_env(__rcvr), __state.__stop_source_);
342 __on_stop_request{__state.__stop_source_});
343 if (__state.__stop_source_.stop_requested())
366 __state.__stop_source_.request_stop(); in __set_error()
406 __state.__stop_source_.request_stop();
|
| H A D | __shared.hpp | 253 inplace_stop_source __stop_source_{}; member
261 __env_(__env::__join(prop{get_stop_token, __stop_source_.get_token()}, in __shared_state()
289 ->__stop_source_.request_stop(); in __detach()
322 else if (__stop_source_.stop_requested()) in __try_start()
|