Method try_cancel

modules/engine/runtime/src/io/common/io_runner.cpp:205–236

}

bool RunnerBase::try_cancel(SkrAsyncServicePriority priority, IORequestId rq) SKR_NOEXCEPT
{
    if (auto pComp = io_component<IOStatusComponent>(rq.get()))
    {
        const auto status = pComp->getStatus();
        if (status == SKR_IO_STAGE_CANCELLED) return true;
        if (status == SKR_IO_STAGE_LOADING) return false;

        if (bool cancel_requested = pComp->getCancelRequested())
        {
            if (pComp->getFinishStep() == SKR_ASYNC_IO_FINISH_STEP_NONE)
            {
                if (pComp->is_async_cancel())
                {
                    auto cancel = [this, priority, rq = rq.get()] { return cancel_(rq, priority); };
                    finish_futures.emplace_back(skr::FutureLauncher<bool>(job_queue).async(cancel), rq);
                }
                else
                {
                    cancel_(rq.get(), priority);
                }
            }
            // remove from batch
            if (auto batch = static_cast<IOBatchBase*>(pComp->getOwnerBatch()))
                batch->removeCancelledRequest(rq);
            else
                SKR_UNREACHABLE_CODE();
            return true;
        }
    }
    return false;
}

void RunnerBase::dispatch_complete_(SkrAsyncServicePriority priority, IORequestId rq) SKR_NOEXCEPT
{