Method complete

include/exec/linux/io_uring_context.hpp:311–336

This function first completes all tasks that are ready in the completion queue of the io_uring. Then it completes all tasks that are ready in the given queue of ready tasks. The function returns the number of previously submitted completed tasks.

      // Then it completes all tasks that are ready in the given queue of ready tasks.
      // The function returns the number of previously submitted completed tasks.
      auto complete(STDEXEC::__intrusive_queue<&__task::__next_> __ready = __task_queue{}) noexcept
        -> int
      {
        __u32 __head  = __head_.load(STDEXEC::__std::memory_order_relaxed);
        __u32 __tail  = __tail_.load(STDEXEC::__std::memory_order_acquire);
        int   __count = 0;
        while (__head != __tail)
        {
          __u32 const            __index = __head & __mask_;
          ::io_uring_cqe const & __cqe   = __entries_[__index];
          auto*                  __op    = bit_cast<__task*>(__cqe.user_data);
          __op->__vtable_->__complete_(__op, __cqe);
          ++__head;
          ++__count;
          __tail = __tail_.load(STDEXEC::__std::memory_order_acquire);
        }
        __head_.store(__head, STDEXEC::__std::memory_order_release);
        while (!__ready.empty())
        {
          __task*        __op = __ready.pop_front();
          ::io_uring_cqe __dummy_cqe{};
          __dummy_cqe.user_data = bit_cast<__u64>(__op);
          __op->__vtable_->__complete_(__op, __dummy_cqe);
        }
        return __count;
      }
    };

    class __context;