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-09-24 13:00:12 +00:00
Code Issues Projects Releases Wiki Activity

threadshare: src elements: don't reset configured_caps

Browse source 
See https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/issues/113
This commit is contained in:
François Laignel 2020-04-29 21:37:22 +02:00
parent 8e38d861b4
commit 4cba9d1e53
3 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
generic/threadshare/src/appsrc.rs
View file

@ -167,9 +167,8 @@ impl AppSrcPadHandler {
.caps = caps;
}
fn reset(&self) {
fn reset_state(&self) {
*self.0.state.try_lock().expect("State locked elsewhere") = Default::default();
*self.0.configured_caps.lock().unwrap() = None;
}
fn set_need_segment(&self) {
@ -445,7 +444,7 @@ impl AppSrc {
gst_debug!(CAT, obj: element, "Stopping");
self.flush(element);
self.src_pad_handler.reset();
self.src_pad_handler.reset_state();
*state = AppSrcState::RejectBuffers;
gst_debug!(CAT, obj: element, "Stopped");

5
generic/threadshare/src/tcpclientsrc.rs
View file

@ -206,9 +206,8 @@ impl TcpClientSrcPadHandler {
.caps = caps;
}
fn reset(&self) {
fn reset_state(&self) {
*self.0.state.try_lock().expect("State locked elsewhere") = Default::default();
*self.0.configured_caps.lock().unwrap() = None;
}
fn set_need_segment(&self) {
@ -460,7 +459,7 @@ impl TcpClientSrc {
gst_debug!(CAT, obj: element, "Stopping");
self.task.stop();
self.src_pad_handler.reset();
self.src_pad_handler.reset_state();
gst_debug!(CAT, obj: element, "Stopped");

5
generic/threadshare/src/udpsrc.rs
View file

@ -255,9 +255,8 @@ impl UdpSrcPadHandler {
state.retrieve_sender_address = retrieve_sender_address;
}
fn reset(&self) {
fn reset_state(&self) {
*self.0.state.try_lock().expect("State locked elsewhere") = Default::default();
*self.0.configured_caps.lock().unwrap() = None;
}
fn set_need_segment(&self) {
@ -631,7 +630,7 @@ impl UdpSrc {
gst_debug!(CAT, obj: element, "Stopping");
self.task.stop();
self.src_pad_handler.reset();
self.src_pad_handler.reset_state();
gst_debug!(CAT, obj: element, "Stopped");