Skip to content

Commit

Permalink
Add linux-drm-syncobj-v1 protocol
Browse files Browse the repository at this point in the history
  • Loading branch information
ids1024 committed Sep 24, 2024
1 parent d7ca032 commit 351a7f2
Show file tree
Hide file tree
Showing 6 changed files with 80 additions and 7 deletions.
10 changes: 5 additions & 5 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -116,4 +116,4 @@ inherits = "release"
lto = "fat"

[patch."https://github.com/Smithay/smithay.git"]
smithay = { git = "https://github.com/smithay//smithay", rev = "08d31e1" }
smithay = { git = "https://github.com/smithay//smithay", rev = "66236e3" }
28 changes: 27 additions & 1 deletion src/backend/kms/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,11 @@ use smithay::{
wayland_server::{Client, DisplayHandle},
},
utils::{DevPath, Size},
wayland::{dmabuf::DmabufGlobal, relative_pointer::RelativePointerManagerState},
wayland::{
dmabuf::DmabufGlobal,
drm_syncobj::{supports_syncobj_eventfd, DrmSyncobjState},
relative_pointer::RelativePointerManagerState,
},
};
use tracing::{error, info, trace, warn};

Expand Down Expand Up @@ -60,6 +64,8 @@ pub struct KmsState {

session: LibSeatSession,
libinput: Libinput,

pub syncobj_state: Option<DrmSyncobjState>,
}

pub fn init_backend(
Expand Down Expand Up @@ -126,6 +132,8 @@ pub fn init_backend(

session,
libinput: libinput_context,

syncobj_state: None,
});

// start x11
Expand All @@ -138,6 +146,24 @@ pub fn init_backend(
}
}

// TODO check if main device supports syncobj eventfd?
let kms = match &mut state.backend {
BackendData::Kms(kms) => kms,
_ => unreachable!(),
};
if let Some(primary_node) = kms
.primary_node
.and_then(|node| node.node_with_type(NodeType::Primary).and_then(|x| x.ok()))
{
if let Some(device) = kms.drm_devices.get(&primary_node) {
let import_device = device.drm.device_fd().clone();
if supports_syncobj_eventfd(&import_device) {
let syncobj_state = DrmSyncobjState::new::<State>(&dh, import_device);
kms.syncobj_state = Some(syncobj_state);
}
}
}

Ok(())
}

Expand Down
27 changes: 27 additions & 0 deletions src/wayland/handlers/compositor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ use smithay::{
CompositorHandler, CompositorState, SurfaceAttributes,
},
dmabuf::get_dmabuf,
drm_syncobj::DrmSyncobjCachedState,
seat::WaylandFocus,
shell::{
wlr_layer::LayerSurfaceAttributes,
Expand Down Expand Up @@ -100,7 +101,14 @@ impl CompositorHandler for State {

fn new_surface(&mut self, surface: &WlSurface) {
add_pre_commit_hook::<Self, _>(surface, move |state, _dh, surface| {
let mut acquire_point = None;
let maybe_dmabuf = with_states(surface, |surface_data| {
acquire_point = surface_data
.cached_state
.get::<DrmSyncobjCachedState>()
.pending()
.acquire_point
.clone();
surface_data
.cached_state
.get::<SurfaceAttributes>()
Expand All @@ -113,6 +121,25 @@ impl CompositorHandler for State {
})
});
if let Some(dmabuf) = maybe_dmabuf {
if let Some(acquire_point) = acquire_point {
if let Ok((blocker, source)) = acquire_point.generate_blocker() {
let client = surface.client().unwrap();
let res = state.common.event_loop_handle.insert_source(
source,
move |_, _, state| {
let dh = state.common.display_handle.clone();
state
.client_compositor_state(&client)
.blocker_cleared(state, &dh);
Ok(())
},
);
if res.is_ok() {
add_blocker(surface, blocker);
return;
}
}
}
if let Ok((blocker, source)) = dmabuf.generate_blocker(Interest::READ) {
let client = surface.client().unwrap();
let res =
Expand Down
19 changes: 19 additions & 0 deletions src/wayland/handlers/drm_syncobj.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
// SPDX-License-Identifier: GPL-3.0-only

use crate::state::{BackendData, State};
use smithay::{
delegate_drm_syncobj,
wayland::drm_syncobj::{DrmSyncobjHandler, DrmSyncobjState},
};

impl DrmSyncobjHandler for State {
fn drm_syncobj_state(&mut self) -> &mut DrmSyncobjState {
let kms = match &mut self.backend {
BackendData::Kms(kms) => kms,
_ => unreachable!(),
};
kms.syncobj_state.as_mut().unwrap()
}
}

delegate_drm_syncobj!(State);
1 change: 1 addition & 0 deletions src/wayland/handlers/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ pub mod decoration;
pub mod dmabuf;
pub mod drm;
pub mod drm_lease;
pub mod drm_syncobj;
pub mod foreign_toplevel_list;
pub mod fractional_scale;
pub mod idle_inhibit;
Expand Down

0 comments on commit 351a7f2

Please sign in to comment.