WIP

pop-os · Dec 4, 2024 · 95ce3d0 · 95ce3d0
1 parent a14d075
commit 95ce3d0
Show file tree

Hide file tree

Showing 13 changed files with 342 additions and 246 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -119,4 +119,5 @@ inherits = "release"
 lto = "fat"
 
 [patch."https://github.com/Smithay/smithay.git"]
-smithay = { git = "https://github.com/smithay//smithay", rev = "bc1d732" }
+#smithay = { git = "https://github.com/smithay//smithay", rev = "bc1d732" }
+smithay = { git = "https://github.com/cmeissl/smithay", branch = "feature/drm_auto_select" }
diff --git a/src/backend/kms/device.rs b/src/backend/kms/device.rs
@@ -4,25 +4,31 @@ use crate::{
     config::{AdaptiveSync, OutputConfig, OutputState},
     shell::Shell,
     utils::prelude::*,
+    wayland::protocols::screencopy::Frame as ScreencopyFrame,
 };
 
 use anyhow::{Context, Result};
 use libc::dev_t;
 use smithay::{
     backend::{
-        allocator::gbm::GbmDevice,
-        drm::{DrmDevice, DrmDeviceFd, DrmEvent, DrmNode},
+        allocator::{
+            gbm::{GbmAllocator, GbmDevice},
+            Fourcc,
+        },
+        drm::{output::DrmOutputManager, DrmDevice, DrmDeviceFd, DrmEvent, DrmNode},
         egl::{context::ContextPriority, EGLContext, EGLDevice, EGLDisplay},
         session::Session,
     },
+    desktop::utils::OutputPresentationFeedback,
     output::{Mode as OutputMode, Output, PhysicalProperties, Scale, Subpixel},
     reexports::{
         calloop::{LoopHandle, RegistrationToken},
         drm::control::{connector, crtc, Device as ControlDevice, ModeTypeFlags},
+        gbm::BufferObjectFlags as GbmBufferFlags,
         rustix::fs::OFlags,
         wayland_server::{protocol::wl_buffer::WlBuffer, DisplayHandle, Weak},
     },
-    utils::{DevPath, DeviceFd, Point, Transform},
+    utils::{Buffer as BufferCoords, DevPath, DeviceFd, Point, Rectangle, Transform},
     wayland::drm_lease::{DrmLease, DrmLeaseState},
 };
 use tracing::{error, info, warn};
@@ -32,7 +38,7 @@ use std::{
     collections::{HashMap, HashSet},
     fmt,
     path::{Path, PathBuf},
-    sync::{atomic::AtomicBool, Arc, RwLock},
+    sync::{atomic::AtomicBool, mpsc::Receiver, Arc, RwLock},
 };
 
 use super::{drm_helpers, socket::Socket, surface::Surface};
@@ -44,15 +50,25 @@ pub struct EGLInternals {
     pub context: EGLContext,
 }
 
+pub type GbmDrmOutputManager = DrmOutputManager<
+    GbmAllocator<DrmDeviceFd>,
+    GbmDevice<DrmDeviceFd>,
+    Option<(
+        OutputPresentationFeedback,
+        Receiver<(ScreencopyFrame, Vec<Rectangle<i32, BufferCoords>>)>,
+    )>,
+    DrmDeviceFd,
+>;
+
 pub struct Device {
     pub dev_node: DrmNode,
     pub render_node: DrmNode,
     pub egl: Option<EGLInternals>,
 
     pub outputs: HashMap<connector::Handle, Output>,
     pub surfaces: HashMap<crtc::Handle, Surface>,
+    pub drm: GbmDrmOutputManager,
     pub gbm: GbmDevice<DrmDeviceFd>,
-    pub drm: DrmDevice,
 
     supports_atomic: bool,
 
@@ -72,8 +88,7 @@ impl fmt::Debug for Device {
             .field("render_node", &self.render_node)
             .field("outputs", &self.outputs)
             .field("surfaces", &self.surfaces)
-            .field("drm", &self.drm)
-            .field("gbm", &self.gbm)
+            .field("drm", &"..")
             .field("egl", &self.egl)
             .field("supports_atomic", &self.supports_atomic)
             .field("leased_connectors", &self.leased_connectors)
@@ -190,15 +205,32 @@ impl State {
             }
         };
 
+        let drm = GbmDrmOutputManager::new(
+            drm,
+            GbmAllocator::new(
+                gbm.clone(),
+                GbmBufferFlags::RENDERING | GbmBufferFlags::SCANOUT,
+            ),
+            gbm.clone(),
+            Some(gbm.clone()),
+            [
+                Fourcc::Abgr2101010,
+                Fourcc::Argb2101010,
+                Fourcc::Abgr8888,
+                Fourcc::Argb8888,
+            ],
+            render_formats,
+        );
+
         let mut device = Device {
             dev_node: drm_node,
             render_node,
             egl: None,
 
             outputs: HashMap::new(),
             surfaces: HashMap::new(),
-            gbm: gbm.clone(),
             drm,
+            gbm,
 
             supports_atomic,
 
@@ -264,6 +296,7 @@ impl State {
             &mut self.common.workspace_state.update(),
             &self.common.xdg_activation_state,
             self.common.startup_done.clone(),
+            &self.common.clock,
         );
 
         self.backend.kms().refresh_used_devices()?;
@@ -364,6 +397,7 @@ impl State {
                 &mut self.common.workspace_state.update(),
                 &self.common.xdg_activation_state,
                 self.common.startup_done.clone(),
+                &self.common.clock,
             );
             // Don't remove the outputs, before potentially new ones have been initialized.
             // reading a new config means outputs might become enabled, that were previously disabled.
@@ -417,6 +451,7 @@ impl State {
                 &mut self.common.workspace_state.update(),
                 &self.common.xdg_activation_state,
                 self.common.startup_done.clone(),
+                &self.common.clock,
             );
             self.common.refresh();
         } else {
@@ -435,7 +470,8 @@ pub struct OutputChanges {
 impl Device {
     pub fn enumerate_surfaces(&mut self) -> Result<OutputChanges> {
         // enumerate our outputs
-        let config = drm_helpers::display_configuration(&mut self.drm, self.supports_atomic)?;
+        let config =
+            drm_helpers::display_configuration(self.drm.device_mut(), self.supports_atomic)?;
 
         let surfaces = self
             .surfaces
@@ -486,19 +522,20 @@ impl Device {
             .get(&conn)
             .cloned()
             .map(|output| Ok(output))
-            .unwrap_or_else(|| create_output_for_conn(&mut self.drm, conn))
+            .unwrap_or_else(|| create_output_for_conn(self.drm.device_mut(), conn))
             .context("Failed to create `Output`")?;
 
-        let non_desktop = match drm_helpers::get_property_val(&self.drm, conn, "non-desktop") {
-            Ok((val_type, value)) => val_type.convert_value(value).as_boolean().unwrap(),
-            Err(err) => {
-                warn!(
-                    ?err,
-                    "Failed to determine if connector is meant desktop usage, assuming so."
-                );
-                false
-            }
-        };
+        let non_desktop =
+            match drm_helpers::get_property_val(self.drm.device_mut(), conn, "non-desktop") {
+                Ok((val_type, value)) => val_type.convert_value(value).as_boolean().unwrap(),
+                Err(err) => {
+                    warn!(
+                        ?err,
+                        "Failed to determine if connector is meant desktop usage, assuming so."
+                    );
+                    false
+                }
+            };
 
         if non_desktop {
             if let Some(crtc) = maybe_crtc {
@@ -528,7 +565,7 @@ impl Device {
                 .user_data()
                 .insert_if_missing(|| RefCell::new(OutputConfig::default()));
 
-            populate_modes(&mut self.drm, &output, conn, position)
+            populate_modes(self.drm.device_mut(), &output, conn, position)
                 .with_context(|| "Failed to enumerate connector modes")?;
 
             let has_surface = if let Some(crtc) = maybe_crtc {