hongshaorou/rustdesk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wayland filter last same frame

Browse Source 
Signed-off-by: fufesou <shuanglongchen@yeah.net>
This commit is contained in:
fufesou 2022-11-25 18:27:17 +08:00
parent 9dfa02a702
commit 87306a3d01
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
libs/scrap/src/wayland/pipewire.rs
View File

@ -122,6 +122,7 @@ pub struct PipeWireRecorder {
appsink: AppSink, appsink: AppSink,
width: usize, width: usize,
height: usize, height: usize,
saved_raw_data: Vec<u128>, // for faster compare and copy
} }
impl PipeWireRecorder { impl PipeWireRecorder {
@ -160,6 +161,7 @@ impl PipeWireRecorder {
height: 0, height: 0,
buffer_cropped: vec![], buffer_cropped: vec![],
is_cropped: false, is_cropped: false,
saved_raw_data: Vec::new(),
}) })
} }
} }
@ -192,6 +194,9 @@ impl Recorder for PipeWireRecorder {
let buf = buf let buf = buf
.into_mapped_buffer_readable() .into_mapped_buffer_readable()
.map_err(|_| GStreamerError("Failed to map buffer.".into()))?; .map_err(|_| GStreamerError("Failed to map buffer.".into()))?;
if let Err(..) = crate::would_block_if_equal(&mut self.saved_raw_data, buf.as_slice()) {
return Ok(PixelProvider::NONE);
}
let buf_size = buf.get_size(); let buf_size = buf.get_size();
// BGRx is 4 bytes per pixel // BGRx is 4 bytes per pixel
if buf_size != (w * h * 4) { if buf_size != (w * h * 4) {
@ -433,16 +438,10 @@ fn request_screen_cast(
if version >= 4 { if version >= 4 {
let restore_token = config::LocalConfig::get_option(RESTORE_TOKEN_CONF_KEY); let restore_token = config::LocalConfig::get_option(RESTORE_TOKEN_CONF_KEY);
if !restore_token.is_empty() { if !restore_token.is_empty() {
args.insert( args.insert(RESTORE_TOKEN.to_string(), Variant(Box::new(restore_token)));
RESTORE_TOKEN.to_string(),
Variant(Box::new(restore_token)),
);
} }
// persist_mode may be configured by the user. // persist_mode may be configured by the user.
args.insert( args.insert("persist_mode".to_string(), Variant(Box::new(2u32)));
"persist_mode".to_string(),
Variant(Box::new(2u32)),
);
} }
} }
args.insert( args.insert(