mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2024-06-08 09:19:23 +00:00
Code Issues Projects Releases Wiki Activity

livesync: Move single segment prop

Browse source 
Keep it with the settings, not after the stats.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1083>
This commit is contained in:
Jan Alexander Steffens (heftig) 2023-02-08 20:10:50 +01:00
parent 165b5f8c50
commit c971c4d1d5
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
utils/livesync/src/livesync/imp.rs
View file

@ -63,6 +63,7 @@ pub struct LiveSync {
struct State {
latency: gst::ClockTime,
late_threshold: Option<gst::ClockTime>,
single_segment: bool,
upstream_latency: Option<gst::ClockTime>,
fallback_duration: gst::ClockTime,
@ -93,17 +94,16 @@ struct State {
num_drop: u64,
num_out: u64,
num_duplicate: u64,
single_segment: bool,
}
const PROP_LATENCY: &str = "latency";
const PROP_LATE_THRESHOLD: &str = "late-threshold";
const PROP_SINGLE_SEGMENT: &str = "single-segment";
const PROP_IN: &str = "in";
const PROP_DROP: &str = "drop";
const PROP_OUT: &str = "out";
const PROP_DUPLICATE: &str = "duplicate";
const PROP_SINGLE_SEGMENT: &str = "single-segment";
const DEFAULT_LATENCY: gst::ClockTime = gst::ClockTime::ZERO;
const DEFAULT_DURATION: gst::ClockTime = gst::ClockTime::from_mseconds(100);
@ -115,6 +115,7 @@ impl Default for State {
Self {
latency: DEFAULT_LATENCY,
late_threshold: DEFAULT_LATE_THRESHOLD,
single_segment: false,
upstream_latency: None,
fallback_duration: DEFAULT_DURATION,
playing: false,
@ -137,7 +138,6 @@ impl Default for State {
num_drop: 0,
num_out: 0,
num_duplicate: 0,
single_segment: false,
}
}
}
@ -249,6 +249,11 @@ impl ObjectImpl for LiveSync {
.default_value(DEFAULT_LATE_THRESHOLD.into_glib())
.mutable_playing()
.build(),
glib::ParamSpecBoolean::builder(PROP_SINGLE_SEGMENT)
.nick("Single segment")
.blurb("Timestamp buffers and eat segments so as to appear as one segment")
.mutable_ready()
.build(),
glib::ParamSpecUInt64::builder(PROP_IN)
.nick("Frames input")
.blurb("Number of incoming frames accepted")
@ -269,11 +274,6 @@ impl ObjectImpl for LiveSync {
.blurb("Number of outgoing frames duplicated")
.read_only()
.build(),
glib::ParamSpecBoolean::builder(PROP_SINGLE_SEGMENT)
.nick("Single segment")
.blurb("Timestamp buffers and eat segments so as to appear as one segment")
.mutable_ready()
.build(),
]
});
@ -315,11 +315,11 @@ impl ObjectImpl for LiveSync {
match pspec.name() {
PROP_LATENCY => state.latency.to_value(),
PROP_LATE_THRESHOLD => state.late_threshold.to_value(),
PROP_SINGLE_SEGMENT => state.single_segment.to_value(),
PROP_IN => state.num_in.to_value(),
PROP_DROP => state.num_drop.to_value(),
PROP_OUT => state.num_out.to_value(),
PROP_DUPLICATE => state.num_duplicate.to_value(),
PROP_SINGLE_SEGMENT => state.single_segment.to_value(),
_ => unimplemented!(),
}
}