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-25 01:20:35 +00:00
Code Issues Projects Releases Wiki Activity

webrtcsink: avoid panic on unprepare from an async tokio context

Browse source 
.. and log an error with advice on how to dispose of elements properly
from a tokio runtime.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1253>
This commit is contained in:
Mathieu Duponchelle 2023-06-20 22:24:28 +02:00
parent f4324fd30e
commit d3cda3dd3a
1 changed files with 23 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
net/webrtc/src/webrtcsink/imp.rs
View file

@ -15,7 +15,7 @@ use anyhow::{anyhow, Error};
use once_cell::sync::Lazy;
use std::collections::HashMap;
use std::ops::Mul;
use std::sync::Mutex;
use std::sync::{mpsc, Mutex};
use super::homegrown_cc::CongestionController;
use super::{WebRTCSinkCongestionControl, WebRTCSinkError, WebRTCSinkMitigationMode};
@ -1266,7 +1266,7 @@ impl WebRTCSink {
}
if let Some(receiver) = state.codecs_done_receiver.take() {
RUNTIME.spawn(async {
RUNTIME.block_on(async {
let _ = receiver.await;
});
}
@ -2905,7 +2905,27 @@ impl ElementImpl for WebRTCSink {
match transition {
gst::StateChange::PausedToReady => {
if let Err(err) = self.unprepare(&element) {
let unprepare_res = match tokio::runtime::Handle::try_current() {
Ok(_) => {
gst::error!(
CAT,
obj: element,
"Trying to set state to NULL from an async \
tokio context, working around the panic but \
you should refactor your code to make use of \
gst::Element::call_async and set the state to \
NULL from there, without blocking the runtime"
);
let (tx, rx) = mpsc::channel();
element.call_async(move |element| {
tx.send(element.imp().unprepare(element)).unwrap();
});
rx.recv().unwrap()
}
Err(_) => self.unprepare(&element),
};
if let Err(err) = unprepare_res {
gst::element_error!(
element,
gst::StreamError::Failed,