Method ReadRemoteFrame

src/daemon/runtime_manager.cpp:1405–1460

}

bool RuntimeManager::ReadRemoteFrame(const std::string& vm_id,
                                     RemoteVideoFrame* frame,
                                     bool need_full_frame,
                                     std::chrono::milliseconds wait_timeout) {
    auto session = FindSession(vm_id);
    if (!session || !frame) return false;
    std::unique_lock<std::mutex> lock(session->frame_mutex);

    // Block the consumer until either the producer queues new slices or the
    // timeout expires. need_full_frame short-circuits the wait because we can
    // synthesize a full-frame slice from the shared framebuffer regardless of
    // whether new partials have arrived.
    if (wait_timeout.count() > 0 &&
        !need_full_frame &&
        session->remote_frame.slices.empty() &&
        session->running.load()) {
        session->remote_frame_cv.wait_for(lock, wait_timeout, [&] {
            return !session->remote_frame.slices.empty() ||
                   session->remote_frame_force_full ||
                   !session->running.load();
        });
    }

    if ((need_full_frame || session->remote_frame_force_full) &&
        session->framebuffer &&
        session->framebuffer->IsValid() &&
        session->framebuffer->width() > 0 &&
        session->framebuffer->height() > 0) {
        const PixelFormat target_format = session->remote_video_format;
        RemoteVideoSlice full = MakeSliceFromBgra(
            session->framebuffer->data(),
            static_cast<int>(session->framebuffer->stride()),
            0, 0,
            session->framebuffer->width(),
            session->framebuffer->height(),
            target_format);
        if (!full.data.empty()) {
            session->remote_frame.slices.clear();
            session->remote_frame.slices.push_back(std::move(full));
            session->remote_frame.width = session->framebuffer->width();
            session->remote_frame.height = session->framebuffer->height();
            session->remote_frame.format = target_format;
            session->remote_frame_force_full = false;
        }
    }

    if (session->remote_frame.slices.empty()) return false;

    frame->width = session->remote_frame.width;
    frame->height = session->remote_frame.height;
    frame->format = session->remote_frame.format;
    frame->seq = session->remote_frame.seq;
    frame->slices = std::move(session->remote_frame.slices);
    session->remote_frame.slices.clear();
    return true;
}

bool RuntimeManager::AttachConsole(const std::string& vm_id, ipc::UnixSocketConnection* client, std::string* error) {