mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-02-16 21:05:15 +00:00
Code Issues Projects Releases Wiki Activity

awstranscriber: Avoid too large initial GAP event

Browse source 
Initialized GstSegment.position is always zero

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1154>
This commit is contained in:
Seungha Yang 2023-03-31 23:07:26 +09:00 committed by GStreamer Marge Bot
parent c6e1efa0fe
commit 4000d60305
1 changed files with 17 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
net/aws/src/transcriber/imp.rs
View file

@ -280,6 +280,16 @@ impl Transcriber {
) -> Result<gst::FlowSuccess, gst::FlowError> { ) -> Result<gst::FlowSuccess, gst::FlowError> {
gst::log!(CAT, obj: pad, "Handling {buffer:?}"); gst::log!(CAT, obj: pad, "Handling {buffer:?}");
if buffer.pts().is_none() {
gst::element_imp_error!(
self,
gst::StreamError::Format,
["Stream with timestamped buffers required"]
);
return Err(gst::FlowError::Error);
}
self.ensure_connection().map_err(|err| { self.ensure_connection().map_err(|err| {
gst::element_imp_error!(self, gst::StreamError::Failed, ["Streaming failed: {err}"]); gst::element_imp_error!(self, gst::StreamError::Failed, ["Streaming failed: {err}"]);
gst::FlowError::Error gst::FlowError::Error
@ -1311,12 +1321,12 @@ impl TranslationPadTask {
let (mut last_position, mut discont_pending) = { let (mut last_position, mut discont_pending) = {
let mut state = self.pad.state.lock().unwrap(); let mut state = self.pad.state.lock().unwrap();
let last_position = if let Some(pos) = state.out_segment.position() { if state.start_time.is_none() {
pos state.start_time = Some(start_time);
} else {
state.out_segment.set_position(start_time); state.out_segment.set_position(start_time);
start_time }
};
let last_position = state.out_segment.position().unwrap();
(last_position, state.discont_pending) (last_position, state.discont_pending)
}; };
@ -1517,6 +1527,7 @@ struct TranslationPadState {
discont_pending: bool, discont_pending: bool,
out_segment: gst::FormattedSegment<gst::ClockTime>, out_segment: gst::FormattedSegment<gst::ClockTime>,
task_abort_handle: Option<AbortHandle>, task_abort_handle: Option<AbortHandle>,
start_time: Option<gst::ClockTime>,
} }
impl Default for TranslationPadState { impl Default for TranslationPadState {
@ -1525,6 +1536,7 @@ impl Default for TranslationPadState {
discont_pending: true, discont_pending: true,
out_segment: Default::default(), out_segment: Default::default(),
task_abort_handle: None, task_abort_handle: None,
start_time: None,
} }
} }
} }