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-12-02 00:11:01 +00:00
Code Issues Projects Releases Wiki Activity

Only consider timeouts if configure bigger than 0

Browse source 
Configuring 0 will never time out.
This commit is contained in:
Sebastian Dröge 2020-09-01 21:38:13 +03:00
parent 9d4e427e14
commit 3ea203825a
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/receiver.rs
View file

@ -907,7 +907,7 @@ impl Receiver<VideoReceiver> {
); );
return Err(gst::FlowError::Error); return Err(gst::FlowError::Error);
} }
Ok(None) if timer.elapsed().as_millis() >= timeout as u128 => { Ok(None) if timeout > 0 && timer.elapsed().as_millis() >= timeout as u128 => {
gst_debug!(self.0.cat, obj: element, "Timed out -- assuming EOS",); gst_debug!(self.0.cat, obj: element, "Timed out -- assuming EOS",);
return Err(gst::FlowError::Eos); return Err(gst::FlowError::Eos);
} }
@ -1335,7 +1335,7 @@ impl Receiver<AudioReceiver> {
); );
return Err(gst::FlowError::Error); return Err(gst::FlowError::Error);
} }
Ok(None) if timer.elapsed().as_millis() >= timeout as u128 => { Ok(None) if timeout > 0 && timer.elapsed().as_millis() >= timeout as u128 => {
gst_debug!(self.0.cat, obj: element, "Timed out -- assuming EOS",); gst_debug!(self.0.cat, obj: element, "Timed out -- assuming EOS",);
return Err(gst::FlowError::Eos); return Err(gst::FlowError::Eos);
} }