| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | at_coroutine_exit.hpp | 72 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() function
74 return stdexec::get_env(__receiver_); in get_env()
114 auto get_env() const noexcept -> env_of_t<_Sender> in get_env() function
116 return stdexec::get_env(__sender_); in get_env()
172 get_scheduler(get_env(__parent.promise())); in await_suspend()
258 auto get_env() const noexcept -> __env in get_env() function
|
| H A D | task.hpp | 58 { get_env(t) } -> __stop_token_provider;
64 { get_env(t) } -> __scheduler_provider;
126 __scheduler_ = get_scheduler(get_env(__parent)); in __default_task_context_impl()
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()
469 auto get_env() const noexcept -> const __promise_context_t& in get_env() function
|
| H A D | sequence_senders.hpp | 103 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() function
105 return stdexec::get_env(__rcvr_); in get_env()
126 stdexec::get_stop_token(stdexec::get_env(__rcvr_)); in set_stopped()
425 auto&& __env = get_env(__rcvr);
524 auto token = stdexec::get_stop_token(stdexec::get_env(__rcvr)); in __set_value_unless_stopped()
|
| H A D | any_sender_of.hpp | 107 return _Tag{}(stdexec::get_env(*static_cast<const _EnvProvider*>( in __anon1bf2f58b0102()
122 return _Tag{}(stdexec::get_env(*static_cast<const _EnvProvider*>( in __anon1bf2f58b0202()
826 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
854 auto get_env() const noexcept -> const __env_t& in get_env() function
943 auto get_env() const noexcept -> const __env_t& in get_env() function
1048 auto get_env() const noexcept -> __env_t<env_of_t<_Receiver>> in get_env() function
1052 stdexec::get_env(__op_->__rcvr_)); in get_env()
1079 stdexec::get_stop_token(stdexec::get_env(this->__rcvr_)), in start()
1244 auto get_env() const noexcept -> __env_t in get_env() function
1437 auto get_env() const noexcept -> stdexec::env_of_t<__receiver_base> in get_env() function in exec::any_receiver_ref
[all …]
|
| H A D | async_scope.hpp | 231 auto get_env() const noexcept -> __env_t<env_of_t<_Receiver>> in get_env() function
234 stdexec::get_env(__op_->__rcvr_), 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_)),
688 auto get_env() const noexcept -> const __env_t<_Env>& in get_env() function
849 auto get_env() const noexcept -> const __spawn_env_t<_Env>& in get_env() function
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __submit.hpp | 61 auto&& __env = stdexec::get_env(__op->__rcvr_); in __delete_op()
100 auto get_env() const noexcept -> env_of_t<_Receiver&> in get_env() function
102 return stdexec::get_env(__opref_().__rcvr_); in get_env()
131 auto&& __env = get_env(__rcvr); in operator ()()
|
| H A D | __schedule_from.hpp | 169 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() function
171 return stdexec::get_env(__state_->__receiver()); in get_env()
224 return __env::__join(__data, stdexec::get_env(__child));
239 get_completion_scheduler<set_value_t>(stdexec::get_env(__sndr));
|
| H A D | __write_env.hpp | 69 static constexpr auto get_env = // member
71 return __env::__join(__state, stdexec::get_env(__rcvr)); in __anon164445800202()
|
| H A D | __let.hpp | 65 constexpr auto get_env() const noexcept -> __env in get_env() function
133 auto get_env() const noexcept in get_env() function
137 __env::__without(stdexec::get_env(__rcvr_), get_domain)); in get_env()
338 stdexec::get_env(__child))}, in __mk_transform_env_fn()
436 return stdexec::get_env(__rcvr); in __get_env()
442 __env::__without(stdexec::get_env(__rcvr), get_domain)); in __get_env()
509 stdexec::get_env(__child));
538 stdexec::get_env(__child),
|
| H A D | __receiver_adaptor.hpp | 41 auto get_env() const noexcept -> empty_env;
181 auto get_env() const noexcept -> env_of_t<__base_t<const _Self&>> in get_env() function
183 return stdexec::get_env(__get_base(static_cast<const _Self&>(*this))); in get_env()
|
| H A D | __basic_sender.hpp | 89 __sexpr_impl<__meval<__msecond, _Self, _Tag>>::get_env, _Index,
113 return stdexec::get_env(
124 -> env_of_t<const _Receiver&> { return stdexec::get_env(__rcvr); };
215 auto get_env() const noexcept in get_env() function
413 return __sexpr_impl<__tag_t>::get_env(_Index(), this->__state_, __rcvr); in __get_env()
464 static constexpr auto get_env = __detail::__get_env; member
518 auto get_env() const noexcept in get_env() function
|
| H A D | __read_env.hpp | 114 __query(), stdexec::get_env(__rcvr));
123 return __query()(stdexec::get_env(__rcvr)); in __anona47160310102()
|
| H A D | __env.hpp | 429 auto get_env() const noexcept -> const _Env&;
767 -> decltype(__env_provider.get_env()) in tag_invoke()
769 static_assert(noexcept(__env_provider.get_env()), in tag_invoke()
771 return __env_provider.get_env(); in tag_invoke()
795 inline constexpr get_env_t get_env{}; variable
800 { get_env(std::as_const(__ep)) } -> queryable;
|
| H A D | __connect_awaitable.hpp | 155 auto get_env() const noexcept -> env_of_t<_Receiver> in get_env() function
157 return stdexec::get_env(__rcvr_); in get_env()
|
| H A D | __run_loop.hpp | 75 if (stdexec::get_stop_token(stdexec::get_env(__rcvr)) in __execute_impl()
159 auto get_env() const noexcept -> __env in get_env() function
|
| H A D | __when_all.hpp | 321 static constexpr auto get_env = //
325 return __mkenv(stdexec::get_env(__rcvr), __state.__stop_source_);
333 __when_all::__mk_state_fn(stdexec::get_env(__rcvr)));
341 __state.__on_stop_.emplace(get_stop_token(stdexec::get_env(__rcvr)),
|
| H A D | __as_awaitable.hpp | 110 auto get_env() const noexcept -> env_of_t<_Promise&> in get_env() function
115 return stdexec::get_env(__continuation.promise()); in get_env()
|
| H A D | __start_detached.hpp | 58 auto get_env() const noexcept -> const _Env& in get_env() function
|
| H A D | __continue_on.hpp | 111 return __env::__join(__data, stdexec::get_env(__child));
|
| H A D | __receiver_ref.hpp | 107 auto get_env() const noexcept -> decltype(auto) in get_env() function in stdexec::__any_::__receiver_ref
|
| H A D | __shared.hpp | 215 auto get_env() const noexcept -> const __env_t<_Env>& in get_env() function
516 const auto __stok = stdexec::get_stop_token(stdexec::get_env(__rcvr));
|
| H A D | __schedulers.hpp | 78 get_env(schedule(static_cast<_Scheduler&&>(__sched)))))
|
| H A D | __execution_fwd.hpp | 74 extern const get_env_t get_env;
|
| /openbmc/qemu/tests/qemu-iotests/ |
| H A D | testenv.py | 96 os_env.update(self.get_env())
99 def get_env(self) -> Dict[str, str]: member in TestEnv
310 args = collections.defaultdict(str, self.get_env())
|
| /openbmc/u-boot/test/py/tests/ |
| H A D | test_env.py | 29 self.get_env()
32 def get_env(self): member in StateTestEnv
|