Method EnqueueXQueueWaitAllCommand

preempt/src/xqueue/command_buffer.cpp:127–155

}

std::shared_ptr<XQueueWaitAllCommand> CommandBuffer::EnqueueXQueueWaitAllCommand()
{
    std::unique_lock<std::mutex> lock(mtx_);

    if (xq_state_ == kQueueStateIdle) {
        // If the XQueue is idle, syncing on this XQueue should return. Here, we should return
        // a completed XCommand so that syncing on this XQueue will return immediately.
        auto wait_all_cmd = std::dynamic_pointer_cast<XQueueWaitAllCommand>(last_enqueued_cmd_);
        XASSERT(last_enqueued_cmd_->GetType() == kCommandTypeXQueueWaitAll &&
                wait_all_cmd != nullptr,
                "last_enqueued_cmd_ must be an XQueueWaitAllCommand if the XQueue is idle");
        return wait_all_cmd;
    }

    if (last_enqueued_cmd_->GetType() == kCommandTypeXQueueWaitAll) {
        auto wait_all_cmd = std::dynamic_pointer_cast<XQueueWaitAllCommand>(last_enqueued_cmd_);
        XASSERT(wait_all_cmd != nullptr, "last_enqueued_cmd_ must be an XQueueWaitAllCommand");
        return wait_all_cmd;
    }

    auto xcmd = std::make_shared<XQueueWaitAllCommand>();
    xcmd->SetState(kCommandStatePending);
    last_enqueued_cmd_ = xcmd;
    cmds_.emplace_back(xcmd);

    lock.unlock();
    cv_.notify_all();
    return xcmd;
}