Method SetLaunchConfig

preempt/src/xqueue/async_xqueue.cpp:176–207

}

void AsyncXQueue::SetLaunchConfig(int64_t threshold, int64_t batch_size)
{
    if (threshold <= 0 && batch_size <= 0) return;

    // Check command threshold.
    if (threshold <= 0) {
        threshold = launch_worker_->GetThreshold();
    } else {
        XASSERT(this->GetFeatures(kQueueFeatureDynamicThreshold),
                "AsyncXQueue does not support dynamic threshold");
    }

    // Check command batch size.
    if (batch_size <= 0) {
        batch_size = launch_worker_->GetBatchSize();
    } else {
        XASSERT(this->GetFeatures(kQueueFeatureDynamicBatchSize),
                "AsyncXQueue does not support dynamic batch size");
    }

    // Check threshold and batch size are valid.
    XASSERT(threshold >= batch_size,
            "command threshold (" FMT_64D ") must not be smaller than "
            "command batch size (" FMT_64D ")", threshold, batch_size);

    // Not thread-safe.
    // TODO: change to thread-safe
    this->WaitAll();
    launch_worker_->SetLaunchConfig(threshold, batch_size);
    SchedAgent::SendEvent(std::make_shared<XQueueConfigUpdateEvent>(kHandle, kDevice, level_,
        launch_worker_->GetThreshold(), launch_worker_->GetBatchSize()));
}