| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
| H A D | task.hpp | 58 get_env(t)
66 get_env(t)
178 __self.__scheduler_ = get_scheduler(get_env(__parent)); in __default_awaiter_context()
202 __stop_callback_{get_stop_token(get_env(__parent)), in __default_awaiter_context()
208 __self.__scheduler_ = get_scheduler(get_env(__parent));
235 __self.__scheduler_ = get_scheduler(get_env(__parent)); in __default_awaiter_context()
237 __self.__stop_token_ = get_stop_token(get_env(__parent)); in __default_awaiter_context()
255 __self.__scheduler_ = get_scheduler(get_env(__parent)); in __default_awaiter_context()
273 __self.__scheduler_ = get_scheduler(get_env(__parent)); in __default_awaiter_context()
286 __self.__scheduler_ = get_scheduler(get_env(__parent)); in __default_awaiter_context()
[all …]
|
| H A D | at_coroutine_exit.hpp | 70 return get_env(__self.__receiver_); in tag_invoke()
113 return get_env(__self.__sender_); in tag_invoke()
173 get_scheduler(get_env(__parent.promise())); in await_suspend()
|
| H A D | sequence_senders.hpp | 107 return stdexec::get_env(__self.__rcvr_); in tag_invoke()
130 stdexec::get_stop_token(stdexec::get_env(__self.__rcvr_)); in tag_invoke()
442 auto&& __env = get_env(__rcvr);
544 auto token = stdexec::get_stop_token(stdexec::get_env(__rcvr)); in __set_value_unless_stopped()
|
| H A D | execution.hpp | 1475 return get_env(__self.__rcvr_); in tag_invoke()
1674 auto&& __env = get_env(__rcvr);
2173 auto&& __env = get_env(__op->__rcvr_); in __delete_op()
2192 return get_env(__self.__opref_().__rcvr_); in tag_invoke()
2221 auto&& __env = get_env(__rcvr); in operator ()()
2785 STDEXEC_DEFINE_MEMBER(get_env);
2902 -> decltype(STDEXEC_CALL_MEMBER(get_env, in tag_invoke()
2906 return STDEXEC_CALL_MEMBER(get_env, __self); in tag_invoke()
2911 (_Dp, get_env) in STDEXEC_MISSING_MEMBER() argument
3995 auto get_env() const noexcept -> __env_t in get_env() function
[all …]
|
| H A D | env.hpp | 102 const auto& __env = get_env(__self.__rcvr_); in tag_invoke()
|
| H A D | async_scope.hpp | 217 get_env(__self.__op_->__rcvr_), in tag_invoke()
384 else if (get_stop_token(get_env(__rcvr_)).stop_requested()) in __complete_()
482 __forward_consumer_(get_stop_token(get_env(__rcvr_)),
|
| H A D | any_sender_of.hpp | 109 get_env(*static_cast<const _EnvProvider*>(__env_provider)), in __anon1bf2f58b0102()
124 get_env(*static_cast<const _EnvProvider*>(__env_provider)), in __anon1bf2f58b0202()
849 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
1054 get_env(__self.__op_->__rcvr_)); in tag_invoke()
1085 stdexec::get_stop_token(stdexec::get_env(__self.__rcvr_)), in tag_invoke()
|
| /openbmc/qemu/tests/qemu-iotests/ |
| H A D | testenv.py | 91 os_env.update(self.get_env())
94 def get_env(self) -> Dict[str, str]: member in TestEnv
305 args = collections.defaultdict(str, self.get_env())
|
| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __basic_sender.hpp | 164 __result_of<__sexpr_impl<_Tag>::get_env, _Index,
187 return stdexec::get_env(
198 -> env_of_t<const _Receiver&> { return stdexec::get_env(__rcvr); };
447 return __sexpr_impl<__tag_t>::get_env(_Index(), this->__state_, __rcvr); in __get_env()
512 static constexpr auto get_env = __detail::__get_env; member
|
| H A D | __execution_fwd.hpp | 68 extern const get_env_t get_env;
|
| H A D | __env.hpp | 629 inline constexpr get_env_t get_env{}; variable
635 get_env(std::as_const(__ep))
|
| H A D | __p2300.hpp | 111 inline constexpr stdexec::get_env_t get_env{}; variable
|
| /openbmc/u-boot/test/py/tests/ |
| H A D | test_env.py | 29 self.get_env()
32 def get_env(self): member in StateTestEnv
|
| /openbmc/openbmc/poky/bitbake/lib/hashserv/ |
| H A D | tests.py | 1474 def get_env(self, name): member in TestHashEquivalenceExternalServer
1481 return self.get_env('BB_TEST_HASHSERV')
1491 username=self.get_env('BB_TEST_HASHSERV_USERNAME'),
1492 password=self.get_env('BB_TEST_HASHSERV_PASSWORD'),
|
| /openbmc/pldm/requester/ |
| H A D | handler.hpp | 492 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
|