Method RuntimeControlService

src/runtime/runtime_service.cpp:255–469

}

RuntimeControlService::RuntimeControlService(std::string vm_id, std::string pipe_name)
    : vm_id_(std::move(vm_id)), pipe_name_(std::move(pipe_name)) {
    console_port_->SetDataAvailableCallback([this]() {
        if (running_) uv_async_send(&send_wakeup_);
    });

    display_port_->SetFrameHandler([this](DisplayFrame frame) {
        uint32_t resW = frame.resource_width ? frame.resource_width : frame.width;
        uint32_t resH = frame.resource_height ? frame.resource_height : frame.height;

        // Create or resize shared framebuffer when resource dimensions change.
        // Each resize uses a unique name (generation suffix) so the Manager
        // can open the new mapping without conflicting with the old one that
        // may still be mapped on its side.
        if (!shm_fb_.IsValid() || shm_fb_.width() != resW || shm_fb_.height() != resH) {
            if (shm_fb_.IsValid()) {
                shm_fb_.Close();
            }
            ++shm_generation_;
            std::string shm_name = ipc::GetSharedFramebufferName(vm_id_)
                                   + "_" + std::to_string(shm_generation_);
            if (!shm_fb_.Create(shm_name, resW, resH)) {
                LOG_ERROR("RuntimeService: failed to create shared framebuffer %ux%u", resW, resH);
                return;
            }
            shm_init_sent_ = false;
            shm_frame_seq_ = 0;
        }

        // Send shm_init notification so the manager can open the mapping.
        if (!shm_init_sent_) {
            ipc::Message init;
            init.kind = ipc::Kind::kEvent;
            init.channel = ipc::Channel::kDisplay;
            init.type = "display.shm_init";
            init.vm_id = vm_id_;
            init.request_id = next_event_id_++;
            init.fields["shm_name"] = shm_fb_.name();
            init.fields["width"] = std::to_string(resW);
            init.fields["height"] = std::to_string(resH);
            Send(init);
            shm_init_sent_ = true;
        }

        // Blit dirty rect into shared memory.
        uint32_t dx = frame.dirty_x;
        uint32_t dy = frame.dirty_y;
        uint32_t dw = frame.width;
        uint32_t dh = frame.height;
        uint32_t src_stride = frame.stride;
        uint32_t dst_stride = shm_fb_.stride();
        const uint8_t* src = frame.data();
        uint8_t* dst = shm_fb_.data();

        for (uint32_t row = 0; row < dh; ++row) {
            size_t src_off = static_cast<size_t>(row) * src_stride;
            size_t dst_off = static_cast<size_t>(dy + row) * dst_stride +
                             static_cast<size_t>(dx) * 4;