| /openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
| H A D | __p2300.hpp | 47 stdexec::tag_invocable<_Tag, _Ts...>;
60 stdexec::stoppable_token<_Token>;
68 stdexec::unstoppable_token<_Token>;
73 stdexec::in_place_stop_source;
86 stdexec::get_delegatee_scheduler_t;
124 stdexec::forward_progress_guarantee;
154 stdexec::operation_state<_OpState>;
266 stdexec::when_all_with_variant_t;
272 stdexec::stopped_as_optional_t;
342 stdexec::completion_signatures<stdexec::set_stopped_t()>>
[all …]
|
| H A D | __cpo.hpp | 69 ::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.hpp | 33 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.hpp | 28 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 | __basic_sender.hpp | 32 namespace stdexec namespace
66 stdexec::__descriptor_fn<_Tag, _Data, _Child>()
69 stdexec::__descriptor_fn_v<stdexec::__detail::__desc<_Tag, _Data, _Child>>
113 return stdexec::get_env(
170 using _Receiver = stdexec::__t<_ReceiverId>;
646 stdexec::__v<stdexec::__minvoke<
647 stdexec::__result_of<_Descriptor>, stdexec::__msize>>>
654 stdexec::__remove_rvalue_reference_t< //
655 stdexec::__call_result_t< //
656 stdexec::__detail::__impl_of<stdexec::__sexpr<_Descriptor>>,
[all …]
|
| H A D | __schedule_from.hpp | 32 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()
202 return stdexec::transform_sender( in operator ()()
224 return __env::__join(__data, stdexec::get_env(__child));
239 get_completion_scheduler<set_value_t>(stdexec::get_env(__sndr));
266 stdexec::set_error(static_cast<_Receiver&&>(__rcvr),
274 stdexec::start(__state.__state2_);
|
| H A D | __read_env.hpp | 33 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.hpp | 30 namespace stdexec namespace
106 using promise_type = stdexec::__t<__promise<_ReceiverId>>;
114 using _Receiver = stdexec::__t<_ReceiverId>;
124 stdexec::set_stopped(static_cast<_Receiver&&>(__rcvr_)); in unhandled_stopped()
132 -> stdexec::__t<__operation<_ReceiverId>> in get_return_object()
134 return stdexec::__t<__operation<_ReceiverId>>{ in get_return_object()
157 return stdexec::get_env(__rcvr_); in get_env()
|
| H A D | __stopped_as_optional.hpp | 34 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 | __spin_loop_pause.hpp | 30 namespace stdexec namespace
43 namespace stdexec namespace
63 namespace stdexec namespace
|
| H A D | __start_detached.hpp | 28 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 | __receivers.hpp | 27 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 | __as_awaitable.hpp | 34 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 | __let.hpp | 37 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()
436 return stdexec::get_env(__rcvr); in __get_env()
463 return stdexec::transform_sender( in operator ()()
509 stdexec::get_env(__child));
552 stdexec::connect, std::move(__sndr2), std::move(__rcvr2)); in __bind_()
553 stdexec::start(__op2); in __bind_()
[all …]
|
| H A D | __awaitable.hpp | 22 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 D | sequence_senders.hpp | 31 using namespace stdexec;
85 stdexec::__declval<stdexec::__decay_t<_Receiver>&>(),
126 stdexec::get_stop_token(stdexec::get_env(__rcvr_)); in set_stopped()
302 stdexec::completion_signatures<stdexec::set_stopped_t()>,
309 stdexec::completion_signatures<stdexec::set_value_t()>,
310 stdexec::__mconst<stdexec::completion_signatures<>>::__f>;
316 stdexec::completion_signatures<stdexec::set_value_t()>,
317 stdexec::__mconst<stdexec::completion_signatures<>>::__f>;
508 stdexec::__callable<stdexec::set_value_t, _Receiver> && //
510 stdexec::stop_token_of_t<stdexec::env_of_t<_Receiver>>> ||
[all …]
|
| H A D | env.hpp | 26 using with_t = stdexec::prop<_Tag, _Value>;
52 template <stdexec::__nothrow_move_constructible _Base,
53 stdexec::__nothrow_move_constructible _Env>
55 -> stdexec::__env::__join_t<_Env, _Base> in operator ()()
61 template <stdexec::__nothrow_move_constructible _Env>
74 using make_env_t = stdexec::__result_of<make_env, _Ts...>;
78 using namespace stdexec;
85 using _Default = stdexec::__t<_DefaultId>;
86 using _Receiver = stdexec::__t<_ReceiverId>;
113 stdexec::set_error(std::move(__rcvr_), in start()
[all …]
|
| H A D | async_scope.hpp | 31 using namespace stdexec;
99 stdexec::start(this->__op_); in start()
270 stdexec::start(__op_); in start()
291 stdexec::__t<__nest_op<_ConstrainedId, stdexec::__id<_Receiver>>>;
295 stdexec::__t<__nest_rcvr<stdexec::__id<_Receiver>>>;
362 using _Env = stdexec::__t<_EnvId>;
608 using _Env = stdexec::__t<_EnvId>;
720 using _Env = stdexec::__t<_EnvId>;
791 using __future_t = stdexec::__t<
817 using _Env = stdexec::__t<_EnvId>;
[all …]
|
| H A D | any_sender_of.hpp | 31 using namespace stdexec;
826 &__rcvr, stdexec::get_stop_token(stdexec::get_env(__rcvr))} in __ref()
1079 stdexec::get_stop_token(stdexec::get_env(this->__rcvr_)), in start()
1411 requires stdexec::tag_invocable<stdexec::set_value_t, __receiver_base,
1415 stdexec::tag_invoke(stdexec::set_value, in set_value()
1421 requires stdexec::tag_invocable<stdexec::set_error_t, __receiver_base,
1425 stdexec::tag_invoke(stdexec::set_error, in set_error()
1431 requires stdexec::tag_invocable<stdexec::set_stopped_t, __receiver_base> in set_stopped()
1433 stdexec::tag_invoke(stdexec::set_stopped, in set_stopped()
1491 stdexec::completion_signatures<stdexec::set_value_t()>>;
[all …]
|
| H A D | execution.hpp | 74 template <stdexec::sender _Ignore, stdexec::sender _Sender>
75 requires stdexec::__ok<stdexec::__bad_pipe_sink_t<_Sender>>
|
| H A D | at_coroutine_exit.hpp | 32 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 D | task.cpp | 20 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 D | context.cpp | 18 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 D | handler.hpp | 410 stdexec::sender_of<stdexec::set_value_t(SendRecvCoResp)> auto
469 template <class RequestInterface, stdexec::receiver R>
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()
537 return stdexec::set_stopped(std::move(receiver)); in onStop()
592 std::optional<typename stdexec::stop_token_of_t<
617 -> stdexec::completion_signatures<
618 stdexec::set_value_t(int, const pldm_msg*, size_t),
619 stdexec::set_stopped_t()>;
622 template <stdexec::receiver R>
[all …]
|
| /openbmc/pldm/requester/test/ |
| H A D | handler_test.cpp | 167 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()
|