mirror of
https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git
synced 2024-06-02 21:39:23 +00:00
Update for ClockId creation API changes
This commit is contained in:
parent
9d394d39ed
commit
bbc18d6349
|
@ -802,7 +802,7 @@ impl PushSrcImpl for SineSrc {
|
||||||
return Err(gst::FlowError::Flushing);
|
return Err(gst::FlowError::Flushing);
|
||||||
}
|
}
|
||||||
|
|
||||||
let id = clock.new_single_shot_id(wait_until).unwrap();
|
let id = clock.new_single_shot_id(wait_until);
|
||||||
clock_wait.clock_id = Some(id.clone());
|
clock_wait.clock_id = Some(id.clone());
|
||||||
drop(clock_wait);
|
drop(clock_wait);
|
||||||
|
|
||||||
|
|
|
@ -705,7 +705,7 @@ For working in live mode, we have to add a few different parts in various places
|
||||||
return Ok(buffer);
|
return Ok(buffer);
|
||||||
}
|
}
|
||||||
|
|
||||||
let id = clock.new_single_shot_id(wait_until).unwrap();
|
let id = clock.new_single_shot_id(wait_until);
|
||||||
|
|
||||||
gst_log!(
|
gst_log!(
|
||||||
CAT,
|
CAT,
|
||||||
|
@ -863,7 +863,7 @@ Now as a last step, we need to actually make use of the new struct we added arou
|
||||||
return Err(gst::FlowReturn::Flushing);
|
return Err(gst::FlowReturn::Flushing);
|
||||||
}
|
}
|
||||||
|
|
||||||
let id = clock.new_single_shot_id(wait_until).unwrap();
|
let id = clock.new_single_shot_id(wait_until);
|
||||||
clock_wait.clock_id = Some(id.clone());
|
clock_wait.clock_id = Some(id.clone());
|
||||||
drop(clock_wait);
|
drop(clock_wait);
|
||||||
|
|
||||||
|
|
|
@ -2022,9 +2022,7 @@ impl FallbackSrc {
|
||||||
assert!(wait_time.is_some());
|
assert!(wait_time.is_some());
|
||||||
assert!(state.source_pending_restart_timeout.is_none());
|
assert!(state.source_pending_restart_timeout.is_none());
|
||||||
|
|
||||||
let timeout = clock
|
let timeout = clock.new_single_shot_id(wait_time);
|
||||||
.new_single_shot_id(wait_time)
|
|
||||||
.expect("can't create clock id");
|
|
||||||
let element_weak = element.downgrade();
|
let element_weak = element.downgrade();
|
||||||
timeout
|
timeout
|
||||||
.wait_async(move |_clock, _time, _id| {
|
.wait_async(move |_clock, _time, _id| {
|
||||||
|
@ -2140,9 +2138,7 @@ impl FallbackSrc {
|
||||||
wait_time,
|
wait_time,
|
||||||
);
|
);
|
||||||
|
|
||||||
let timeout = clock
|
let timeout = clock.new_single_shot_id(wait_time);
|
||||||
.new_single_shot_id(wait_time)
|
|
||||||
.expect("can't create clock id");
|
|
||||||
let element_weak = element.downgrade();
|
let element_weak = element.downgrade();
|
||||||
timeout
|
timeout
|
||||||
.wait_async(move |_clock, _time, _id| {
|
.wait_async(move |_clock, _time, _id| {
|
||||||
|
|
|
@ -548,7 +548,7 @@ fn stop_pipeline(mut pipeline: Pipeline) {
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
// Signal shutdown to the clock thread
|
// Signal shutdown to the clock thread
|
||||||
let clock_id = clock.new_single_shot_id(0.into()).unwrap();
|
let clock_id = clock.new_single_shot_id(0.into());
|
||||||
let _ = clock_id.wait();
|
let _ = clock_id.wait();
|
||||||
|
|
||||||
let switch = pipeline.get_by_name("switch").unwrap();
|
let switch = pipeline.get_by_name("switch").unwrap();
|
||||||
|
|
Loading…
Reference in a new issue