chris/iced_video_player
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

pull sample or preroll with timeout

Browse source
This commit is contained in:
jazzfool 2024-10-02 17:18:27 +10:00
parent d7e5399bc6
commit fa02ee5652
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/video.rs
View file

@ -238,7 +238,6 @@ impl Video {
let alive = Arc::new(AtomicBool::new(true)); let alive = Arc::new(AtomicBool::new(true));
let last_frame_time = Arc::new(Mutex::new(Instant::now())); let last_frame_time = Arc::new(Mutex::new(Instant::now()));
let pipeline_ref = pipeline.clone();
let frame_ref = Arc::clone(&frame); let frame_ref = Arc::clone(&frame);
let upload_frame_ref = Arc::clone(&upload_frame); let upload_frame_ref = Arc::clone(&upload_frame);
let alive_ref = Arc::clone(&alive); let alive_ref = Arc::clone(&alive);
@ -246,11 +245,14 @@ impl Video {
let worker = std::thread::spawn(move || { let worker = std::thread::spawn(move || {
while alive_ref.load(Ordering::Acquire) { while alive_ref.load(Ordering::Acquire) {
if pipeline_ref.state(None).1 == gst::State::Paused { let frame_interval = std::time::Duration::from_secs_f64(1.0 / framerate);
std::thread::sleep(std::time::Duration::from_secs_f64(1.0 / framerate));
}
if let Err(gst::FlowError::Error) = (|| -> Result<(), gst::FlowError> { if let Err(gst::FlowError::Error) = (|| -> Result<(), gst::FlowError> {
let sample = app_sink.pull_sample().map_err(|_| gst::FlowError::Eos)?; let timeout =
gst::ClockTime::from_nseconds(2 * frame_interval.as_nanos() as u64);
let sample = app_sink
.try_pull_sample(timeout)
.or_else(|| app_sink.try_pull_preroll(timeout))
.ok_or(gst::FlowError::Eos)?;
let buffer = sample.buffer().ok_or(gst::FlowError::Error)?; let buffer = sample.buffer().ok_or(gst::FlowError::Error)?;
let map = buffer.map_readable().map_err(|_| gst::FlowError::Error)?; let map = buffer.map_readable().map_err(|_| gst::FlowError::Error)?;