luca
/
gst-plugin-pingxelflut
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: add boolean property for diff-only mode

This commit is contained in:
Luca 2025-02-28 21:53:25 +01:00
parent 4a332db17e
commit 52dbf859ee
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/pingxelflutsink/imp.rs
View File

@ -1,4 +1,4 @@
use gstreamer::glib::{self, ParamSpec, ParamSpecString, Value}; use gstreamer::glib::{self, ParamSpec, ParamSpecBoolean, ParamSpecString, Value};
use gstreamer::prelude::*; use gstreamer::prelude::*;
use gstreamer::subclass::prelude::*; use gstreamer::subclass::prelude::*;
use gstreamer::subclass::ElementMetadata; use gstreamer::subclass::ElementMetadata;
@ -7,7 +7,6 @@ use gstreamer::{
FlowSuccess, LoggableError, PadDirection, PadPresence, PadTemplate, ResourceError, FlowSuccess, LoggableError, PadDirection, PadPresence, PadTemplate, ResourceError,
}; };
use gstreamer_base::prelude::*;
use gstreamer_base::subclass::prelude::*; use gstreamer_base::subclass::prelude::*;
use gstreamer_video::prelude::*; use gstreamer_video::prelude::*;
@ -34,6 +33,7 @@ static CAT: LazyLock<DebugCategory> = LazyLock::new(|| {
#[derive(Default)] #[derive(Default)]
struct Settings { struct Settings {
bind_address: Option<SocketAddr>, bind_address: Option<SocketAddr>,
diff_only: bool,
prefix: Option<Ipv6Addr>, prefix: Option<Ipv6Addr>,
} }
@ -71,6 +71,10 @@ impl ObjectImpl for PingxelflutSink {
.nick("Bind address") .nick("Bind address")
.blurb("Local address to bind to") .blurb("Local address to bind to")
.build(), .build(),
ParamSpecBoolean::builder("diff-only")
.nick("Diff only")
.blurb("Only send pixels different from previous frame")
.build(),
ParamSpecString::builder("prefix") ParamSpecString::builder("prefix")
.nick("Destination prefix") .nick("Destination prefix")
.blurb("Prefix of pingxelflut server") .blurb("Prefix of pingxelflut server")
@ -92,6 +96,9 @@ impl ObjectImpl for PingxelflutSink {
.map(|s| s.parse().ok()) .map(|s| s.parse().ok())
.unwrap_or(None); .unwrap_or(None);
} }
"diff-only" => {
settings.diff_only = value.get::<bool>().unwrap();
}
"prefix" => { "prefix" => {
settings.prefix = value settings.prefix = value
.get::<Option<String>>() .get::<Option<String>>()
@ -112,6 +119,7 @@ impl ObjectImpl for PingxelflutSink {
.as_ref() .as_ref()
.map(|addr| addr.to_string()) .map(|addr| addr.to_string())
.to_value(), .to_value(),
"diff-only" => settings.diff_only.to_value(),
"prefix" => settings "prefix" => settings
.prefix .prefix
.as_ref() .as_ref()
@ -244,11 +252,13 @@ impl VideoSinkImpl for PingxelflutSink {
(y * frame.plane_stride()[0] as u32 + x * frame.n_components()) as usize; (y * frame.plane_stride()[0] as u32 + x * frame.n_components()) as usize;
let (r, g, b) = (data[i] as u16, data[i + 1] as u16, data[i + 2] as u16); let (r, g, b) = (data[i] as u16, data[i + 1] as u16, data[i + 2] as u16);
if prev_frame.as_ref().map_or(false, |f| { if settings.diff_only
f.plane_data(0).is_ok_and(|d| { && prev_frame.as_ref().map_or(false, |f| {
d[i] as u16 == r && d[i + 1] as u16 == g && d[i + 2] as u16 == b f.plane_data(0).is_ok_and(|d| {
d[i] as u16 == r && d[i + 1] as u16 == g && d[i + 2] as u16 == b
})
}) })
}) { {
continue; continue;
} }