Home
last modified time | relevance | path

Searched refs:stdexec (Results 1 – 25 of 101) sorted by relevance

12345

/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__p2300.hpp35 inline constexpr stdexec::tag_invoke_t tag_invoke{};
39 stdexec::tag_invoke_result<_Tag, _Ts...>;
43 stdexec::tag_invoke_result_t<_Tag, _Ts...>;
47 stdexec::tag_invocable<_Tag, _Ts...>;
51 stdexec::nothrow_tag_invocable<_Tag, _Ts...>;
54 using tag_t STDEXEC_STD_DEPRECATED = stdexec::tag_t<_Tag>;
60 stdexec::stoppable_token<_Token>;
64 stdexec::stoppable_token_for<_Token, _Callback, _Initializer>;
68 stdexec::unstoppable_token<_Token>;
70 using never_stop_token STDEXEC_STD_DEPRECATED = stdexec::never_stop_token;
[all …]
H A D__cpo.hpp69 ::stdexec::__arg_type_t<void(__VA_ARGS__())>
74 const ::stdexec::__tag_type_t<__VA_ARGS__##_t::*>&, STDEXEC_MEMFN_DECL_ARGS
84 using STDEXEC_CAT(_TAG, _t) = STDEXEC_CAT(stdexec::_TAG, _t)
103 namespace stdexec namespace
131 using stdexec::connect_t;
132 using stdexec::get_completion_signatures_t;
133 using stdexec::get_env_t;
134 using stdexec::set_error_t;
135 using stdexec::set_stopped_t;
136 using stdexec::set_value_t;
[all …]
H A D__run_loop.hpp33 namespace stdexec namespace
60 using _Receiver = stdexec::__t<_ReceiverId>;
75 if (stdexec::get_stop_token(stdexec::get_env(__rcvr)) in __execute_impl()
78 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
82 stdexec::set_value(static_cast<_Receiver&&>(__rcvr)); in __execute_impl()
87 stdexec::set_error(static_cast<_Receiver&&>(__rcvr), in __execute_impl()
119 using completion_signatures = stdexec::completion_signatures<
125 stdexec::__t<__operation<stdexec::__id<_Receiver>>>;
182 -> stdexec::forward_progress_guarantee in query()
184 return stdexec::forward_progress_guarantee::parallel; in query()
[all …]
H A D__submit.hpp28 namespace stdexec namespace
52 using _Receiver = stdexec::__t<__mapply<__q<__msecond>, _Operation>>;
61 auto&& __env = stdexec::get_env(__op->__rcvr_); in __delete_op()
62 auto __alloc = stdexec::get_allocator(__env); in __delete_op()
80 stdexec::set_value(static_cast<_Receiver&&>(__opref_().__rcvr_), in set_value()
88 stdexec::set_error(static_cast<_Receiver&&>(__opref_().__rcvr_), in set_error()
95 stdexec::set_stopped(__opref_().__rcvr_); in set_stopped()
102 return stdexec::get_env(__opref_().__rcvr_); in get_env()
109 using _Sender = stdexec::__t<_SenderId>;
110 using _Receiver = stdexec::__t<_ReceiverId>;
[all …]
H A D__schedule_from.hpp32 namespace stdexec namespace
95 using _Scheduler = stdexec::__t<_SchedulerId>;
160 stdexec::set_error(static_cast<_Receiver&&>(__state_->__receiver()), in set_error()
166 stdexec::set_stopped(static_cast<_Receiver&&>(__state_->__receiver())); in set_stopped()
171 return stdexec::get_env(__state_->__receiver()); in get_env()
203 return stdexec::transform_sender( in operator ()()
225 return __env::__join(__data, stdexec::get_env(__child));
240 get_completion_scheduler<set_value_t>(stdexec::get_env(__sndr));
265 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
273 stdexec::start(__state.__state2_);
H A D__basic_sender.hpp33 namespace stdexec namespace
67 stdexec::__descriptor_fn<_Tag, _Data, _Child>()
70 stdexec::__descriptor_fn_v<stdexec::__detail::__desc<_Tag, _Data, _Child>>
114 return stdexec::get_env(
125 -> env_of_t<const _Receiver&> { return stdexec::get_env(__rcvr); };
171 using _Receiver = stdexec::__t<_ReceiverId>;
196 __op_->__complete(_Idx(), stdexec::set_value, in set_value()
204 __op_->__complete(_Idx(), stdexec::set_error, in set_error()
211 __op_->__complete(_Idx(), stdexec::set_stopped); in set_stopped()
720 struct tuple_size<stdexec::__sexpr<_Descriptor>> :
[all …]
H A D__read_env.hpp33 namespace stdexec namespace
38 using __result_t = __call_result_t<_Tag, env_of_t<stdexec::__t<_ReceiverId>>>;
42 __nothrow_callable<_Tag, env_of_t<stdexec::__t<_ReceiverId>>>;
113 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
114 __query(), stdexec::get_env(__rcvr));
123 return __query()(stdexec::get_env(__rcvr)); in __anona47160310102()
127 stdexec::__set_value_invoke(static_cast<_Receiver&&>(__rcvr),
H A D__connect_awaitable.hpp30 namespace stdexec namespace
106 using promise_type = stdexec::__t<__promise<_ReceiverId>>;
114 using _Receiver = stdexec::__t<_ReceiverId>;
128 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in unhandled_stopped()
136 -> stdexec::__t<__operation<_ReceiverId>> in get_return_object()
138 return stdexec::__t<__operation<_ReceiverId>>{ in get_return_object()
161 return stdexec::get_env(__rcvr_); in get_env()
H A D__stopped_as_optional.hpp34 namespace stdexec namespace
95 stdexec::set_value(static_cast<_Receiver&&>(__rcvr),
101 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
107 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
112 stdexec::set_value(static_cast<_Receiver&&>(__rcvr),
H A D__receivers.hpp27 namespace stdexec namespace
61 (void)tag_invoke(stdexec::set_value_t{}, in operator ()()
97 (void)tag_invoke(stdexec::set_error_t{}, in operator ()()
129 (void)tag_invoke(stdexec::set_stopped_t{}, in operator ()()
211 stdexec::set_value(static_cast<_Receiver&&>(__rcvr)); in __set_value_invoke()
224 stdexec::__set_value_invoke<true>(static_cast<_Receiver&&>(__rcvr), in __set_value_invoke()
230 stdexec::set_error(static_cast<_Receiver&&>(__rcvr), in __set_value_invoke()
H A D__start_detached.hpp28 namespace stdexec namespace
37 using _Env = stdexec::__t<_EnvId>;
77 stdexec::apply_sender(__domain, *this, static_cast<_Sender&&>(__sndr)); in operator ()()
87 stdexec::apply_sender(__domain, *this, static_cast<_Sender&&>(__sndr), in operator ()()
H A D__let.hpp37 namespace stdexec namespace
117 stdexec::set_value(static_cast<_Receiver&&>(__rcvr_), in set_value()
124 stdexec::set_error(static_cast<_Receiver&&>(__rcvr_), in set_error()
130 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
137 __env::__without(stdexec::get_env(__rcvr_), get_domain)); in get_env()
338 stdexec::get_env(__child))}, in __mk_transform_env_fn()
442 return stdexec::get_env(__rcvr); in __get_env()
448 __env::__without(stdexec::get_env(__rcvr), get_domain)); in __get_env()
477 return stdexec::transform_sender( in operator ()()
523 stdexec::get_env(__child));
[all …]
H A D__as_awaitable.hpp34 namespace stdexec namespace
67 stdexec::set_error(static_cast<__receiver_base&&>(*this), in set_value()
93 using _Promise = stdexec::__t<_PromiseId>;
115 return stdexec::get_env(__continuation.promise()); in get_env()
178 using _Promise = stdexec::__t<_PromiseId>;
179 using _Sender = stdexec::__t<_SenderId>;
192 stdexec::start(__op_state_); in await_suspend()
H A D__spin_loop_pause.hpp30 namespace stdexec namespace
43 namespace stdexec namespace
63 namespace stdexec namespace
H A D__awaitable.hpp22 namespace stdexec namespace
125 stdexec::__get_awaiter(static_cast<_Awaitable&&>(__awaitable),
136 decltype(stdexec::__as_lvalue(
137 stdexec::__get_awaiter(std::declval<_Awaitable>(),
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp23 struct sequence_sender_t : stdexec::sender_t
31 using namespace stdexec;
85 stdexec::__declval<stdexec::__decay_t<_Receiver>&>(),
86 stdexec::__declval<_Sender>()));
96 using receiver_concept = stdexec::receiver_t;
98 using _Receiver = stdexec::__t<_ReceiverId>;
105 return stdexec::get_env(__rcvr_); in get_env()
111 return stdexec::set_value(static_cast<_Receiver&&>(__rcvr_)); in set_value()
121 stdexec::set_value(static_cast<_Receiver&&>(__rcvr_)); in set_stopped()
126 stdexec::get_stop_token(stdexec::get_env(__rcvr_)); in set_stopped()
[all …]
H A Denv.hpp26 using with_t = stdexec::prop<_Tag, _Value>;
35 return stdexec::prop{_Tag(), static_cast<_Value&&>(__val)}; in operator ()()
44 return stdexec::__env::__without(static_cast<_Env&&>(__env), _Tag()); in operator ()()
52 template <stdexec::__nothrow_move_constructible _Base,
53 stdexec::__nothrow_move_constructible _Env>
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>
74 using make_env_t = stdexec::__result_of<make_env, _Ts...>;
78 using namespace stdexec;
[all …]
H A Dasync_scope.hpp32 using namespace stdexec;
40 __a.nest(stdexec::just())
41 } -> sender_of<stdexec::set_value_t()>;
76 using _Receiver = stdexec::__t<_ReceiverId>;
85 __op_(stdexec::connect(static_cast<_Constrained&&>(__sndr),
100 stdexec::start(this->__op_); in start()
106 stdexec::start(static_cast<__t*>(__self)->__op_); in __notify_waiter()
117 using _Constrained = stdexec::__t<_ConstrainedId>;
122 using sender_concept = stdexec::sender_t;
126 stdexec::__t<__when_empty_op<__cvref_id<_Self, _Constrained>,
[all …]
H A Dany_sender_of.hpp31 using namespace stdexec;
41 return stdexec::tag_invoke(__create_vtable_t{}, __mtype<_VTable>{}, in operator ()()
107 return _Tag{}(stdexec::get_env(*static_cast<const _EnvProvider*>( in __anon1bf2f58b0102()
122 return _Tag{}(stdexec::get_env(*static_cast<const _EnvProvider*>( in __anon1bf2f58b0202()
217 stdexec::tag_invoke(__delete_t{}, __mtype<_Tp>{}, __storage); in operator ()()
232 stdexec::tag_invoke(__copy_construct_t{}, __mtype<_Tp>{}, __self, in operator ()()
249 stdexec::tag_invoke(__move_construct_t{}, __mtype<_Tp>{}, __self, in operator ()()
792 stdexec::__t<__vtable<completion_signatures<_Sigs...>, _Queries...>>;
816 using receiver_concept = stdexec::receiver_t;
825 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
[all …]
H A Dexecution.hpp74 template <stdexec::sender _Ignore, stdexec::sender _Sender>
75 requires stdexec::__ok<stdexec::__bad_pipe_sink_t<_Sender>>
H A Dat_coroutine_exit.hpp32 using namespace stdexec;
47 using receiver_concept = stdexec::receiver_t;
55 stdexec::set_value(static_cast<_Receiver&&>(__receiver_), in set_value()
63 stdexec::set_error(static_cast<_Receiver&&>(__receiver_), in set_error()
74 return stdexec::get_env(__receiver_); in get_env()
93 using sender_concept = stdexec::sender_t;
102 return stdexec::connect( in connect()
116 return stdexec::get_env(__sender_); in get_env()
/openbmc/sdbusplus/test/async/
H A Dtask.cpp20 stdexec::sync_wait(t()); in TEST()
44 stdexec::sync_wait(_::two(executed)); in TEST()
72 EXPECT_THROW(stdexec::sync_wait(_::one()), std::logic_error); in TEST()
76 stdexec::sync_wait(_::two(caught)); in TEST()
91 co_return co_await stdexec::just(0); in TEST()
98 stdexec::sync_wait( in TEST()
100 stdexec::then([=](auto result) { EXPECT_EQ(result, count); })); in TEST()
H A Dcontext.cpp18 ctx->spawn(stdexec::just() | in spawnStop()
19 stdexec::then([this]() { ctx->request_stop(); })); in spawnStop()
38 ctx->spawn(stdexec::just()); in TEST_F()
60 stdexec::then([&ran]() { ran = true; })); in TEST_F()
83 co_return co_await stdexec::just(0); in TEST_F()
91 stdexec::then([=](auto result) { EXPECT_EQ(result, count); })); in TEST_F()
108 ctx->spawn(m->next() | stdexec::then([&ran](...) { ran = true; })); in TEST_F()
112 stdexec::then([&m](...) { m.reset(); })); in TEST_F()
140 stdexec::then([&]() { m.reset(); })); in TEST_F()
/openbmc/pldm/requester/
H A Dhandler.hpp410 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto
469 template <class RequestInterface, stdexec::receiver R>
500 friend void tag_invoke(stdexec::start_t, SendRecvMsgOperation& op) noexcept in tag_invoke()
502 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
507 return stdexec::set_stopped(std::move(op.receiver)); in tag_invoke()
517 return stdexec::set_value(std::move(op.receiver), rc, in tag_invoke()
537 return stdexec::set_stopped(std::move(receiver)); in onStop()
558 return stdexec::set_value(std::move(receiver), static_cast<int>(rc), in onComplete()
592 std::optional<typename stdexec::stop_token_of_t<
593 stdexec::env_of_t<R>>::template callback_type<std::function<void()>>>
[all …]
/openbmc/pldm/requester/test/
H A Dhandler_test.cpp167 stdexec::just() | stdexec::let_value([&] -> exec::task<void> { in TEST_F()
200 stdexec::sync_wait(scope.on_empty()); in TEST_F()
215 stdexec::just() | stdexec::let_value([&] -> exec::task<void> { in TEST_F()
225 }) | stdexec::upon_stopped([&] { stopped = true; }), in TEST_F()
232 stdexec::sync_wait(scope.on_empty()); in TEST_F()
272 scope.spawn(stdexec::just() | stdexec::let_value([&] -> exec::task<void> { in TEST_F()
295 stdexec::sync_wait(scope.on_empty()); in TEST_F()

12345