| 1029 | } |
| 1030 | |
| 1031 | void submit(::io_uring_sqe& __sqe) noexcept |
| 1032 | { |
| 1033 | [[maybe_unused]] |
| 1034 | int prev = __n_ops_.fetch_add(1, STDEXEC::__std::memory_order_relaxed); |
| 1035 | STDEXEC_ASSERT(prev == 0); |
| 1036 | __context& __context_ = this->__base_.context(); |
| 1037 | __receiver_t& __receiver = this->__base_.receiver(); |
| 1038 | __on_context_stop_.emplace(__context_.get_stop_token(), __stop_callback{this}); |
| 1039 | __on_receiver_stop_.emplace(STDEXEC::get_stop_token(STDEXEC::get_env(__receiver)), |
| 1040 | __stop_callback{this}); |
| 1041 | this->__base_.submit(__sqe); |
| 1042 | } |
| 1043 | |
| 1044 | void complete(::io_uring_cqe const & __cqe) noexcept |
| 1045 | { |