Method RetireSignal

layers/state_tracker/semaphore_state.cpp:501–525

}

void vvl::Semaphore::RetireSignal(uint64_t payload) {
    auto guard = WriteLock();
    if (payload <= completed_.payload) {
        return;
    }
    TimePoint& timepoint = vvl::FindExisting(timeline_, payload);
    assert(timepoint.signal_submit.has_value());

    OpType completed_op = kSignal;
    const Queue* completed_op_queue = timepoint.signal_submit->queue;

    // If there is a wait operation then mark it as the last completed instead.
    // The reason to do this here instead on the waiter side (after it is unblocked)
    // is because signal can have larger (timeline) value than corresponding wait value.
    // In this case it's the signal that defines the last completed value.
    if (!timepoint.wait_submits.empty()) {
        completed_op = kWait;
        // NOTE: for timeline semaphores there can be several waiters. Also for timeline
        // semaphores the queue of the completed operation is only used by Semaphore::InUse
        // for reporting purposes. We can choose any valid wait queue if there are multiple.
        completed_op_queue = timepoint.wait_submits[0].queue;
    }

    RetireTimePoint(payload, completed_op, completed_op_queue);
}

void vvl::Semaphore::RetireTimePoint(uint64_t payload, OpType completed_op, const Queue* completed_op_queue) {
    auto it = timeline_.begin();