Function CancelJobInternal

engine/dlib/src/dlib/jobsystem.cpp:330–377

}

static JobSystemResult CancelJobInternal(JobThreadContext* ctx, HJob hjob)
{
    JobItem* item = GetJobItem(ctx, hjob);
    if (!item)
        return JOBSYSTEM_RESULT_INVALID_HANDLE;

    JobSystemResult result = JOBSYSTEM_RESULT_CANCELED;

    if (item->m_Status == JOBSYSTEM_STATUS_PROCESSING || item->m_Status == JOBSYSTEM_STATUS_CALLBACK)
    {
        item->m_CancelRequested = 1;
        result = JOBSYSTEM_RESULT_PENDING;
    }
    else if (item->m_Status == JOBSYSTEM_STATUS_FINISHED)
    {
        item->m_Status = JOBSYSTEM_STATUS_CANCELED;
        item->m_Result = 0;
    }
    else
    {
        // Can only cancel queued/created items directly, but still wait on children when already canceled
        assert(item->m_Status == JOBSYSTEM_STATUS_CREATED || item->m_Status == JOBSYSTEM_STATUS_QUEUED || item->m_Status == JOBSYSTEM_STATUS_CANCELED);
        item->m_Status = JOBSYSTEM_STATUS_CANCELED;
    }

    HJob hchild = item->m_FirstChild;
    while (hchild != INVALID_JOB)
    {
        JobSystemResult childresult = CancelJobInternal(ctx, hchild);
        if (childresult == JOBSYSTEM_RESULT_INVALID_HANDLE)
        {
            break; // We cannot get the item pointer
        }

        JobItem* child = GetJobItem(ctx, hchild);
        if (child == 0)
        {
            break; // We cannot iterate further
        }

        if (childresult == JOBSYSTEM_RESULT_PENDING)
            result = JOBSYSTEM_RESULT_PENDING;

        hchild = child->m_Sibling;
    }

    return result;
}

JobSystemResult JobSystemCancelJob(HJobContext context, HJob hjob)
{