MCPcopy Create free account
hub / github.com/NVIDIA/stdexec / complete

Method complete

include/exec/linux/io_uring_context.hpp:851–862  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

849 static constexpr void submit(::io_uring_sqe&) noexcept {}
850
851 void complete(::io_uring_cqe const & __cqe) noexcept
852 {
853 auto token = STDEXEC::get_stop_token(STDEXEC::get_env(__rcvr_));
854 if (__cqe.res == -ECANCELED || __context_.stop_requested() || token.stop_requested())
855 {
856 STDEXEC::set_stopped(static_cast<_Receiver&&>(__rcvr_));
857 }
858 else
859 {
860 STDEXEC::set_value(static_cast<_Receiver&&>(__rcvr_));
861 }
862 }
863
864 __context& __context_;
865 STDEXEC_ATTRIBUTE(no_unique_address) _Receiver __rcvr_;

Callers

nothing calls this directly

Calls 4

set_valueFunction · 0.85
get_envFunction · 0.50
set_stoppedFunction · 0.50
stop_requestedMethod · 0.45

Tested by

no test coverage detected