Home
last modified time | relevance | path

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

12

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__env.hpp186 template <class _Env>
187 requires tag_invocable<get_scheduler_t, const _Env&>
188 auto operator()(const _Env& __env) const noexcept
189 -> tag_invoke_result_t<get_scheduler_t, const _Env&>;
205 template <class _Env>
206 requires tag_invocable<get_delegation_scheduler_t, const _Env&>
207 auto operator()(const _Env& __t) const noexcept
208 -> tag_invoke_result_t<get_delegation_scheduler_t, const _Env&>;
221 template <class _Env>
222 requires tag_invocable<get_allocator_t, const _Env&>
[all …]
H A D__senders.hpp53 template <class _Sender, class _Env>
55 transform_sender_result_t<__late_domain_of_t<_Sender, _Env>, _Sender, _Env>;
57 template <class _Sender, class... _Env>
60 __declval<_Env>()...));
62 template <class _Sender, class... _Env>
66 __declval<_Env>()...));
68 template <class _Sender, class... _Env>
69 concept __with_member = __mvalid<__member_result_t, _Sender, _Env...>;
71 template <class _Sender, class... _Env>
73 __mvalid<__static_member_result_t, _Sender, _Env...>;
[all …]
H A D__domain.hpp58 template <class _DomainOrTag, class _Sender, class... _Env>
60 requires(_DomainOrTag __tag, _Sender&& __sender, const _Env&... __env) {
64 template <class _Sender, class... _Env>
67 && __has_transform_sender<tag_of_t<_Sender>, _Sender, _Env...>;
69 template <class _Type, class _Sender, class _Env>
71 requires(_Type __obj, _Sender&& __sender, _Env&& __env) {
73 static_cast<_Env&&>(__env));
76 template <class _Sender, class _Env>
79 && __has_transform_env<tag_of_t<_Sender>, _Sender, _Env>;
107 template <class _Sender, class _Env>
[all …]
H A D__transform_completion_signatures.hpp38 template <class _Sender, class... _Env>
39 auto __checked_completion_signatures(_Sender&& __sndr, _Env&&... __env) noexcept in __checked_completion_signatures()
41 using __completions_t = __completion_signatures_of_t<_Sender, _Env...>; in __checked_completion_signatures()
46 template <class _Sender, class... _Env>
47 requires sender_in<_Sender, _Env...>
50 __declval<_Env>()...));
52 template <class _Sender, class... _Env>
53 requires sender_in<_Sender, _Env...>
55 __completion_signatures_of_t<_Sender, _Env...>;
326 class _Sndr, class _Env = empty_env,
[all …]
H A D__write_env.hpp36 template <sender _Sender, class _Env>
37 auto operator()(_Sender&& __sndr, _Env __env) const in operator ()()
39 return __make_sexpr<__write_env_t>(static_cast<_Env&&>(__env), in operator ()()
43 template <class _Env>
45 auto operator()(_Env __env) const -> __binder_back<__write_env_t, _Env> in operator ()()
47 return {{static_cast<_Env&&>(__env)}, {}, {}}; in operator ()()
50 template <class _Env>
52 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
55 return __env::__join(__state, static_cast<_Env&&>(__env)); in __transform_env_fn()
59 template <sender_expr_for<__write_env_t> _Self, class _Env>
[all …]
H A D__transform_sender.hpp39 template <class _Sender, class _Env>
42 template <sender_expr _Sender, class _Env>
45 decltype(auto) transform_sender(_Sender&& __sndr, const _Env& __env) const
46 noexcept(__is_nothrow_transform_sender<_Sender, _Env>());
55 template <class _Domain, class _Sender, class _Env>
59 _Env&& __env) const noexcept in operator ()()
61 if constexpr (__domain::__has_transform_env<_Domain, _Sender, _Env>) in operator ()()
64 static_cast<_Env&&>(__env)); in operator ()()
69 static_cast<_Sender&&>(__sndr), static_cast<_Env&&>(__env)); in operator ()()
76 template <class _Domain, class _Sender, class... _Env>
[all …]
H A D__when_all.hpp67 template <class _Env>
68 auto __mkenv(_Env&& __env, const inplace_stop_source& __stop_source) noexcept in __mkenv()
71 static_cast<_Env&&>(__env)); in __mkenv()
74 template <class _Env>
76 decltype(__when_all::__mkenv(__declval<_Env>(),
79 template <class _Sender, class _Env>
81 sender_in<_Sender, _Env> && __mvalid<__value_types_of_t, _Sender, _Env,
91 template <class _Sender, class... _Env>
94 _WITH_ENVIRONMENT_<_Env>...>;
103 template <class _Sender, class... _Env>
[all …]
H A D__debug.hpp38 template <class _Env>
39 requires tag_invocable<__is_debug_env_t, const _Env&>
40 auto operator()(const _Env&) const noexcept
41 -> tag_invoke_result_t<__is_debug_env_t, const _Env&>;
44 template <class _Env>
45 using __debug_env_t = env<prop<__is_debug_env_t, bool>, _Env>;
47 template <class _Env>
48 concept __is_debug_env = tag_invocable<__is_debug_env_t, _Env>;
108 template <class _CvrefSenderId, class _Env, class _Completions>
116 template <class _CvrefSenderId, class _Env, class... _Sigs>
[all …]
H A D__schedulers.hpp100 template <class _Env>
101 requires tag_invocable<get_scheduler_t, const _Env&>
102 inline auto get_scheduler_t::operator()(const _Env& __env) const noexcept in operator ()()
103 -> tag_invoke_result_t<get_scheduler_t, const _Env&> in operator ()()
105 static_assert(nothrow_tag_invocable<get_scheduler_t, const _Env&>); in operator ()()
106 static_assert(scheduler<tag_invoke_result_t<get_scheduler_t, const _Env&>>); in operator ()()
110 template <class _Env>
111 requires tag_invocable<get_delegation_scheduler_t, const _Env&>
113 const _Env& __env) const noexcept in operator ()()
114 -> tag_invoke_result_t<get_delegation_scheduler_t, const _Env&> in operator ()()
[all …]
H A D__start_detached.hpp37 using _Env = stdexec::__t<_EnvId>; typedef
44 _Env __env_;
58 auto get_env() const noexcept -> const _Env& in get_env()
66 template <class _Env = empty_env>
67 using __detached_receiver_t = __t<__detached_receiver<__id<__decay_t<_Env>>>>;
80 template <class _Env, sender_in<__as_root_env_t<_Env>> _Sender>
82 __late_domain_of_t<_Sender, __as_root_env_t<_Env>>,
83 start_detached_t, _Sender, __as_root_env_t<_Env>>
84 void operator()(_Sender&& __sndr, _Env&& __env) const in operator ()()
88 __as_root_env(static_cast<_Env&&>(__env))); in operator ()()
[all …]
H A D__let.hpp147 template <class _Scheduler, class _Env>
149 __if_c<__is_scheduler_affine<schedule_result_t<_Scheduler>>, _Env,
152 __env::__without_t<_Env, get_domain_t>>>;
159 template <class _Sender, class _Set, class... _Env>
166 _WITH_SENDER_<_Sender>, _WITH_ENVIRONMENT_<_Env>...>;
168 template <class _Sender, class _Set, class... _Env>
169 using __bad_result_sender = __t<__bad_result_sender_<_Sender, _Set, _Env...>>;
171 template <class _Sender, class _Set, class... _Env>
176 _WITH_SENDER_<_Sender>, _WITH_ENVIRONMENT_<_Env>...>;
179 template <class _Sender, class... _Env>
[all …]
H A D__on.hpp60 template <class _Sender, class _Env>
69 _WITH_SENDER_<_Sender>, _WITH_ENVIRONMENT_<_Env>>{}; in get_completion_signatures()
141 template <class _Env>
143 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
149 return __detail::__mkenv_sched(static_cast<_Env&&>(__env), in __transform_env_fn()
154 return static_cast<_Env>(static_cast<_Env&&>(__env)); in __transform_env_fn()
159 template <class _Env>
161 static auto __transform_sender_fn(const _Env& __env) noexcept in __transform_sender_fn()
172 if constexpr (__is_root_env<_Env>) in __transform_sender_fn()
220 template <class _Sender, class _Env>
[all …]
H A D__into_variant.hpp42 template <class _Sender, class _Env>
43 requires sender_in<_Sender, _Env>
44 using __into_variant_result_t = value_types_of_t<_Sender, _Env>;
46 template <class _Sender, class... _Env>
48 __value_types_t<__completion_signatures_of_t<_Sender, _Env...>>;
55 template <class _Sender, class... _Env>
58 __completion_signatures_of_t<_Sender, _Env...>,
59 __meval<__variant_completions, __variant_t<_Sender, _Env...>>,
116 []<class _Self, class... _Env>(_Self&&, _Env&&...) noexcept //
117 -> __completions<__child_of<_Self>, _Env...> {
H A D__continues_on.hpp44 template <class _Env>
45 using __scheduler_t = __result_of<get_completion_scheduler<set_value_t>, _Env>;
59 using _Env = __t<__environ<__id<__decay_t<_Scheduler>>>>; in operator ()() typedef
62 _Env{{static_cast<_Scheduler&&>(__sched)}}, in operator ()()
75 using _Env = __0; typedef
82 get_completion_scheduler_t<set_value_t>(_Env)),
84 get_completion_scheduler_t<set_value_t>(_Env))>;
86 template <class _Env>
87 static auto __transform_sender_fn(const _Env&) in __transform_sender_fn()
97 template <class _Sender, class _Env>
[all …]
H A D__continue_on.hpp44 template <class _Env>
45 using __scheduler_t = __result_of<get_completion_scheduler<set_value_t>, _Env>;
59 using _Env = __t<__environ<__id<__decay_t<_Scheduler>>>>; in operator ()() typedef
62 _Env{{static_cast<_Scheduler&&>(__sched)}}, in operator ()()
75 using _Env = __0; typedef
82 get_completion_scheduler_t<set_value_t>(_Env)),
84 get_completion_scheduler_t<set_value_t>(_Env))>;
86 template <class _Env>
87 static auto __transform_sender_fn(const _Env&) in __transform_sender_fn()
97 template <class _Sender, class _Env>
[all …]
H A D__split.hpp46 template <sender _Sender, class _Env = empty_env>
47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
48 auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
53 __domain, __make_sexpr<split_t>(static_cast<_Env&&>(__env),
71 template <class _CvrefSender, class _Env>
73 __t<__meval<__receiver, __cvref_id<_CvrefSender>, __id<_Env>>>;
84 [&]<class _Env, class _Child>(__ignore, _Env&& __env, in transform_sender()
88 __make_intrusive<__shared_state<_Child, __decay_t<_Env>>, in transform_sender()
90 static_cast<_Env&&>(__env)); in transform_sender()
H A D__ensure_started.hpp46 template <sender _Sender, class _Env = empty_env>
47 requires sender_in<_Sender, _Env> && __decay_copyable<env_of_t<_Sender>>
48 [[nodiscard]] auto operator()(_Sender&& __sndr, _Env&& __env = {}) const in operator ()()
60 __make_sexpr<ensure_started_t>(static_cast<_Env&&>(__env),
79 template <class _CvrefSender, class _Env>
81 __t<__meval<__receiver, __cvref_id<_CvrefSender>, __id<_Env>>>;
92 [&]<class _Env, class _Child>(__ignore, _Env&& __env, in transform_sender()
96 __make_intrusive<__shared_state<_Child, __decay_t<_Env>>, in transform_sender()
98 static_cast<_Env&&>(__env)); in transform_sender()
H A D__read_env.hpp47 template <class _Tag, class _Env>
51 _WITH_QUERY_<_Tag>, _WITH_ENVIRONMENT_<_Env>>;
53 template <class _Tag, class _Env>
54 requires __callable<_Tag, _Env>
56 __if_c<__nothrow_callable<_Tag, _Env>,
57 completion_signatures<set_value_t(__call_result_t<_Tag, _Env>)>,
58 completion_signatures<set_value_t(__call_result_t<_Tag, _Env>),
88 template <class _Tag, class _Env>
91 _Tag, _Env>;
94 []<class _Self, class _Env>(const _Self&, _Env&&) noexcept
[all …]
H A D__receiver_ref.hpp55 template <class _Sigs, class _Env>
58 template <class _Env, class... _Sigs>
59 struct __receiver_vtable_for<completion_signatures<_Sigs...>, _Env> :
62 _Env (*__do_get_env)(const void* __op_state) noexcept;
65 static auto __s_get_env(const void* __ptr) noexcept -> _Env in __s_get_env()
81 auto __get_env(const void* __op_state) const noexcept -> _Env in __get_env()
87 template <class _OpState, class _GetEnv, class _GetReceiver, class _Env,
89 inline constexpr __receiver_vtable_for<_Sigs, _Env> __receiver_vtable_for_v{
92 template <class _Sigs, class _Env = empty_env>
103 _GetReceiver, _Env, _Sigs>},
[all …]
H A D__shared.hpp87 template <class _CvrefSender, class _Env>
188 using _Env = stdexec::__t<_EnvId>; typedef
216 auto get_env() const noexcept -> const __env_t<_Env>& in get_env()
222 __shared_state<_CvrefSender, _Env>* __sh_state_;
233 template <class _CvrefSender, class _Env>
235 private __enable_intrusive_from_this<__shared_state<_CvrefSender, _Env>, 2>
237 using __receiver_t = __t<__receiver<__cvref_id<_CvrefSender>, __id<_Env>>>;
242 __completion_signatures_of_t<_CvrefSender, _Env>,
254 __env_t<_Env> __env_;
260 explicit __shared_state(_CvrefSender&& __sndr, _Env __env) : in __shared_state()
[all …]
H A D__schedule_from.hpp56 template <class _CvrefSender, class _Env>
59 __completion_signatures_of_t<_CvrefSender, _Env>, __tuple_t,
72 template <class _CvrefSender, class... _Env>
75 __completion_signatures_of_t<_CvrefSender, _Env...>,
78 template <class _Scheduler, class _CvrefSender, class... _Env>
82 __completion_signatures_of_t<_CvrefSender, _Env...>,
87 _Env...>,
89 __all_nothrow_decay_copyable_results<_CvrefSender, _Env...>>,
200 using _Env = __t<__environ<__id<__decay_t<_Scheduler>>>>; in operator ()() typedef
201 auto __env = _Env{{static_cast<_Scheduler&&>(__sched)}}; in operator ()()
[all …]
H A D__start_on.hpp74 template <class _Env>
76 static auto __transform_env_fn(_Env&& __env) noexcept in __transform_env_fn()
79 return __detail::__mkenv_sched(static_cast<_Env&&>(__env), __sched); in __transform_env_fn()
83 template <class _Sender, class _Env>
84 static auto transform_env(const _Sender& __sndr, _Env&& __env) noexcept in transform_env()
87 __transform_env_fn(static_cast<_Env&&>(__env))); in transform_env()
90 template <class _Sender, class _Env>
91 static auto transform_sender(_Sender&& __sndr, const _Env&) in transform_sender()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp49 template <class _Sender, class _Env = empty_env>
51 sender_in<_Sender, _Env> //
53 __all_contained_in<completion_signatures_of_t<_Sender, _Env>,
166 template <class _Sender, class _Env>
168 transform_sender_result_t<__late_domain_of_t<_Sender, _Env>, _Sender, _Env>;
170 template <class _Sender, class _Env>
172 tag_invocable<get_item_types_t, __tfx_sender<_Sender, _Env>, _Env>;
173 template <class _Sender, class _Env>
175 typename __decay_t<__tfx_sender<_Sender, _Env>>::item_types;
177 template <class _Sender, class _Env>
[all …]
H A Denv.hpp41 template <class _Env, class _Tag>
42 auto operator()(_Env&& __env, _Tag) const -> decltype(auto) in operator ()()
44 return stdexec::__env::__without(static_cast<_Env&&>(__env), _Tag()); in operator ()()
53 stdexec::__nothrow_move_constructible _Env>
54 auto operator()(_Base&& __base, _Env&& __env) const noexcept in operator ()()
55 -> stdexec::__env::__join_t<_Env, _Base> in operator ()()
57 return stdexec::__env::__join(static_cast<_Env&&>(__env), in operator ()()
61 template <stdexec::__nothrow_move_constructible _Env>
62 auto operator()(_Env&& __env) const noexcept -> _Env in operator ()()
64 return static_cast<_Env&&>(__env); in operator ()()
[all …]
H A Dasync_scope.hpp139 template <__decays_to<__t> _Self, class... _Env>
140 static auto get_completion_signatures(_Self&&, _Env&&...) in get_completion_signatures()
142 __env_t<_Env>...> in get_completion_signatures()
309 template <__decays_to<__t> _Self, class... _Env>
310 static auto get_completion_signatures(_Self&&, _Env&&...) in get_completion_signatures()
312 __env_t<_Env>...> in get_completion_signatures()
334 template <class _Sender, class _Env>
363 using _Env = stdexec::__t<_EnvId>; typedef
426 std::unique_ptr<__future_state<_Sender, _Env>> __state_;
453 std::unique_ptr<__future_state<_Sender, _Env>> __state) : in __t()
[all …]

12